C#的ODBC和Mysql的链接
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); } } }}
页:
[1]