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# async await 异步编程实现机制详解

C# async await 异步编程实现机制详解

《C#asyncawait异步编程实现机制详解》async/await是C#5.0引入的语法糖,它基于**状态机（StateMachine）**模式实现,将异步方法转换为编译器生成的状态机类,本... 目录一、async/await 异步编程实现机制1.1 核心概念1.2 编译器转换过程1.3 关键组件解析
阅读更多...
C#中lock关键字的使用小结

C#中lock关键字的使用小结

《C#中lock关键字的使用小结》在C#中,lock关键字用于确保当一个线程位于给定实例的代码块中时,其他线程无法访问同一实例的该代码块,下面就来介绍一下lock关键字的使用... 目录使用方式工作原理注意事项示例代码为什么不能lock值类型在C#中，lock关键字用于确保当一个线程位于给定实例的代码块中时
阅读更多...
C# $字符串插值的使用

C# $字符串插值的使用

《C#$字符串插值的使用》本文介绍了C#中的字符串插值功能,详细介绍了使用$符号的实现方式,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录$ 字符使用方式创建内插字符串包含不同的数据类型控制内插表达式的格式控制内插表达式的对齐方式内插表达式中使用转义序列内插表达式中使用
阅读更多...
C#中的Converter的具体应用

C#中的Converter的具体应用

《C#中的Converter的具体应用》C#中的Converter提供了一种灵活的类型转换机制,本文详细介绍了Converter的基本概念、使用场景,具有一定的参考价值,感兴趣的可以了解一下... 目录Converter的基本概念1. Converter委托2. 使用场景布尔型转换示例示例1：简单的字符串到
阅读更多...
C#监听txt文档获取新数据方式

C#监听txt文档获取新数据方式

《C#监听txt文档获取新数据方式》文章介绍通过监听txt文件获取最新数据,并实现开机自启动、禁用窗口关闭按钮、阻止Ctrl+C中断及防止程序退出等功能,代码整合于主函数中,供参考学习... 目录前言一、监听txt文档增加数据二、其他功能1. 设置开机自启动2. 禁止控制台窗口关闭按钮3. 阻止Ctrl +
阅读更多...
C#解析JSON数据全攻略指南

C#解析JSON数据全攻略指南

《C#解析JSON数据全攻略指南》这篇文章主要为大家详细介绍了使用C#解析JSON数据全攻略指南,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、为什么jsON是C#开发必修课？二、四步搞定网络JSON数据1. 获取数据 - HttpClient最佳实践2. 动态解析 - 快速
阅读更多...
C#连接SQL server数据库命令的基本步骤

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用：如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.
阅读更多...
C#读写文本文件的多种方式详解

C#读写文本文件的多种方式详解

《C#读写文本文件的多种方式详解》这篇文章主要为大家详细介绍了C#中各种常用的文件读写方式,包括文本文件,二进制文件、CSV文件、JSON文件等,有需要的小伙伴可以参考一下... 目录一、文本文件读写1. 使用 File 类的静态方法2. 使用 StreamReader 和 StreamWriter二、二进
阅读更多...
C#中Guid类使用小结

C#中Guid类使用小结

《C#中Guid类使用小结》本文主要介绍了C#中Guid类用于生成和操作128位的唯一标识符,用于数据库主键及分布式系统,支持通过NewGuid、Parse等方法生成,感兴趣的可以了解一下... 目录前言一、什么是 Guid二、生成 Guid1. 使用 Guid.NewGuid() 方法2. 从字符串创建
阅读更多...
C# 比较两个list 之间元素差异的常用方法

C# 比较两个list 之间元素差异的常用方法

《C#比较两个list之间元素差异的常用方法》：本文主要介绍C#比较两个list之间元素差异,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1. 使用Except方法2. 使用Except的逆操作3. 使用LINQ的Join,GroupJoin
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2