logo资料库

C#访问和操作MYSQL数据库.docx

发布时间：2022-06-24 发布人：admin 分类：说明书 资料大小：0.06M 资料格式：docx 举报 版权申诉
第1页 / 共10页
第2页 / 共10页
第3页 / 共10页
第4页 / 共10页
第5页 / 共10页
第6页 / 共10页
第7页 / 共10页
第8页 / 共10页
资料共10页，剩余部分请下载后查看
    C#访问和操作 MYSQL 数据库 这里介绍下比较简单的方式，引用 MySql.Data.dll 然后添加一个 MySqlHelper 类来对 MySql 数据库进 行访问和操作。 1.将 MySql.Data.dll 引用到你的项目中 下载地址：MySql.Data.rar 添加引用后在你的数据库操作类(如 MySqlHelper.cs)中添加引用声明 using MySql.Data; using MySql.Data.MySqlClient; 2.添加一个 MySqlHelper 类来对 MySql 数据库进行操作。 MySqlHelper.CS 网上有很多列子，把代码 拷下来就可以直接使用。如果里面的 ExcecuteNonquery、GetDataSet 等基本访问数据库方法还是无 法满足你开发需求的话，你还可以自己重新改写代码来扩充其功能。 MySqlHelper： using System; using System.Collections; using System.Configuration; using MySql.Data; using MySql.Data.MySqlClient; using System.Data; /// ///MYSQLHelper 的摘要说明 /// public abstract class MySqlHelper { //数据库连接字符串 public static string Conn = "Database='wp';Data Source='localhost';User Id='root';Pass word='root';charset='utf8';pooling=true"; // 用于缓存参数的 HASH 表 private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());
    /// /// 给定连接的数据库用假设参数执行一个 sql 命令（不返回数据集） /// /// 一个有效的连接字符串 /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者 sql 命令语句 /// 执行命令所用参数的集合 /// 执行命令所影响的行数 public static int ExecuteNonQuery(string connectionString, CommandType cmdType, stri ng cmdText, 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 命令（不返回数据集） /// /// 一个现有的数据库连接 /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者 sql 命令语句 /// 执行命令所用参数的集合 /// 执行命令所影响的行数 public static int ExecuteNonQuery(MySqlConnection connection, CommandType cmdTyp e, string cmdText, params MySqlParameter[] commandParameters) { MySqlCommand cmd = new MySqlCommand();
    PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters); int val = cmd.ExecuteNonQuery(); cmd.Parameters.Clear(); return val; } /// ///使用现有的 SQL 事务执行一个 sql 命令（不返回数据集） /// /// ///举例: /// int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "Publish Orders", new MySqlParameter("@prodid", 24)); /// /// 一个现有的事务 /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者 sql 命令语句 /// 执行命令所用参数的集合 /// 执行命令所影响的行数 public static int ExecuteNonQuery(MySqlTransaction trans, CommandType cmdType, stri ng cmdText, params MySqlParameter[] commandParameters) { MySqlCommand cmd = new MySqlCommand(); PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, commandParam eters); 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 connectionString, CommandType c mdType, string cmdText, 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.CloseConnecti on); //清除参数 cmd.Parameters.Clear(); return reader; } catch { //关闭连接，抛出异常 conn.Close(); throw; } } /// /// 返回 DataSet ///
    /// 一个有效的连接字符串 /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者 sql 命令语句 /// 执行命令所用参数的集合 /// public static DataSet GetDataSet(string connectionString, CommandType cmdType, stri ng cmdText, 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, "PublishOr ders", new MySqlParameter("@prodid", 24)); /// ///一个有效的连接字符串 /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者 sql 命令语句 /// 执行命令所用参数的集合 /// 用 Convert.To{Type}把类型转换为想要的 public static object ExecuteScalar(string connectionString, CommandType cmdType, stri ng cmdText, 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; } } /// /// 用指定的数据库连接执行一个命令并返回一个数据集的第一列 /// /// /// 例如: /// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOr ders", new MySqlParameter("@prodid", 24)); /// /// 一个存在的数据库连接
    /// 命令类型(存储过程, 文本, 等等) /// 存储过程名称或者 sql 命令语句 /// 执行命令所用参数的集合 /// 用 Convert.To{Type}把类型转换为想要的 public static object ExecuteScalar(MySqlConnection connection, CommandType cmdTyp e, string cmdText, params MySqlParameter[] commandParameters) { } MySqlCommand cmd = new MySqlCommand(); 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[] comman dParameters) { } 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, MyS qlTransaction trans, CommandType cmdType, string cmdText, MySqlParameter[] cmdParm s) { 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 parm in cmdParms) cmd.Parameters.Add(parm);
    分享到：
    赞 收藏

    相关推荐

    资料库

    数据库

    共收录1218份资料，累计14个分类，关注成员有19位，主要包括：NoSQL,MongoDB,Redis,SQLite,Memcached,DB2,Sybase,Informix,PostgreSQL,MySQL,SQLServer,Access,Oracle,其它

    热门标签

    NoSQL MongoDB Redis SQLite Memcached DB2 Sybase Informix PostgreSQL MySQL SQLServer Access Oracle 其它

    最新资料