C#工具類SqlServerHelper，基於System.Data.SqlClient封裝

来源:https://www.cnblogs.com/Jun168/archive/2019/08/22/11395456.html
-Advertisement-
Play Games

源碼： ...


源碼：

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Data;
  4 using System.Linq;
  5 using System.Text;
  6 using System.Threading.Tasks;
  7 using System.Data.SqlClient;
  8 
  9 namespace Fly.Util.DataBase
 10 {
 11     /// <summary>
 12     /// SqlServer資料庫操作類
 13     /// </summary>
 14     public static class SqlServerHelper
 15     {
 16         /// <summary>  
 17         /// 執行資料庫非查詢操作,返回受影響的行數  
 18         /// </summary>  
 19         /// <param name="connectionString">資料庫連接字元串</param>
 20         /// <param name="cmdType">命令的類型</param>
 21         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
 22         /// <param name="cmdParms">命令參數集合</param>  
 23         /// <returns>當前操作影響的數據行數</returns>  
 24         public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
 25         {
 26             SqlCommand cmd = new SqlCommand();
 27             using (SqlConnection conn = new SqlConnection(connectionString))
 28             {
 29                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
 30                 int val = cmd.ExecuteNonQuery();
 31                 cmd.Parameters.Clear();
 32                 return val;
 33             }
 34         }
 35 
 36         /// <summary>  
 37         /// 執行資料庫事務非查詢操作,返回受影響的行數  
 38         /// </summary>  
 39         /// <param name="transaction">資料庫事務對象</param>  
 40         /// <param name="cmdType">Command類型</param>  
 41         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
 42         /// <param name="cmdParms">命令參數集合</param>  
 43         /// <returns>當前事務操作影響的數據行數</returns>  
 44         public static int ExecuteNonQuery(SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
 45         {
 46             SqlCommand cmd = new SqlCommand();
 47             PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);
 48             int val = cmd.ExecuteNonQuery();
 49             cmd.Parameters.Clear();
 50             return val;
 51         }
 52 
 53         /// <summary>  
 54         /// 執行資料庫非查詢操作,返回受影響的行數  
 55         /// </summary>  
 56         /// <param name="connection">SqlServer資料庫連接對象</param>  
 57         /// <param name="cmdType">Command類型</param>  
 58         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
 59         /// <param name="cmdParms">命令參數集合</param>  
 60         /// <returns>當前操作影響的數據行數</returns>  
 61         public static int ExecuteNonQuery(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
 62         {
 63             if (connection == null)
 64                 throw new ArgumentNullException("當前資料庫連接不存在");
 65             SqlCommand cmd = new SqlCommand();
 66             PrepareCommand(cmd, connection, null, cmdType, cmdText, cmdParms);
 67             int val = cmd.ExecuteNonQuery();
 68             cmd.Parameters.Clear();
 69             return val;
 70         }
 71 
 72         /// <summary>  
 73         /// 執行資料庫查詢操作,返回SqlDataReader類型的記憶體結果集  
 74         /// </summary>  
 75         /// <param name="connectionString">資料庫連接字元串</param>
 76         /// <param name="cmdType">命令的類型</param>
 77         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
 78         /// <param name="cmdParms">命令參數集合</param>  
 79         /// <returns>當前查詢操作返回的SqlDataReader類型的記憶體結果集</returns>  
 80         public static SqlDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
 81         {
 82             SqlCommand cmd = new SqlCommand();
 83             SqlConnection conn = new SqlConnection(connectionString);
 84             try
 85             {
 86                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
 87                 SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
 88                 cmd.Parameters.Clear();
 89                 return reader;
 90             }
 91             catch
 92             {
 93                 cmd.Dispose();
 94                 conn.Close();
 95                 throw;
 96             }
 97         }
 98 
 99         /// <summary>  
100         /// 執行資料庫查詢操作,返回DataSet類型的結果集  
101         /// </summary>  
102         /// <param name="connectionString">資料庫連接字元串</param>
103         /// <param name="cmdType">命令的類型</param>
104         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
105         /// <param name="cmdParms">命令參數集合</param>  
106         /// <returns>當前查詢操作返回的DataSet類型的結果集</returns>  
107         public static DataSet ExecuteDataSet(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
108         {
109             SqlCommand cmd = new SqlCommand();
110             SqlConnection conn = new SqlConnection(connectionString);
111             DataSet ds = null;
112             try
113             {
114                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
115                 SqlDataAdapter adapter = new SqlDataAdapter();
116                 adapter.SelectCommand = cmd;
117                 ds = new DataSet();
118                 adapter.Fill(ds);
119                 cmd.Parameters.Clear();
120             }
121             catch
122             {
123                 throw;
124             }
125             finally
126             {
127                 cmd.Dispose();
128                 conn.Close();
129                 conn.Dispose();
130             }
131 
132             return ds;
133         }
134 
135         /// <summary>  
136         /// 執行資料庫查詢操作,返回DataTable類型的結果集  
137         /// </summary>  
138         /// <param name="connectionString">資料庫連接字元串</param>
139         /// <param name="cmdType">命令的類型</param>
140         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
141         /// <param name="cmdParms">命令參數集合</param>  
142         /// <returns>當前查詢操作返回的DataTable類型的結果集</returns>  
143         public static DataTable ExecuteDataTable(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
144         {
145             SqlCommand cmd = new SqlCommand();
146             SqlConnection conn = new SqlConnection(connectionString);
147             DataTable dt = null;
148 
149             try
150             {
151                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
152                 SqlDataAdapter adapter = new SqlDataAdapter();
153                 adapter.SelectCommand = cmd;
154                 dt = new DataTable();
155                 adapter.Fill(dt);
156                 cmd.Parameters.Clear();
157             }
158             catch
159             {
160                 throw;
161             }
162             finally
163             {
164                 cmd.Dispose();
165                 conn.Close();
166                 conn.Dispose();
167             }
168 
169             return dt;
170         }
171 
172         /// <summary>  
173         /// 執行資料庫查詢操作,返回結果集中位於第一行第一列的Object類型的值  
174         /// </summary>  
175         /// <param name="connectionString">資料庫連接字元串</param>
176         /// <param name="cmdType">命令的類型</param>
177         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
178         /// <param name="cmdParms">命令參數集合</param>  
179         /// <returns>當前查詢操作返回的結果集中位於第一行第一列的Object類型的值</returns>  
180         public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
181         {
182             SqlCommand cmd = new SqlCommand();
183             SqlConnection conn = new SqlConnection(connectionString);
184             object result = null;
185             try
186             {
187                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
188                 result = cmd.ExecuteScalar();
189                 cmd.Parameters.Clear();
190             }
191             catch
192             {
193                 throw;
194             }
195             finally
196             {
197                 cmd.Dispose();
198                 conn.Close();
199                 conn.Dispose();
200             }
201 
202             return result;
203         }
204 
205         /// <summary>  
206         /// 執行資料庫事務查詢操作,返回結果集中位於第一行第一列的Object類型的值  
207         /// </summary>  
208         /// <param name="trans">一個已存在的資料庫事務對象</param>  
209         /// <param name="commandType">命令類型</param>  
210         /// <param name="commandText">SqlServer存儲過程名稱或PL/SQL命令</param>  
211         /// <param name="cmdParms">命令參數集合</param>  
212         /// <returns>當前事務查詢操作返回的結果集中位於第一行第一列的Object類型的值</returns>  
213         public static object ExecuteScalar(SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
214         {
215             if (trans == null)
216                 throw new ArgumentNullException("當前資料庫事務不存在");
217             SqlConnection conn = trans.Connection;
218             if (conn == null)
219                 throw new ArgumentException("當前事務所在的資料庫連接不存在");
220 
221             SqlCommand cmd = new SqlCommand();
222             object result = null;
223 
224             try
225             {
226                 PrepareCommand(cmd, conn, trans, cmdType, cmdText, cmdParms);
227                 result = cmd.ExecuteScalar();
228                 cmd.Parameters.Clear();
229             }
230             catch
231             {
232                 throw;
233             }
234             finally
235             {
236                 trans.Dispose();
237                 cmd.Dispose();
238                 conn.Close();
239                 conn.Dispose();
240             }
241 
242             return result;
243         }
244 
245         /// <summary>  
246         /// 執行資料庫查詢操作,返回結果集中位於第一行第一列的Object類型的值  
247         /// </summary>  
248         /// <param name="conn">資料庫連接對象</param>  
249         /// <param name="cmdType">Command類型</param>  
250         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
251         /// <param name="cmdParms">命令參數集合</param>  
252         /// <returns>當前查詢操作返回的結果集中位於第一行第一列的Object類型的值</returns>  
253         public static object ExecuteScalar(SqlConnection conn, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
254         {
255             if (conn == null) throw new ArgumentException("當前資料庫連接不存在");
256             SqlCommand cmd = new SqlCommand();
257             object result = null;
258 
259             try
260             {
261                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
262                 result = cmd.ExecuteScalar();
263                 cmd.Parameters.Clear();
264             }
265             catch
266             {
267                 throw;
268             }
269             finally
270             {
271                 cmd.Dispose();
272                 conn.Close();
273                 conn.Dispose();
274             }
275 
276             return result;
277         }
278 
279         /// <summary>
280         /// 執行存儲過程
281         /// </summary>
282         /// <param name="connection">SqlServer資料庫連接對象</param>  
283         /// <param name="storedProcName">存儲過程名</param>
284         /// <param name="parameters">存儲過程參數</param>
285         /// <returns>SqlDataReader對象</returns>
286         public static SqlDataReader RunStoredProcedure(SqlConnection connection, string storedProcName, IDataParameter[] parameters)
287         {
288             SqlDataReader returnReader = null;
289             connection.Open();
290             SqlCommand command = BuildSqlCommand(connection, storedProcName, parameters);
291             returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
292             return returnReader;
293         }
294 
295 
296         /// <summary>  
297         /// 執行資料庫命令前的準備工作  
298         /// </summary>  
299         /// <param name="cmd">Command對象</param>  
300         /// <param name="conn">資料庫連接對象</param>  
301         /// <param name="trans">事務對象</param>  
302         /// <param name="cmdType">Command類型</param>  
303         /// <param name="cmdText">SqlServer存儲過程名稱或PL/SQL命令</param>  
304         /// <param name="cmdParms">命令參數集合</param>  
305         private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
306         {
307             if (conn.State != ConnectionState.Open)
308                 conn.Open();
309 
310             cmd.Connection = conn;
311             cmd.CommandText = cmdText;
312 
313             if (trans != null)
314                 cmd.Transaction = trans;
315 
316             cmd.CommandType = cmdType;
317 
318             if (cmdParms != null)
319             {
320                 foreach (SqlParameter parm in cmdParms)
321                     cmd.Parameters.Add(parm);
322             }
323         }
324 
325         /// <summary>
326         /// 構建SqlCommand對象
327         /// </summary>
328         /// <param name="connection">資料庫連接</param>
329         /// <param name="storedProcName">存儲過程名</param>
330         /// <param name="parameters">存儲過程參數</param>
331         /// <returns>SqlCommand</returns>
332         private static SqlCommand BuildSqlCommand(SqlConnection connection, string storedProcName, IDataParameter[] parameters)
333         {
334             SqlCommand command = new SqlCommand(storedProcName, connection);
335             command.CommandType = CommandType.StoredProcedure;
336             foreach (SqlParameter parameter in parameters)
337             {
338                 command.Parameters.Add(parameter);
339             }
340             return command;
341         }
342     }
343 }

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • java解析json字元串詳解（兩種方法）
    一、使用JSONObject來解析JSON數據官方提供的，所以不需要導入第三方jar包；直接上代碼，如下 步驟解讀： 定義一個JSON數組，用於將伺服器返回的數據傳入到一個JSONArray對象中； 然後迴圈遍歷這個JSONArray，從中取出每一個元素（JSONObject對象），接下來只需調用g ...
  • json與String的轉化
    String轉成jsonObject JsonObject json = JsonObject.fromObject(String str) String轉成JsonArray JsonArray jsonArray = JsonArray.fromObject(String str) 在開發過程中 ...
  • Spring Security 解析(二) —— 認證過程
    Spring Security 解析(二) —— 認證過程   在學習Spring Cloud 時，遇到了授權服務oauth 相關內容時，總是一知半解，因此決定先把Spring Security 、Spring Security Oauth2 等許可權、認證相關的內容、原理及設計學 ...
  • Java 中的動態代理
    一、概述 1. 什麼是代理 我們大家都知道微商代理，簡單地說就是代替廠家賣商品，廠家“委托”代理為其銷售商品。關於微商代理，首先我們從他們那裡買東西時通常不知道背後的廠家究竟是誰，也就是說，“委托者”對我們來說是不可見的;其次，微商代理主要以朋友圈的人為目標客戶，這就相當於為廠家做了一次對客戶群體的 ...
  • Java學習筆記（四）
    本篇概述==> 數組（依舊只敘述與C++不同的地方，或者一些應用方法例子，畢竟語言是共通的，多了也是廢話.jpg） 一，如果創建一維數組，二維數組，以及 N維數組（以此類推）呢 二，數組的一些方法（排序，複製.......） 1. 增強型 For 迴圈 用來取值，不能修改數組裡的值，相當於 普通 f ...
  • Java函數式編程原理以及應用
    一. 函數式編程 Java8所有的新特性基本基於函數式編程的思想，函數式編程的帶來，給Java註入了新鮮的活力。 下麵來近距離觀察一下函數式編程的幾個特點： 函數可以作為變數、參數、返回值和數據類型。 基於表達式來替代方法的調用 函數無狀態，可以併發和獨立使用 函數無副作用，不會修改外部的變數 函數 ...
  • 番茄日誌發佈1.0.3版本-增加Kafka支持
    可能你是第一次聽說TomatoLog，沒關係，我可以從頭告訴你，通過瞭解番茄日誌，希望能幫助有需要的朋友，番茄日誌處理將大大降低你採集、分析、處理日誌的過程。 ...
  • C#8.0—非空引用類型
    非空引用類型——C 8.0 原文地址：https://devblogs.microsoft.com/dotnet/try out nullable reference types/?utm_source=vs_developer_news&utm_medium=referral 該新增的特性最關鍵的 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類