C#：SqlHelper

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C#：SqlHelper，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含16382字，纯文字阅读大概需要24分钟。

内容图文

一、底层

注：引用命名空间

using System.Data;
using System.Data.SqlClient;

  1     public class SqlHelper
  2     {
  3         /// <summary>
  4         /// 数据库连接字符串
  5         /// Data Source=数据库地址;Initial Catalog=数据库名称;Persist Security Info=True;User ID=用户名;Password=密码
  6         /// </summary>
  7         private string _SqlConnectionStr = "";
  8         public string SqlConnectionStr { get { return _SqlConnectionStr; } }
  9         public SqlHelper(string connStr)
 10         {
 11             this._SqlConnectionStr = connStr;
 12         }
 13         #region 单值查询      
 14         public string GetSingle(string sqlStr)
 15         {
 16             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
 17             {
 18                 using (SqlCommand cmd = new SqlCommand(sqlStr, conn))
 19                 {
 20                     try
 21                     {
 22                         conn.Open();
 23                         return String.Format("{0}", cmd.ExecuteScalar());
 24                     }
 25                     catch(SqlException e)
 26                     {
 27                         throw e;
 28                     }
 29                     finally
 30                     {
 31                         conn.Close();
 32                     }
 33                 }
 34             }
 35         }
 36         public string GetSingle(string sqlStr,SqlParameter[] cmdParams)
 37         {
 38             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
 39             {
 40                 using (SqlCommand cmd = new SqlCommand())
 41                 {
 42                     try
 43                     {
 44                         conn.Open();
 45                         cmd.Connection = conn;
 46                         cmd.CommandType = CommandType.Text;
 47                         cmd.CommandText = sqlStr;
 48                         cmd.Parameters.AddRange(cmdParams);
 49                         return String.Format("{0}", cmd.ExecuteScalar());
 50                     }
 51                     catch(SqlException e)
 52                     {
 53                         throw e;
 54                     }
 55                     finally
 56                     {
 57                         conn.Close();
 58                     }
 59                 }
 60             }
 61         }
 62         #endregion
 63 
 64         #region 查询数据集        
 65         public DataSet Query(string sqlStr)
 66         {
 67             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
 68             {
 69                 using (SqlDataAdapter ada = new SqlDataAdapter(sqlStr, conn))
 70                 {
 71                     try
 72                     {
 73                         conn.Open();
 74                         DataSet ds = new DataSet();
 75                         ada.Fill(ds);
 76                         return ds;
 77                     }
 78                     catch(SqlException e)
 79                     {
 80                         throw e;
 81                     }
 82                     finally
 83                     {
 84                         conn.Close();
 85                     }
 86                 }
 87             }
 88         }
 89         public DataSet Query(string sqlStr,SqlParameter[] cmdParams)
 90         {
 91             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
 92             {
 93                 using (SqlCommand cmd = new SqlCommand())
 94                 {
 95                     using (SqlDataAdapter ada = new SqlDataAdapter(cmd))
 96                     {
 97                         try
 98                         {
 99                             conn.Open();
100                             cmd.Connection = conn;
101                             cmd.CommandType = CommandType.Text;
102                             cmd.CommandText = sqlStr;
103                             cmd.Parameters.AddRange(cmdParams);
104 
105                             DataSet ds = new DataSet();
106                             ada.Fill(ds);
107                             return ds;                            
108                         }
109                         catch(SqlException e)
110                         {
111                             throw e;
112                         }
113                         finally
114                         {
115                             conn.Close();
116                         }
117                     }
118                 }
119             }
120         }
121         public DataSet RunProcedure(string procName,SqlParameter[] cmdParams)
122         {
123             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
124             {
125                 using (SqlCommand cmd = new SqlCommand())
126                 {
127                     using (SqlDataAdapter ada = new SqlDataAdapter(cmd))
128                     {
129                         try
130                         {
131                             conn.Open();
132                             cmd.Connection = conn;
133                             cmd.CommandType = CommandType.StoredProcedure;
134                             cmd.CommandText = procName;
135                             cmd.Parameters.AddRange(cmdParams);
136 
137                             DataSet ds = new DataSet();
138                             ada.Fill(ds);
139                             return ds;
140                         }
141                         catch(SqlException e)
142                         {
143                             throw e;
144                         }
145                         finally
146                         {
147                             conn.Close();
148                         }
149                     }
150                 }
151             }
152         }
153         #endregion
154 
155         #region 单表查询        
156         public DataTable GetQueryData(string sqlStr)
157         {
158             DataSet ds = Query(sqlStr);
159             if (ds != null && ds.Tables.Count > 0)
160                 return ds.Tables[0];
161             return null; 
162         }
163         public DataTable GetQueryData(string sqlStr ,SqlParameter[] cmdParams)
164         {
165             DataSet ds = Query(sqlStr, cmdParams);
166             if (ds != null && ds.Tables.Count > 0)
167                 return ds.Tables[0];
168             return null;
169         }
170         public DataTable GetProcData(string procName,SqlParameter[] cmdParams)
171         {
172             DataSet ds = RunProcedure(procName, cmdParams);
173             if (ds != null && ds.Tables.Count > 0)
174                 return ds.Tables[0];
175             return null;
176         }
177         #endregion
178 
179         #region 单行查询       
180         public DataRow GetQueryRecord(string sqlStr)
181         {
182             DataTable dt = GetQueryData(sqlStr);
183             if (dt != null && dt.Rows.Count > 0)
184                 return dt.Rows[0];
185             return null;
186         }
187         public DataRow GetQueryRecord(string sqlStr,SqlParameter[] cmdParams)
188         {
189             DataTable dt = GetQueryData(sqlStr, cmdParams);
190             if (dt != null && dt.Rows.Count > 0)
191                 return dt.Rows[0];
192             return null;
193         }
194         public DataRow GetProcRecord(string procName,SqlParameter[] cmdParams)
195         {
196             DataTable dt = GetProcData(procName, cmdParams);
197             if (dt != null && dt.Rows.Count > 0)
198                 return dt.Rows[0];
199             return null;
200         }
201         #endregion
202 
203         #region 使用完应关闭Reader
204         public SqlDataReader ExecuteReader(string sqlStr)
205         {
206             SqlConnection conn = new SqlConnection(this._SqlConnectionStr);
207             SqlCommand cmd = new SqlCommand(sqlStr, conn);
208             try
209             {
210                 conn.Open();
211                 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
212             }
213             catch(SqlException e)
214             {
215                 throw e;
216             }
217         }
218         public SqlDataReader ExecuteReeder(string sqlStr,SqlParameter[] cmdParams)
219         {
220             SqlConnection conn = new SqlConnection(this._SqlConnectionStr);
221             SqlCommand cmd = new SqlCommand();
222             try
223             {
224                 conn.Open();
225                 cmd.Connection = conn;
226                 cmd.CommandType = CommandType.Text;
227                 cmd.CommandText = sqlStr;
228                 cmd.Parameters.AddRange(cmdParams);
229                 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
230             }
231             catch(SqlException e)
232             {
233                 throw e;
234             }
235         }
236         #endregion
237 
238         #region 执行sql语句        
239         public int ExecuteSql(string sqlStr)
240         {
241             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
242             {
243                 using (SqlCommand cmd = new SqlCommand(sqlStr, conn))
244                 {
245                     try
246                     {
247                         conn.Open();
248                         return cmd.ExecuteNonQuery();
249                     }
250                     catch(SqlException e)
251                     {
252                         throw e;
253                     }
254                     finally
255                     {
256                         conn.Close();
257                     }
258                 }
259             }
260         }
261         public int ExecuteSql(string sqlStr,SqlParameter[] cmdParams)
262         {
263             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
264             {
265                 using (SqlCommand cmd = new SqlCommand())
266                 {
267                     try
268                     {
269                         conn.Open();
270                         cmd.Connection = conn;
271                         cmd.CommandType = CommandType.Text;
272                         cmd.CommandText = sqlStr;
273                         cmd.Parameters.AddRange(cmdParams);
274                         return cmd.ExecuteNonQuery();
275                     }
276                     catch(SqlException e)
277                     {
278                         throw e;
279                     }
280                     finally
281                     {
282                         conn.Close();
283                     }
284                 }
285             }
286         }
287         #endregion
288 
289         #region 执行事务        
290         public int ExecuteSqlTran(List<string> sqlStrList)
291         {
292             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
293             {
294                 using (SqlCommand cmd = new SqlCommand())
295                 {
296                     using (SqlTransaction tran = conn.BeginTransaction())
297                     {
298                         try
299                         {
300                             cmd.Connection = conn;
301                             cmd.CommandType = CommandType.Text;                        
302                             cmd.Transaction = tran;
303                             conn.Open();
304                             int count = 0;
305                             foreach(string sql in sqlStrList)
306                             {
307                                 cmd.CommandText = sql;
308                                 count += cmd.ExecuteNonQuery();
309                             }
310                             tran.Commit();
311                             return count;
312                         }
313                         catch(SqlException e)
314                         {
315                             tran.Rollback();
316                             throw e;
317                         }
318                         finally
319                         {
320                             conn.Close();
321                         }
322                     }
323                 }
324             }
325         }
326         public int ExecuteSqlTran(List<KeyValuePair<string,SqlParameter[]>> sqlStrList)
327         {
328             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
329             {
330                 using (SqlCommand cmd = new SqlCommand())
331                 {
332                     using (SqlTransaction tran = conn.BeginTransaction())
333                     {
334                         try
335                         {
336                             cmd.Connection = conn;
337                             cmd.CommandType = CommandType.Text;
338                             cmd.Transaction = tran;
339                             conn.Open();
340                             int count = 0;
341                             foreach(var item in sqlStrList)
342                             {
343                                 cmd.CommandText = item.Key;
344                                 cmd.Parameters.Clear();
345                                 cmd.Parameters.AddRange(item.Value);
346                                 count += cmd.ExecuteNonQuery();
347                             }
348                             tran.Commit();
349                             return count;
350                         }
351                         catch(SqlException e)
352                         {
353                             tran.Rollback();
354                             throw e;
355                         }
356                         finally
357                         {
358                             conn.Close();
359                         }
360                     }
361                 }
362             }
363         }
364         public int ExecuteProc(string procName,SqlParameter[] cmdParams)
365         {
366             using (SqlConnection conn = new SqlConnection(this._SqlConnectionStr))
367             {
368                 using (SqlCommand cmd = new SqlCommand())
369                 {
370                     try
371                     {
372                         conn.Open();
373                         cmd.Connection = conn;
374                         cmd.CommandType = CommandType.StoredProcedure;
375                         cmd.CommandText = procName;
376                         cmd.Parameters.AddRange(cmdParams);
377                         return cmd.ExecuteNonQuery();
378                     }
379                     catch(SqlException e)
380                     {
381                         throw e;
382                     }
383                     finally
384                     {
385                         conn.Close();
386                     }
387                 }
388             }     
389         }
390         #endregion
391     }

二、工厂模式

 1     public class DbProvider
 2     {
 3         private static string _SqlConnectionStr = null;
 4         public static string SqlConnectionStr
 5         {
 6             get
 7             {
 8                 string connStr = _SqlConnectionStr;
 9                 if (connStr == null)
10                     connStr = "Data Source=(local);Initial Catalog=testDB;Persist Security Info=True;User ID=sa;Password=123456"; //一般这里是读取项目配置文件里的数据库参数来生成连接字符串
11                 return connStr;
12             }
13         }
14         public static SqlHelper SqlServer
15         {
16             get
17             {
18                 return new SqlHelper(SqlConnectionStr);
19             }
20         }
21     }

三、实例使用

1     public class Demo
2     {
3         public DataTable QueryOrderInfo(string id)
4         {
5             string sql = "select * from order where id=@id";
6             SqlParameter[] cmdParams = new SqlParameter[] { new SqlParameter("@id", id) };
7             return DbProvider.SqlServer.GetQueryData(sql, cmdParams);
8         }
9     }

C#：SqlHelper

标签：connect on() 数据 ret 数据库 oca 工厂模式 man data

本文系统来源：https://www.cnblogs.com/ecake/p/8425858.html

内容总结

以上是互联网集市为您收集整理的C#：SqlHelper全部内容，希望文章能够帮你解决C#：SqlHelper所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/498857.html

来源：【匿名】

【上一篇】Csharp: read Sybase SQL anywhere5.5 using c#【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【C#：SqlHelper】教程文章相关的互联网学习教程文章

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Configuration;using System.Data;using System.Data.SqlClient;namespace 登录.DAL{ public static class SqlHelper { private static readonly string conStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString; //执行增删改的 public static ...

C# SqlHelper类的数据库操作【代码】【图】

1#region 私有构造函数和方法2 3private SqlHelper() { }4 5///<summary> 6/// 将SqlParameter参数数组(参数值)分配给SqlCommand命令. 7/// 这个方法将给任何一个参数分配DBNull.Value; 8/// 该操作将阻止默认值的使用. 9///</summary> 10///<param name="command">命令名</param> 11///<param name="commandParameters">SqlParameters数组</param> 12privatestaticvoid AttachParameters(SqlCommand command, SqlParamet...

C# 封装SqlHelper【代码】

老师在讲C#实战项目时所使用的SqlHelper，使用的数据库时SQL Server注意，连接数据库的连接字符串需要在配置文件中设置好<appSettings><add key = "connString" value="data source = .; database = CourseSelectionInfo; integrated security = true"/> </appSettings>public class SqLHelper {#region 连接字符串connStringprivate static string connString;static DBHelper(){connString = ConfigurationManager.AppSettings["...

C#中SqlHelper类封装及调用【代码】

在AppConfig.cs增加DataSouce连接字符串（SQL Server）： <connectionStrings><add name="sql" connectionString="server=127.0.0.1;database=Test;uid=root;pwd=root;"/></connectionStrings>SqlHelper类： using实质：在程序编译阶段，编译器会自动将using语句生成为try-finally语句，并在finally块中调用对象的Dispose方法，来清理资源。所以，using语句等效于try-finally语句。 using (Font f2 = new Font("Arial", 10, FontS...

一个自定义的C#数据库操作基础类 SqlHelper

public class SQLHelper { private string strConn = null; private SqlConnection Conn = null; private SqlCommand Cmd = null; private SqlDataReader Sqlsdr = null; public SQLHelper() { //利用反射连接数据库 strConn = ConfigurationManager.ConnectionStrings["strConn"].ConnectionString; //strConn = "data source=192.168.24.83;initial catalog=NewsSystem;user id=sa;password=123456"; Conn = new SqlC...

C# / MSSQL / WinForm / ASP.NET - SQLHelper中返回SqlDataReader数据【图】

);cmd.Parameters.Clear();return rdr;}catch{conn.Close();throw;}}#region//ExecuteDataSet方法　　 ================================================================================================ c#数据库访问返回值类型为SqlDataReader时使用using时注意的问题2014-04-19 0 个评论来源：c#数据库访问返回值类型为SqlDataReader时使用using时注意的问题收藏我要投稿在封装通用 SQLSERVER 数据可访...

C#、WinForm、ASP.NET - SQLHelper.cs【代码】

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks;using System.Configuration; using System.Data; using System.Data.SqlClient; using System.Windows.Forms;namespace Car.Command {public static class SQLHelper{//获取连接字符串public static string ConString = ConfigurationManager.ConnectionStrings["ConString"].ConnectionString;#region Exe...

微软C#版SQLHelper.cs通用类

System; using System.Data; using System.Xml; using System.Data.SqlClient; using System.Collections; using System.Configuration;namespace BookDAL { /// <summary> /// SqlServer数据访问帮助类 /// </summary> public sealed class SqlHelper { #region 私有构造函数和方法private SqlHelper() { }/// <summary> /// 将SqlParameter参数数组(参数值)分配给SqlCommand命令. /// 这个方法将给任何一个参数分配DBNull....

C#实现较为实用的SQLhelper

public class SQLHelper2 {3 // 超时时间4 private static int Timeout = 1000;5 // 数据库名称6 public const String BestNet = "BestNet";7 //存储过程名称8 public const String UserInfoCURD = "UserInfoCURD";9 // 数据库连接字符串10 private static Dictionary<String, String> ConnStrs = new Dictionary<String, String>();11 12 /// <summ...

c# 连接数据库SqlHelper

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Configuration;using System.Data;using System.Data.SqlClient; namespace 登录.DAL{ public static class SqlHelper { private static readonly string conStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString;//执行增删改的 public static int Exe...

C#封装CRUD到SqlHelper类解读【代码】

首先看需要添加的内容：参数说明： name：表示键值，在代码中需要通过这键值来找到对应的连接字符串信息。 connectionString：链接数据库的字符串信息。Server：数据库服务器，Database：数据库，uid：数据库账户名，pwd：数据库密码<?xml version="1.0" encoding="utf-8" ?> <configuration><startup> <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" /></startup><!--这个写数据库链接配置信息，自己手动添...

使用C#编写SqlHelper类【代码】

<connectionStrings> 2 <add name="Sql" connectionString="server=数据库地址;uid=用户名;pwd=密码;database=数据库名"/> 3 </connectionStrings>1.接着需要创建一个名为SqlHepler类，然后创建一个方法来获取app.config文件中配置的连接字符串。1 public static string GetSqlConnectionString() 2 { 3 return ConfigurationManager. 4 ConnectionStrings["Sql"].ConnectionString; 5 }2.下面来封装第一个SqlHe...

C#：SqlHelper【代码】

一、底层注：引用命名空间 using System.Data;using System.Data.SqlClient; 1 public class SqlHelper2 {3 /// <summary>4 /// 数据库连接字符串5 /// Data Source=数据库地址;Initial Catalog=数据库名称;Persist Security Info=True;User ID=用户名;Password=密码6 /// </summary>7 private string _SqlConnectionStr = "";8 public string SqlConnectionStr { get ...

C# SqlHelper

System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Data.SqlClient; using System.Linq; using System.Text; using System.Threading.Tasks;namespace CarHailing.Base {/// <summary>/// 数据库帮助类/// </summary>public class SqlHelp{/// <summary>/// 创建一个已打开的连接/// </summary>/// <returns></returns>private static SqlConnection CreateConn(){SqlConn...

C# SqlHelper【代码】

using System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Data.SqlClient; using System.Linq; using System.Text; using System.Threading.Tasks;namespace CarHailing.Base {/// <summary>/// 数据库帮助类/// </summary>public class SqlHelp{/// <summary>/// 创建一个已打开的连接/// </summary>/// <returns></returns>private static SqlConnection CreateConn(){S...

C# - 技术教程分类

C# 教程 C# 简介 C# 环境 C# 程序结构 C# 基本语法 C# 数据类型 C# 类型转换 C# 变量 C# 常量 C# 运算符 C# 判断 C# 循环 C# 封装 C# 方法 C# 可空类型 C# 数组（Array） C# 字符串（String） C# 结构体（Struct） C# 枚举（Enum） C# 类（Class） C# 继承 C# 多态性 C# 运算符重载 C# 接口（Interface） C# 命名空间（Namespace） C# 预处理器指令 C# 异常处理 C# 特性（Attribute） C# 反射（Reflection） C# 属性（Property） C# 索引器（Indexer） C# 委托（Delegate） C# 事件（Event） C# 集合（Collection） C# 泛型（Generic） C# 匿名方法 C# 不安全代码 C# 多线程 c# 全部

C# - 最热教程

c#编程连接oracle数据库无法加载DLL(oc...一个适合新手C#程序员编写练习的小项目...C# 异步UDP发送接收数据 C#程序执行时间长和慢查询解决：线程并...c# aspose操作word文档 C#继承讲解以及对象的创建 jquery+ajax+C#实现无刷新操作数据库数...C#精髓 GridView72大绝技学习gridview...c# static的全部用法收集整理 js模拟实现类似c#下的hashtable的简单功...

首页 / C# / C#：SqlHelper

C#：SqlHelper

内容导读

内容图文

内容总结

内容备注

内容手机端

【C#：SqlHelper】教程文章相关的互联网学习教程文章

c# 连接数据库SqlHelper

C# SqlHelper类的数据库操作【代码】【图】

C# 封装SqlHelper【代码】

C#中SqlHelper类封装及调用【代码】

一个自定义的C#数据库操作基础类 SqlHelper

C# / MSSQL / WinForm / ASP.NET - SQLHelper中返回SqlDataReader数据【图】

C#、WinForm、ASP.NET - SQLHelper.cs【代码】

微软C#版SQLHelper.cs通用类

C#实现较为实用的SQLhelper

c# 连接数据库SqlHelper

C#封装CRUD到SqlHelper类解读【代码】

使用C#编写SqlHelper类【代码】

C#：SqlHelper【代码】

C# SqlHelper

C# SqlHelper【代码】

SQL - 相关标签

C# - 技术教程分类

C# - 最新教程

C# - 最热教程