C#連接MySql數據庫

1、要連接MySql數據庫必須首先下載MySql官方的連接.net的文件，文件下載地址為http://dev.mysql.com/downloads/connector/net/6.6.html#downloads ，下載平台選擇.Net&Mono,下載ZIP免安裝版。
2、解壓縮剛才下載的mysql-connector-net-6.6.6-noinstall.zip文件，里面有幾個版本選擇，在這里我選V4，
然后添加mysqlData.dll到C#項目的引用中，然后就可以編寫程序進行數據庫的操作了。
3、數據庫操作代碼 InsertMySql.cs
<pre name="code" class="csharp">using System;
using System.Collections;
using System.Linq;
using System.Text;
using MySql.Data;
using MySql.Data.MySqlClient;
using System.Data;
namespace Sql
{
    class InsertSql
    {
        public MySqlConnection myCon;
        public InsertSql()    //連接數據庫  
        {
            string constr = "server=localhost;User Id=root;password=016457t;Database=car_flow";
            myCon = new MySqlConnection(constr);  
        }
        public bool OpenMysql()     //打開數據庫 
        {
            try
            {
                myCon.Open();         
            }
            catch
            {
                return false;
            }
            return true;
        }
        public MySqlCommand ExcuteOrder(string sql,MySqlConnection myCon)     //執行命令語句sql
        {
            MySqlCommand myCom = new MySqlCommand(sql, myCon);
            return myCom;
        }
        public void GetSerchResult(MySqlCommand myCom)    //獲取查詢結果
        {
            try
            {
                MySqlDataReader msDr = myCom.ExecuteReader();
                int column = msDr.FieldCount;  //獲取集合列數
                while (msDr.Read())
                {
                    if (msDr.HasRows)
                    {
                        for (int i = 0; i < column; i++)
                        {
                            Console.Write(msDr.GetString(i) + "  ");
                        }
                        Console.WriteLine();
                    }
                }
                msDr.Close();      //關閉數據集
            }
            catch(Exception e)
            {
                Console.WriteLine(e.Data);
                Console.WriteLine("獲取查詢結果集出錯");
            }
        }
        public void GetDelInsertUpdateResult(MySqlCommand myCom)       //獲取刪、插、更新執行結果
        {
            try
            {
                myCom.ExecuteNonQuery();
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Data);
                Console.WriteLine("執行出錯");
            }
        }
        public void CloseMySqlConnection()      //關閉數據庫連接句柄
        {
            myCon.Close();
        }
        public static void Main()
        {
            InsertSql insertsql = new InsertSql();
            string quest = "select *from car_whether where 時間=20160328";  //查詢語句
            insertsql.OpenMysql();  //打開數據庫
            MySqlCommand myCom=insertsql.ExcuteOrder(quest, insertsql.myCon);  //執行操作
            insertsql.GetSerchResult(myCom);  //獲取查詢集並輸出
            insertsql.CloseMySqlConnection();  //關閉連接
        }
    }
}