Mysql操作方法類

幫助類：

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資料庫連接
/// <summary>
/// 建立資料庫連接.
/// </summary>
/// <returns>返回MySqlConnection對象</returns>
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命令
/// <summary>
/// 執行MySqlCommand
/// </summary>
/// <param name="M_str_sqlstr">SQL語句</param>
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對象
/// <summary>
/// 創建一個MySqlDataReader對象
/// </summary>
/// <param name="M_str_sqlstr">SQL語句</param>
/// <returns>返回MySqlDataReader對象</returns>
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