c# DbHelper的封装

2024-03-13 06:04
文章标签 c# 封装 .net netcore dbhelper

本文主要是介绍c# DbHelper的封装，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

c# DbHelper的封装

基于ADO.NET框架，封装了适用于多个关系型数据库的DbHelper。通过简洁明了的代码，实现了对各种数据库的高效操作。

public class DbHelper{private readonly DataBase _dataBase;public DbHelper(DataBase dataBase){_dataBase = dataBase;}public DataBase GetDataBase(){return _dataBase;}public DbConnection GetDbConnection(){var conn = _dataBase.CreationConnection();if (conn.State == ConnectionState.Closed){conn.Open();}return conn;}/// <summary>/// 执行语句/// </summary>/// <param name="sql">sql语句</param>/// <param name="cmdParms">参数</param>/// <returns></returns>public int Execute(string sql, params DbParameter[] cmdParms){using (DbConnection connection = GetDbConnection()){using (DbCommand cmd = connection.CreateCommand()){try{PrepareCommand(cmd, connection, null, sql, cmdParms);int rows = cmd.ExecuteNonQuery();cmd.Parameters.Clear();return rows;}catch (DbException e){throw e;}}}}/// <summary>/// 批量查询/// </summary>/// <param name="sql">sql语句</param>/// <param name="cmdParms">参数</param>/// <returns></returns>public DataSet Query(string sql, params DbParameter[] cmdParms){using (DbConnection connection = GetDbConnection()){DataSet ds = new DataSet();try{DbProviderFactory factory = DbProviderFactories.GetFactory(connection);DbCommand command = factory.CreateCommand();PrepareCommand(command, connection, null, sql, cmdParms);DbDataAdapter adapter = factory.CreateDataAdapter();adapter.SelectCommand = command;adapter.Fill(ds, "ds");adapter.Dispose();command.Dispose();}catch (DbException ex){throw ex;}return ds;}}/// <summary>/// 批量查询/// </summary>/// <typeparam name="T"></typeparam>/// <param name="sql">sql语句</param>/// <param name="reader">数据读取器</param>/// <param name="cmdParms">参数</param>/// <returns></returns>/// <exception cref="Exception"></exception>public List<T> Query<T>(string sql, Func<IDataReader, T> reader, params DbParameter[] cmdParms){if (reader == null)throw new Exception("数据读取器是空的!");List<T> list = new List<T>();using (DbConnection connection = GetDbConnection()){using (DbCommand cmd = connection.CreateCommand()){try{PrepareCommand(cmd, connection, null, sql, cmdParms);DbDataReader myReader = cmd.ExecuteReader();cmd.Parameters.Clear();while (myReader.Read()){list.Add(reader(myReader));}myReader.Close();}catch (DbException e){throw e;}}}return list;}/// <summary>/// 单个查询/// </summary>/// <typeparam name="T"></typeparam>/// <param name="sql">sql语句</param>/// <param name="reader">数据读取器</param>/// <param name="cmdParms">参数</param>/// <returns></returns>/// <exception cref="Exception"></exception>public T QueryFirstOrDefault<T>(string sql, Func<IDataReader, T> reader, params DbParameter[] cmdParms){if (reader == null){throw new Exception("数据读取器是空的!");}var model = default(T);using (DbConnection connection = GetDbConnection()){using (DbCommand cmd = connection.CreateCommand()){try{PrepareCommand(cmd, connection, null, sql, cmdParms);DbDataReader myReader = cmd.ExecuteReader();cmd.Parameters.Clear();if (myReader.Read())model = reader(myReader);myReader.Close();}catch (DbException e){throw e;}}}return model;}/// <summary>/// 执行存储过程/// </summary>/// <param name="storedProcName">存储过程名</param>/// <param name="parameters">存储过程参数</param>/// <returns></returns>public DataSet RunProcedure(string storedProcName, DbParameter[] parameters){using (DbConnection connection = GetDbConnection()){DataSet dataSet = new DataSet();connection.Open();DbDataAdapter sqlDA = DbProviderFactories.GetFactory(connection).CreateDataAdapter();sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);sqlDA.Fill(dataSet, "ds");sqlDA.SelectCommand.Dispose();sqlDA.Dispose();return dataSet;}}/// <summary>/// 执行存储过程，返回SqlDataReader ( 注意：调用该方法后，一定要对SqlDataReader进行Close )/// </summary>/// <param name="storedProcName">存储过程名</param>/// <param name="parameters">存储过程参数</param>/// <returns>SqlDataReader</returns>public DbDataReader RunProcedureToReader(string storedProcName, DbParameter[] parameters){using (DbConnection connection = GetDbConnection()){DbDataReader returnReader;connection.Open();DbCommand command = BuildQueryCommand(connection, storedProcName, parameters);command.CommandType = CommandType.StoredProcedure;returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);command.Dispose();return returnReader;}}/// <summary>/// 执行存储过程/// </summary>/// <param name="storedProcName">存储过程名</param>/// <param name="parameters">存储过程参数</param>/// <returns>SqlDataReader</returns>public T RunProcedure<T>(string storedProcName, Func<IDataReader, T> reader, DbParameter[] parameters){if (reader == null){throw new Exception("数据读取器是空的!");}T t = default(T);using (DbConnection connection = GetDbConnection()){DbDataReader returnReader;connection.Open();DbCommand command = BuildQueryCommand(connection, storedProcName, parameters);command.CommandType = CommandType.StoredProcedure;returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);command.Dispose();if (returnReader.Read())t = reader(returnReader);returnReader.Close();}return t;}/// <summary>/// 执行存储过程/// </summary>/// <param name="storedProcName">存储过程名</param>/// <param name="parameters">存储过程参数</param>/// <returns>SqlDataReader</returns>public List<T> RunProcedureToList<T>(string storedProcName, Func<IDataReader, T> reader, DbParameter[] parameters){if (reader == null){throw new Exception("数据读取器是空的!");}List<T> list = new List<T>();using (DbConnection connection = GetDbConnection()){DbDataReader returnReader;connection.Open();DbCommand command = BuildQueryCommand(connection, storedProcName, parameters);command.CommandType = CommandType.StoredProcedure;returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);command.Dispose();while (returnReader.Read())list.Add(reader(returnReader));returnReader.Close();}return list;}/// <summary>/// 返回首行首列/// </summary>/// <param name="sql">sql语句</param>/// <param name="cmdParms">参数</param>/// <returns></returns>public object ExecuteScalar(string sql, params DbParameter[] cmdParms){object result = null;using (DbConnection connection = GetDbConnection()){using (DbCommand cmd = connection.CreateCommand()){try{PrepareCommand(cmd, connection, null, sql, cmdParms);result = cmd.ExecuteScalar();}catch (DbException e){throw e;}}}return result;}/// <summary>/// 分页列表/// </summary>/// <typeparam name="T"></typeparam>/// <param name="tablename">表名(可以自定)</param>/// <param name="page">分页信息</param>/// <param name="reader">读取器</param>/// <param name="where">条件</param>/// <param name="field">字段</param>/// <param name="order">排序</param>public List<T> QueryWithPage<T>(string tablename, PageInfo page, Func<IDataReader, T> reader, string where = "", string field = "*", string order = "", params DbParameter[] cmdParms){long offset = page.Index * page.PageSize;string sql = "SELECT " + field + " FROM " + tablename;sql = ListPageSql(sql, where, order);sql = sql + " " + Limit(offset, page.PageSize);string sql2 = "SELECT COUNT(0) FROM " + tablename;sql2 = ListPageSql(sql2, where, "");string sql3 = sql + ";" + sql2;List<T> list = new List<T>();using (DbConnection conn = GetDbConnection()){using (DbCommand cmd = conn.CreateCommand()){try{PrepareCommand(cmd, conn, null, sql3, cmdParms);DbDataReader myReader = cmd.ExecuteReader();cmd.Parameters.Clear();while (myReader.Read()){list.Add(reader(myReader));}if (myReader.NextResult() && myReader.Read())page.Count = myReader.GetInt64Ex(0);myReader.Close();}catch (MySqlException e){throw new Exception(e.Message);}}}return list;}/// <summary>/// 组装分页sql/// </summary>/// <param name="sql">基础sql</param>/// <param name="where">条件</param>/// <param name="order">排序</param>/// <returns></returns>private string ListPageSql(string sql, string where, string order){if (!string.IsNullOrEmpty(where)){sql = sql + " WHERE " + where;}if (!string.IsNullOrEmpty(order)){sql = sql + " " + order;}return sql;}/// <summary>/// 分页/// </summary>/// <param name="offset">偏移</param>/// <param name="size">每页显示数据尺寸</param>/// <returns></returns>/// <exception cref="Exception"></exception>public string Limit(long offset, long size){if (offset == -1){if (_dataBase.DbType != DbBaseType.SqlServer){return "LIMIT " + size;}}else{if (_dataBase.DbType == DbBaseType.MySql){return string.Format("LIMIT {0},{1}", offset, size);}if (_dataBase.DbType == DbBaseType.PostgreSql || _dataBase.DbType == DbBaseType.Sqlite){return string.Format(" LIMIT {0} OFFSET {1}", size, offset);}}throw new Exception("暂时不支持其它分页语法");}public DbParameter CreateDbParameter(string parameterName, DbType dbType, object value){using(DbConnection connection = GetDbConnection()){DbParameter dbParameter = DbProviderFactories.GetFactory(connection).CreateParameter();dbParameter.ParameterName = parameterName;dbParameter.DbType = dbType;dbParameter.Value = value;return dbParameter;}}protected void PrepareCommand(DbCommand cmd, DbConnection conn, DbTransaction trans, string cmdText, DbParameter[] cmdParms){cmd.Connection = conn;cmd.CommandText = cmdText;if (trans != null)cmd.Transaction = trans;cmd.CommandType = CommandType.Text;SetParameters(cmd, cmdParms);}private DbCommand BuildQueryCommand(DbConnection connection, string storedProcName, DbParameter[] parameters){DbCommand command = connection.CreateCommand();command.CommandText = storedProcName;command.CommandType = CommandType.StoredProcedure;SetParameters(command, parameters);return command;}private void SetParameters(DbCommand command, DbParameter[] cmdParms){if (cmdParms != null){foreach (var parameter in cmdParms){if ((parameter.Direction == ParameterDirection.InputOutput||parameter.Direction == ParameterDirection.Input)&&(parameter.Value == null)){parameter.Value = DBNull.Value;}command.Parameters.Add(parameter);}}}}

这篇关于c# DbHelper的封装的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/803855。

相关文章

C#如何去掉文件夹或文件名非法字符

C#如何去掉文件夹或文件名非法字符

《C#如何去掉文件夹或文件名非法字符》：本文主要介绍C#如何去掉文件夹或文件名非法字符的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录C#去掉文件夹或文件名非法字符net类库提供了非法字符的数组这里还有个小窍门总结C#去掉文件夹或文件名非法字符实现有输入字
阅读更多...
C#之List集合去重复对象的实现方法

C#之List集合去重复对象的实现方法

《C#之List集合去重复对象的实现方法》：本文主要介绍C#之List集合去重复对象的实现方法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录C# List集合去重复对象方法1、测试数据2、测试数据3、知识点补充总结C# List集合去重复对象方法1、测试数据
阅读更多...
C#实现将Office文档(Word/Excel/PDF/PPT)转为Markdown格式

C#实现将Office文档(Word/Excel/PDF/PPT)转为Markdown格式

《C#实现将Office文档(Word/Excel/PDF/PPT)转为Markdown格式》Markdown凭借简洁的语法、优良的可读性,以及对版本控制系统的高度兼容性,逐渐成为最受欢迎的文档格式... 目录为什么要将文档转换为 Markdown 格式使用工具将 Word 文档转换为 Markdown（.
阅读更多...
Java调用C#动态库的三种方法详解

Java调用C#动态库的三种方法详解

《Java调用C#动态库的三种方法详解》在这个多语言编程的时代,Java和C#就像两位才华横溢的舞者,各自在不同的舞台上展现着独特的魅力,然而,当它们携手合作时,又会碰撞出怎样绚丽的火花呢？今天,我们... 目录方法1：C++/CLI搭建桥梁——Java ↔ C# 的“翻译官”步骤1：创建C#类库（.NET
阅读更多...
C#代码实现解析WTGPS和BD数据

C#代码实现解析WTGPS和BD数据

《C#代码实现解析WTGPS和BD数据》在现代的导航与定位应用中,准确解析GPS和北斗（BD）等卫星定位数据至关重要,本文将使用C#语言实现解析WTGPS和BD数据,需要的可以了解下... 目录一、代码结构概览1. 核心解析方法2. 位置信息解析3. 经纬度转换方法4. 日期和时间戳解析5. 辅助方法二、L
阅读更多...
使用C#删除Excel表格中的重复行数据的代码详解

使用C#删除Excel表格中的重复行数据的代码详解

《使用C#删除Excel表格中的重复行数据的代码详解》重复行是指在Excel表格中完全相同的多行数据,删除这些重复行至关重要,因为它们不仅会干扰数据分析,还可能导致错误的决策和结论,所以本文给大家介绍... 目录简介使用工具C# 删除Excel工作表中的重复行语法工作原理实现代码C# 删除指定Excel单元
阅读更多...
C#使用MQTTnet实现服务端与客户端的通讯的示例

C#使用MQTTnet实现服务端与客户端的通讯的示例

《C#使用MQTTnet实现服务端与客户端的通讯的示例》本文主要介绍了C#使用MQTTnet实现服务端与客户端的通讯的示例,包括协议特性、连接管理、QoS机制和安全策略,具有一定的参考价值,感兴趣的可... 目录一、MQTT 协议简介二、MQTT 协议核心特性三、MQTTNET 库的核心功能四、服务端（BR
阅读更多...
C#继承之里氏替换原则分析

C#继承之里氏替换原则分析

《C#继承之里氏替换原则分析》：本文主要介绍C#继承之里氏替换原则,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录C#里氏替换原则一.概念二.语法表现三.类型检查与转换总结C#里氏替换原则一.概念里氏替换原则是面向对象设计的基本原则之一：核心思想：所有引py
阅读更多...
C#实现访问远程硬盘的图文教程

C#实现访问远程硬盘的图文教程

《C#实现访问远程硬盘的图文教程》在现实场景中,我们经常用到远程桌面功能,而在某些场景下,我们需要使用类似的远程硬盘功能,这样能非常方便地操作对方电脑磁盘的目录、以及传送文件,这次我们将给出一个完整的... 目录引言一. 远程硬盘功能展示二. 远程硬盘代码实现1. 底层业务通信实现2. UI 实现三. De
阅读更多...
C#通过进程调用外部应用的实现示例

C#通过进程调用外部应用的实现示例

《C#通过进程调用外部应用的实现示例》本文主要介绍了C#通过进程调用外部应用的实现示例,以WINFORM应用程序为例,在C#应用程序中调用PYTHON程序,具有一定的参考价值,感兴趣的可以了解一下... 目录窗口程序类进程信息类 系统设置类 以WINFORM应用程序为例，在C#应用程序中调用python程序
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2