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=[sqlstr1,sqlstr2,sqlstr3],返回受影响的行数
  
•         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();
  
•                 }
  
•             }
  
•         }
  
•     }
  
• }