C# 如何连接操作 MySQL 数据库(使用 SourceForge 上的驱动)

 1using System;
 2using System.IO;
 3
 4using MySQLDriverCS; //引入的命名空间就这个
 5using System.Data.Common;
 6
 7namespace cc.unmi
 8{
 9    public class Program
10    {
11        public static void Main(string[] args)
12        {
13            //MySQLDriverCS 有了 MySQLConnectionStringBuilder 和 MySQLConnectionString 来构造连接字符串
14            //其实反而有点故弄玄虚，也许是以前直接用连接字符串习惯了
15            MySQLConnectionString conStr = new MySQLConnectionString("localhost", "unmi_db", "unmi", "xxxxxx");
16
17            //从 MySQLConnectionStringBuilder 来看似乎可支持的属性较少，不知道连接池那些功能怎么样
18            //string connStr = "Data Source=unmi_db;Password=xxxxxx;User ID=unmi;Location=localhost;Port=3306;Extended Properties=";
19
20            MySQLConnection conn = new MySQLConnection(conStr.AsString); //或 new MySQLConnection(connStr);
21
22            conn.Open();
23
24            //参数用 @, 同样支持 ? 的方式, 应该也是不推荐用 ? 的形式
25            //string sql = "update wp_options set option_value='http://unmi.cc' where option_id=?id and <a href="mailto:option_name=@name">option_name=@name</a>";
26            string sql = "select option_name from wp_options where option_id=?id and <a href="mailto:option_name=@name">option_name=@name</a>";
27
28            MySQLCommand com = new MySQLCommand(sql, conn);
29
30            MySQLParameter paraId = new MySQLParameter("?id", 1);
31            MySQLParameter paraName = new MySQLParameter("@name", "siteurl");
32
33            //其实是加在 MySQLParameterCollection 里的
34            //看起来与 AddWithValue() 有异曲同功之妙，比如可写成 com.Parameters.Add(new MySQLParameter("@id",1);
35            com.Parameters.Add(paraId);
36            com.Parameters.Add(paraName);
37
38            //如果是查询
39            //MySQLDataReader dr = com.ExecuteReaderEx();//执行 ExecuteReaderEx() 返回的才是 MySQLDataReader
40
41            DbTransaction trans = conn.BeginTransaction(); //开启事物
42
43            try
44            {
45                //com.ExecuteNonQuery();
46                //还要执行更多的语句时应使用事物
47                Console.WriteLine(com.ExecuteScalar().ToString());
48                trans.Commit();
49            }
50            catch (MySQLException ex)
51            {
52                Console.WriteLine(ex.Message);
53                trans.Rollback();
54            }
55            finally
56            {
57                conn.Close();
58            }
59
60            Console.ReadKey();
61        }
62    }
63}

 1 new MySQLInsertCommand(
 2     dbCon,//连接
 3     new object[,] { //字段名及对应值
 4         {"SettingID",100},
 5         {"SettingValue","<a href="http://unmi.cc/">http://unmi.cc</a>"}
 6     },
 7     "Settings" //表名
 8 ); //new 后即执行，可用 bSuccess 与 Query 属性分别获得成功与否及相应的 SQL
 9
10 //这个 MySQLSelectCommand 有点让人蛋疼，还不如直接 SQL 痛快
11 DataTable dt = new MySQLSelectCommand(dbCon, //连接
12     new string[] { "SettingID", "SettingValue" },//要查询的字段列表
13     new string[] { "Settings" }, // 要查询的表，可以多个
14     new object[,] { { "SettingID", "=", 100 } },//条件
15     null,
16     null //后面还可以有 limit, distinct 等指令及参数
17 ).Table; //获得 DataTable
18
19 //更新时用这种方式还算方便
20 new MySQLUpdateCommand(dbCon,
21     new object[,] { { "SettingValue", "<a href="http://unmi.cc/">http://unmi.cc</a>" } },
22     "Settings",
23     new object[,] { { "SettingID", "=", 100 } },
24     null
25 ); //new 后即执行，可用 bSuccess 与 Query 属性分别获得成功与否及相应的 SQL
26
27 //参数与 MySQLUpdateCommand 的后四个相同
28 new MySQLDeleteCommand(dbCon, "Trash", null, null);