一、准备工具
visual stuido（本示例使用visual studio 2010）
mysql.data.dll
mysql_installer_community_v5.6.21.1_setup.1415604646.msi
二、新建dbutility通用访问mysql类库
1、在解决方案中新建一个dbutility类库，作为访问mysql的通用sql语句存放地点
2、引入mysql.data.dll
3、配置web.config mysql数据库连接字符串
在解决方案根目录下打开web.config配置文件，在connectionstrings节点中加入mysql连接字符串
4、新建sqlhelper通用mysql访问类，该类的定义如下：
/// ///sqlhelper 的摘要说明 /// public abstract class sqlhelper { //数据库连接字符串（注意：这里的“dbconnectionstring”一定要与web.config文件中connectionstrings节点值一致） public static readonly string connectionstring = system.configuration.configurationmanager.connectionstrings[dbconnectionstring].tostring(); // 用于缓存参数的hash表 private static hashtable parmcache = hashtable.synchronized(new hashtable()); /// /// 给定连接的数据库用假设参数执行一个sql命令（不返回数据集） /// /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者sql命令语句 /// 执行命令所用参数的集合 /// 执行命令所影响的行数 public static int executenonquery(string cmdtext, commandtype cmdtype = commandtype.text, params mysqlparameter[] commandparameters) { mysqlcommand cmd = new mysqlcommand(); using (mysqlconnection conn = new mysqlconnection(connectionstring)) { preparecommand(cmd, conn, null, cmdtype, cmdtext, commandparameters); int val = cmd.executenonquery(); cmd.parameters.clear(); return val; } } /// /// 用执行的数据库连接执行一个返回数据集的sql命令 /// /// /// 举例: /// mysqldatareader r = executereader(connstring, commandtype.storedprocedure, publishorders, new mysqlparameter(@prodid, 24)); /// /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者sql命令语句 /// 执行命令所用参数的集合 /// 包含结果的读取器 public static mysqldatareader executereader(string cmdtext, commandtype cmdtype = commandtype.text, params mysqlparameter[] commandparameters) { //创建一个mysqlcommand对象 mysqlcommand cmd = new mysqlcommand(); //创建一个mysqlconnection对象 mysqlconnection conn = new mysqlconnection(connectionstring); //在这里我们用一个try/catch结构执行sql文本命令/存储过程，因为如果这个方法产生一个异常我们要关闭连接，因为没有读取器存在， //因此commandbehaviour.closeconnection 就不会执行 try { //调用 preparecommand 方法，对 mysqlcommand 对象设置参数 preparecommand(cmd, conn, null, cmdtype, cmdtext, commandparameters); //调用 mysqlcommand 的 executereader 方法 mysqldatareader reader = cmd.executereader(commandbehavior.closeconnection); //清除参数 cmd.parameters.clear(); return reader; } catch { //关闭连接，抛出异常 conn.close(); throw; } } /// /// 返回dataset /// /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者sql命令语句 /// 执行命令所用参数的集合 /// public static dataset getdataset(string cmdtext, commandtype cmdtype = commandtype.text, params mysqlparameter[] commandparameters) { //创建一个mysqlcommand对象 mysqlcommand cmd = new mysqlcommand(); //创建一个mysqlconnection对象 mysqlconnection conn = new mysqlconnection(connectionstring); //在这里我们用一个try/catch结构执行sql文本命令/存储过程，因为如果这个方法产生一个异常我们要关闭连接，因为没有读取器存在， try { //调用 preparecommand 方法，对 mysqlcommand 对象设置参数 preparecommand(cmd, conn, null, cmdtype, cmdtext, commandparameters); //调用 mysqlcommand 的 executereader 方法 mysqldataadapter adapter = new mysqldataadapter(); adapter.selectcommand = cmd; dataset ds = new dataset(); adapter.fill(ds); //清除参数 cmd.parameters.clear(); conn.close(); return ds; } catch (exception e) { throw e; } } /// /// 用指定的数据库连接字符串执行一个命令并返回一个数据集的第一列 /// /// ///例如: /// object obj = executescalar(connstring, commandtype.storedprocedure, publishorders, new mysqlparameter(@prodid, 24)); /// /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者sql命令语句 /// 执行命令所用参数的集合 /// 用 convert.to{type}把类型转换为想要的 public static object executescalar(string cmdtext, commandtype cmdtype = commandtype.text, params mysqlparameter[] commandparameters) { mysqlcommand cmd = new mysqlcommand(); using (mysqlconnection connection = new mysqlconnection(connectionstring)) { preparecommand(cmd, connection, null, cmdtype, cmdtext, commandparameters); object val = cmd.executescalar(); cmd.parameters.clear(); return val; } } /// /// 将参数集合添加到缓存 /// /// 添加到缓存的变量 /// 一个将要添加到缓存的sql参数集合 public static void cacheparameters(string cachekey, params mysqlparameter[] commandparameters) { parmcache[cachekey] = commandparameters; } /// /// 找回缓存参数集合 /// /// 用于找回参数的关键字 /// 缓存的参数集合 public static mysqlparameter[] getcachedparameters(string cachekey) { mysqlparameter[] cachedparms = (mysqlparameter[])parmcache[cachekey]; if (cachedparms == null) return null; mysqlparameter[] clonedparms = new mysqlparameter[cachedparms.length]; for (int i = 0, j = cachedparms.length; i < j; i++) clonedparms[i] = (mysqlparameter)((icloneable)cachedparms[i]).clone(); return clonedparms; } /// /// 准备执行一个命令 /// /// sql命令 /// oledb连接 /// oledb事务 /// 命令类型例如 存储过程或者文本 /// 命令文本,例如:select * from products /// 执行命令的参数 private static void preparecommand(mysqlcommand cmd, mysqlconnection conn, mysqltransaction trans, commandtype cmdtype, string cmdtext, mysqlparameter[] cmdparms) { if (conn.state != connectionstate.open) conn.open(); cmd.connection = conn; cmd.commandtext = cmdtext; if (trans != null) cmd.transaction = trans; cmd.commandtype = cmdtype; if (cmdparms != null) { foreach (mysqlparameter parameter in cmdparms) { if ((parameter.direction == parameterdirection.inputoutput || parameter.direction == parameterdirection.input) && (parameter.value == null)) { parameter.value = dbnull.value; } cmd.parameters.add(parameter); } } } }
三、访问mysql数据库（增删查改）
提示：sql语句无论是oracle、mysql、sqlserver，增删查改语句大体相似，皆为insert、delete、update、select操作，故熟悉一种数据库操作语句后，亦可相对容易学习其他数据库语句
using system.collections.generic;
using system.text;
using mysql.data.mysqlclient;
using system.data;
using dbutility;
1、插入操作（insert）
示例代码：
public int add( int userid, string name){ stringbuilder sb = new stringbuilder(); sb.append(insert into t_photo(name,userid) ); sb.append(values(?name,?userid) ); mysqlparameter[] parameters = { new mysqlparameter(?name, mysqldbtype.string), new mysqlparameter(?userid, mysqldbtype.int32) }; parameters[0].value = name; parameters[1].value = userid; return sqlhelper.executenonquery(sb.tostring(), commandtype.text, parameters);}
2、删除操作（delete）
示例代码：
public int delete(long id, int userid){ stringbuilder sb = new stringbuilder(); sb.append(delete from t_photo where id = ?id and userid = ?userid); mysqlparameter[] parameters = { new mysqlparameter(?id, mysqldbtype.int64), new mysqlparameter(?userid, mysqldbtype.int32) }; parameters[0].value = id; parameters[1].value = userid; return sqlhelper.executenonquery(sb.tostring(), commandtype.text, parameters);}
3、修改操作（update）
示例代码：
public int editname(long id, int userid, string name){ stringbuilder sb = new stringbuilder(); sb.append(update t_photo set name = ?name where id = ?id and userid = ?userid); mysqlparameter[] parameters = { new mysqlparameter(?id, mysqldbtype.int64), new mysqlparameter(?userid, mysqldbtype.int32), new mysqlparameter(?name, mysqldbtype.string) }; parameters[0].value = id; parameters[1].value = userid; parameters[2].value = name; return sqlhelper.executenonquery(sb.tostring(), commandtype.text, parameters);}
4、查询操作（select）
示例代码：
public mysqldatareader getlistbyordercode(string ordercode){ stringbuilder sb = new stringbuilder(); sb.append(select id,ordercount,subtotal,productid, ); sb.append(from t_orderdetail ); //筛选条件 sb.append(where ordercode = ?ordercode ); //排序 sb.append(order by id desc ); mysqlparameter[] parameters = { new mysqlparameter(?ordercode, mysqldbtype.string) }; parameters[0].value = ordercode; return sqlhelper.executereader(sb.tostring(), commandtype.text, parameters);}
5、调用存储过程
示例代码：
public int backorder(long id){ stringbuilder sb = new stringbuilder(); sb.append(backorder );//存储过程名称 mysqlparameter[] parameters = { new mysqlparameter(?orderid, mysqldbtype.int64)//orderid必须与存储过程参数名、数据类型一致 }; parameters[0].value = id; return mycustomsqlhelper.executenonquery(sb.tostring(), commandtype.storedprocedure, parameters);}