using System;
using System.IO;
 
using MySQLDriverCS; //引入的命名空間就這個(gè)
using System.Data.Common;
 
namespace cc.unmi
{
    public class Program
    {
        public static void Main(string[] args)
        {
            //MySQLDriverCS 有了 MySQLConnectionStringBuilder 和 MySQLConnectionString 來構(gòu)造連接字符串
            //其實(shí)反而有點(diǎn)故弄玄虛，也許是以前直接用連接字符串習(xí)慣了
            MySQLConnectionString conStr = new MySQLConnectionString("localhost", "unmi_db", "unmi", "xxxxxx");
 
            //從 MySQLConnectionStringBuilder 來看似乎可支持的屬性較少，不知道連接池那些功能怎么樣
            //string connStr = "Data Source=unmi_db;Password=xxxxxx;User ID=unmi;Location=localhost;Port=3306;Extended Properties=";
 
            MySQLConnection conn = new MySQLConnection(conStr.AsString); //或 new MySQLConnection(connStr);
 
            conn.Open();
 
            //參數(shù)用 @, 同樣支持 ? 的方式, 應(yīng)該也是不推薦用 ? 的形式
            //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>";
            string sql = "select option_name from wp_options where option_id=?id and <a href="mailto:option_name=@name">option_name=@name</a>";
 
            MySQLCommand com = new MySQLCommand(sql, conn);
 
            MySQLParameter paraId = new MySQLParameter("?id", 1);
            MySQLParameter paraName = new MySQLParameter("@name", "siteurl");
 
            //其實(shí)是加在 MySQLParameterCollection 里的
            //看起來與 AddWithValue() 有異曲同功之妙，比如可寫成 com.Parameters.Add(new MySQLParameter("@id",1);
            com.Parameters.Add(paraId);
            com.Parameters.Add(paraName);
 
            //如果是查詢
            //MySQLDataReader dr = com.ExecuteReaderEx();//執(zhí)行 ExecuteReaderEx() 返回的才是 MySQLDataReader
 
            DbTransaction trans = conn.BeginTransaction(); //開啟事物
 
            try
            {
                //com.ExecuteNonQuery();
                //還要執(zhí)行更多的語句時(shí)應(yīng)使用事物
                Console.WriteLine(com.ExecuteScalar().ToString());
                trans.Commit();
            }
            catch (MySQLException ex)
            {
                Console.WriteLine(ex.Message);
                trans.Rollback();
            }
            finally
            {
                conn.Close();
            }
 
            Console.ReadKey();
        }
    }
}

{"Could not load file or assembly 'MySQLDriverCS, Version=3.0.1735.36021, Culture=neutral, PublicKeyToken=172f94dfb0faf263' or one of its dependencies. An attempt was made to load a program with an incorrect format."}

 new MySQLInsertCommand(
                dbCon,//連接
                new object[,] { //字段名及對(duì)應(yīng)值
                    {"SettingID",100},
                    {"SettingValue","http://www.fzitv.net"}
                },
                "Settings" //表名
            ); //new 后即執(zhí)行，可用 bSuccess 與 Query 屬性分別獲得成功與否及相應(yīng)的 SQL
 
            //這個(gè) MySQLSelectCommand 有點(diǎn)讓人蛋疼，還不如直接 SQL 痛快
            DataTable dt = new MySQLSelectCommand(dbCon, //連接
                new string[] { "SettingID", "SettingValue" },//要查詢的字段列表
                new string[] { "Settings" }, // 要查詢的表，可以多個(gè)
                new object[,] { { "SettingID", "=", 100 } },//條件
                null,
                null //后面還可以有 limit, distinct 等指令及參數(shù)
            ).Table; //獲得 DataTable
 
            //更新時(shí)用這種方式還算方便
            new MySQLUpdateCommand(dbCon,
                new object[,] { { "SettingValue", "http://www.fzitv.net" } },
                "Settings",
                new object[,] { { "SettingID", "=", 100 } },
                null
            ); //new 后即執(zhí)行，可用 bSuccess 與 Query 屬性分別獲得成功與否及相應(yīng)的 SQL
 
            //參數(shù)與 MySQLUpdateCommand 的后四個(gè)相同
            new MySQLDeleteCommand(dbCon, "Trash", null, null);