C#的ODBC和Mysql的链接

chenhailong

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Data.SqlClient;using MySQLDriverCS;using System.Data;namespace ADONet{    class Program    {        static void Main(string[] args)        {            MySQLConnection conn = null;            try            {                conn = getMySqlCon();                conn.Open();                Console.WriteLine("链接成功");                String sqlcoding = "set names gb2312";                MySQLCommand commn = getSqlCommand(sqlcoding, conn);                commn.ExecuteNonQuery();                string sql = "select * from test ";                MySQLCommand mda = getSqlCommand(sql, conn);                MySQLDataReader reader = getResultSet(mda);                while (reader.Read())                {                    if (reader.HasRows)                    {                        Console.WriteLine("编号:" + reader.GetString(0) + "|姓名:" + reader.GetString(1) + "|年龄:" + reader.GetString(2) + "|性别:" + reader.GetString(3));                    }                }                Console.ReadKey();                conn.Close();            }            catch (Exception e)            {                Console.WriteLine(e.Message);            }            finally            {                conn.Close();                Console.ReadKey();            }        }        /// <summary>        /// 建立mysql数据库链接        /// </summary>        /// <returns></returns>        public static MySQLConnection getMySqlCon()        {            String mysqlStr = "Data Source=test;Password=chenhailong;User ID=root;Location=localhost;Port=3306;database=test;CharSet=utf8;port=3306";            //String mySqlCon = new MySQLConnectionString("localhost", "test", "root", "chenhailong").AsString;            MySQLConnection mysql = new MySQLConnection(mysqlStr);            return mysql;        }        /// <summary>        /// 建立执行命令语句对象        /// </summary>        /// <param name="sql"></param>        /// <param name="mysql"></param>        /// <returns></returns>        public static MySQLCommand getSqlCommand(String sql, MySQLConnection mysql)        {            MySQLCommand mySqlCommand = new MySQLCommand(sql, mysql);            //  MySqlCommand mySqlCommand = new MySqlCommand(sql);            // mySqlCommand.Connection = mysql;            return mySqlCommand;        }        /// <summary>        /// 查询并获得结果集并遍历        /// </summary>        /// <param name="mySqlCommand"></param>        public static void getResultset(MySQLCommand mySqlCommand)        {            MySQLDataReader reader = mySqlCommand.ExecuteReaderEx();            try            {                while (reader.Read())                {                    if (reader.HasRows)                    {                        Console.WriteLine("编号:" + reader.GetInt32(0) + "|姓名:" + reader.GetString(1) + "|年龄:" + reader.GetInt32(2) + "|学历:" + reader.GetString(3));                    }                }            }            catch (Exception)            {                Console.WriteLine("查询失败了！");            }            finally            {                reader.Close();            }        }        /// <summary>        /// 得到ResultSet        /// </summary>        /// <param name="mySqlCommand"></param>        /// <returns>MySQLDataReader</returns>        public static MySQLDataReader getResultSet(MySQLCommand mySqlCommand)        {            MySQLDataReader reader = mySqlCommand.ExecuteReaderEx();            return reader;        }        /// <summary>        /// 添加数据        /// </summary>        /// <param name="mySqlCommand"></param>        public static void getInsert(MySQLCommand mySqlCommand)        {            try            {                mySqlCommand.ExecuteNonQuery();            }            catch (Exception ex)            {                String message = ex.Message;                Console.WriteLine("插入数据失败了！" + message);            }        }        /// <summary>        /// 修改数据        /// </summary>        /// <param name="mySqlCommand"></param>        public static void getUpdate(MySQLCommand mySqlCommand)        {            try            {                mySqlCommand.ExecuteNonQuery();            }            catch (Exception ex)            {                String message = ex.Message;                Console.WriteLine("修改数据失败了！" + message);            }        }        /// <summary>        /// 删除数据        /// </summary>        /// <param name="mySqlCommand"></param>        public static void getDel(MySQLCommand mySqlCommand)        {            try            {                mySqlCommand.ExecuteNonQuery();            }            catch (Exception ex)            {                String message = ex.Message;                Console.WriteLine("删除数据失败了！" + message);            }        }        /// <summary>        /// 得到操作        /// </summary>        public static void setValue()        {            string dataDir = AppDomain.CurrentDomain.BaseDirectory;            if (dataDir.EndsWith(@"\bin\Debug\")                    || dataDir.EndsWith(@"\bin\Release\"))            {                dataDir = System.IO.Directory.GetParent(dataDir).Parent.Parent.FullName;                AppDomain.CurrentDomain.SetData("DataDirectory", dataDir);            }        }    }}