`

C#的ODBC和Mysql的链接

    博客分类:
  • C#
阅读更多
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);
            }
        }
    }
}

 

0
0
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics