C# 使用mysql-connector-net连接mysql
1、下载 mysql-connector-net包；2、引用 mysql-connector-net包中的MySql.Data.dll；
3、程序源代码：
[*]using System;
[*]using System.Collections.Generic;
[*]using System.Linq;
[*]using System.Text;
[*]using System.Data;
[*]using MySql.Data.MySqlClient;
[*]
[*]namespace Document_convert.DB
[*]{
[*] class MYSQL
[*] {
[*] #region建立MySql数据库连接
[*] ///
[*] /// 建立数据库连接.
[*] ///
[*] /// 返回MySqlConnection对象
[*] public MySqlConnection getmysqlcon()
[*] {
[*] string M_str_sqlcon = "server=localhost;user id=root;password=phpwind.net;database=phpcmsv9;"; //根据自己的设置
[*] MySqlConnection myCon = new MySqlConnection(M_str_sqlcon);
[*] return myCon;
[*] }
[*] #endregion
[*] //建立数据库连接字符串
[*] private static string connectionString = "Server=localhost;Uid=root;Pwd=phpwind.net;Database=phpcmsv9;Port=3306;charset=utf8";
[*] //建立查询，返回DataSet数据集
[*] public static DataSet Query(string SQLString)
[*] {
[*] using (MySqlConnection connection = new MySqlConnection(connectionString))
[*] {
[*] DataSet ds = new DataSet();
[*] try
[*] {
[*] connection.Open();
[*] MySqlDataAdapter command = new MySqlDataAdapter(SQLString, connection);
[*] command.Fill(ds);
[*] }
[*] catch (System.Data.SqlClient.SqlException ex)
[*] {
[*] throw new Exception(ex.Message);
[*] }
[*] finally
[*] {
[*] connection.Close();
[*] }
[*] return ds;
[*] }
[*] }
[*] //建立查询，返回受影响的行数
[*] public static int ExecuteSql(string SQLString)
[*] {
[*] using (MySqlConnection connection = new MySqlConnection(connectionString))
[*] {
[*] using (MySqlCommand cmd = new MySqlCommand(SQLString, connection))
[*] {
[*] try
[*] {
[*] connection.Open();
[*] int rows = cmd.ExecuteNonQuery();
[*] return rows;
[*] }
[*] catch (System.Data.SqlClient.SqlException e)
[*] {
[*] connection.Close();
[*] throw e;
[*] }
[*] finally
[*] {
[*] cmd.Dispose();
[*] connection.Close();
[*] }
[*] }
[*] }
[*] }
[*] //建立数组查询arrSql=,返回受影响的行数
[*] public static int ExecuteSql(string[] arrSql)
[*] {
[*] using (MySqlConnection connection = new MySqlConnection(connectionString))
[*] {
[*]
[*] try
[*] {
[*] connection.Open();
[*] //MySqlCommand cmdEncoding = new MySqlCommand(SET_ENCODING, connection);
[*] //cmdEncoding.ExecuteNonQuery();
[*] int rows = 0;
[*] foreach (string strN in arrSql)
[*] {
[*] using (MySqlCommand cmd = new MySqlCommand(strN, connection))
[*] {
[*] rows += cmd.ExecuteNonQuery();
[*] }
[*] }
[*] return rows;
[*] }
[*] catch (System.Data.SqlClient.SqlException e)
[*] {
[*] connection.Close();
[*] throw e;
[*] }
[*] finally
[*] {
[*] connection.Close();
[*] }
[*] }
[*] }
[*] }
[*]}
页:
[1]