帮助类：
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
namespace TestMYSQL
{
public class MySqlHelper
{
string M_str_sqlcon = string.Empty;
private MySqlHelper()
{
}
public MySqlHelper(string str_sqlcon)
{
M_str_sqlcon = str_sqlcon;
}
region 建立MySql数据库连接
///
/// 建立数据库连接.
///
/// 返回MySqlConnection对象
private MySqlConnection getmysqlcon()
{
//string M_str_sqlcon = “server=localhost;user id=root;password=root;database=abc”; //根据自己的设置
MySqlConnection myCon = new MySqlConnection(M_str_sqlcon);
return myCon;
}
endregion
region 执行MySqlCommand命令
///
/// 执行MySqlCommand
///
/// SQL语句
public int getmysqlcom(string M_str_sqlstr)
{
int rel = 0;
MySqlConnection mysqlcon=null;
MySqlCommand mysqlcom=null;
try
{
mysqlcon = this.getmysqlcon();
mysqlcon.Open();
mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
rel = mysqlcom.ExecuteNonQuery();
return rel;
}
catch (Exception ex)
{
throw ex;
}
finally
{
if (mysqlcom != null)
{
mysqlcom.Dispose();
}
if (mysqlcon != null)
{
mysqlcon.Close();
mysqlcon.Dispose();
}
}
}
endregion
region 创建MySqlDataReader对象
///
/// 创建一个MySqlDataReader对象
///
/// SQL语句
/// 返回MySqlDataReader对象
public MySqlDataReader getmysqlread(string M_str_sqlstr)
{
MySqlConnection mysqlcon = null;
MySqlCommand mysqlcom = null;
try
{
mysqlcon = this.getmysqlcon();
mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
mysqlcon.Open();
MySqlDataReader mysqlread = mysqlcom.ExecuteReader(CommandBehavior.CloseConnection);
return mysqlread;
}
catch (Exception ex)
{
throw ex;
}
finally
{
if (mysqlcom != null)
{
mysqlcom.Dispose();
}
if (mysqlcon != null)
{
mysqlcon.Close();
mysqlcon.Dispose();
}
}
}
endregion
}
}
后台：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace SQLToMysql_Move
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
TestMYSQL.MySqlHelper mysql = new TestMYSQL.MySqlHelper(“server=127.0.0.1;user id=root;password=123456;database=ce”);
private void button1_Click(object sender, EventArgs e)
{
int rel = 0;
try
{
DataSet dataset = Common.DbHelperSQL.Query(“select * from dbo.Num”);
DataTable dt = dataset.Tables[0];
dataGridView1.DataSource = dt;
for (int i = 0; i < dt.Rows.Count ; i++)
{
label1.Text = dt.Rows[i][0].ToString();
label2.Text = dt.Rows[i][1].ToString();
rel = mysql.getmysqlcom(“INSERT INTO ce.notice (Content, Start_date, End_date) VALUES (‘” + dt.Rows[i][1].ToString() + “‘, ‘” + dt.Rows[i][0].ToString() + “‘, ‘2‘);”);
}
MessageBox.Show((rel > 0) ? “成功” : “失败”);
}
catch (Exception ex)
{
throw ex;
}
//TestMYSQL.MySqlHelper mysql = new TestMYSQL.MySqlHelper(“server=127.0.0.1;user id=root;password=123456;database=ce”);
//string sql = “INSERT INTO ce.notice (Id, Content, Start_date, End_date) VALUES (‘2‘, ‘2‘, ‘2‘, ‘2‘);”;
//try
//{
// int rel = mysql.getmysqlcom(sql);
// MessageBox.Show((rel > 0) ? “成功” : “失败”);
//}
//catch (Exception ex)
//{
// MessageBox.Show(ex.Message);
//}
}
}
}
相关DLL:
https://i.cnblogs.com/Files.aspx