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#中读取XML文件的四种常用方法

C#中读取XML文件的四种常用方法

《C#中读取XML文件的四种常用方法》Xml是Internet环境中跨平台的,依赖于内容的技术,是当前处理结构化文档信息的有力工具,下面我们就来看看C#中读取XML文件的方法都有哪些吧... 目录XML简介格式C#读取XML文件方法使用XmlDocument使用XmlTextReader/XmlTextWr
阅读更多...
C++实现封装的顺序表的操作与实践

C++实现封装的顺序表的操作与实践

《C++实现封装的顺序表的操作与实践》在程序设计中,顺序表是一种常见的线性数据结构,通常用于存储具有固定顺序的元素,与链表不同,顺序表中的元素是连续存储的,因此访问速度较快,但插入和删除操作的效率可能... 目录一、顺序表的基本概念二、顺序表类的设计1. 顺序表类的成员变量2. 构造函数和析构函数三、顺序表
阅读更多...
C#比较两个List集合内容是否相同的几种方法

C#比较两个List集合内容是否相同的几种方法

《C#比较两个List集合内容是否相同的几种方法》本文详细介绍了在C#中比较两个List集合内容是否相同的方法,包括非自定义类和自定义类的元素比较,对于非自定义类,可以使用SequenceEqual、... 目录 一、非自定义类的元素比较1. 使用 SequenceEqual 方法（顺序和内容都相等）2.
阅读更多...
C#使用DeepSeek API实现自然语言处理,文本分类和情感分析

C#使用DeepSeek API实现自然语言处理,文本分类和情感分析

《C#使用DeepSeekAPI实现自然语言处理,文本分类和情感分析》在C#中使用DeepSeekAPI可以实现多种功能,例如自然语言处理、文本分类、情感分析等,本文主要为大家介绍了具体实现步骤,... 目录准备工作文本生成文本分类问答系统代码生成翻译功能文本摘要文本校对图像描述生成总结在C#中使用Deep
阅读更多...
Go语言利用泛型封装常见的Map操作

Go语言利用泛型封装常见的Map操作

《Go语言利用泛型封装常见的Map操作》Go语言在1.18版本中引入了泛型,这是Go语言发展的一个重要里程碑,它极大地增强了语言的表达能力和灵活性,本文将通过泛型实现封装常见的Map操作,感... 目录什么是泛型泛型解决了什么问题Go泛型基于泛型的常见Map操作代码合集总结什么是泛型泛型是一种编程范式，允
阅读更多...
C#从XmlDocument提取完整字符串的方法

C#从XmlDocument提取完整字符串的方法

《C#从XmlDocument提取完整字符串的方法》文章介绍了两种生成格式化XML字符串的方法,方法一使用`XmlDocument`的`OuterXml`属性,但输出的XML字符串不带格式,可读性差,... 方法1：通过XMLDocument的OuterXml属性，见XmlDocument类该方法获得的xm
阅读更多...
C#多线程编程中导致死锁的常见陷阱和避免方法

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁（Deadlock）是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁？死锁的典型条件：2. 导致死锁的常见原因2.1 锁的顺序问题错误示例：不同
阅读更多...
C#提取PDF表单数据的实现流程

C#提取PDF表单数据的实现流程

《C#提取PDF表单数据的实现流程》PDF表单是一种常见的数据收集工具,广泛应用于调查问卷、业务合同等场景,凭借出色的跨平台兼容性和标准化特点,PDF表单在各行各业中得到了广泛应用,本文将探讨如何使用... 目录引言使用工具C# 提取多个PDF表单域的数据C# 提取特定PDF表单域的数据引言PDF表单是一
阅读更多...
C#实现添加/替换/提取或删除Excel中的图片

C#实现添加/替换/提取或删除Excel中的图片

《C#实现添加/替换/提取或删除Excel中的图片》在Excel中插入与数据相关的图片,能将关键数据或信息以更直观的方式呈现出来,使文档更加美观,下面我们来看看如何在C#中实现添加/替换/提取或删除E... 在Excandroidel中插入与数据相关的图片，能将关键数据或信息以更直观的方式呈现出来，使文档更
阅读更多...
C#实现系统信息监控与获取功能

C#实现系统信息监控与获取功能

《C#实现系统信息监控与获取功能》在C#开发的众多应用场景中,获取系统信息以及监控用户操作有着广泛的用途,比如在系统性能优化工具中,需要实时读取CPU、GPU资源信息,本文将详细介绍如何使用C#来实现... 目录前言一、C# 监控键盘1. 原理与实现思路2. 代码实现二、读取 CPU、GPU 资源信息1.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2