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
  • 如何基於surging跨網關跨語言進行緩存降級
    基於.NET Framework 4.8 開發的深度學習模型部署測試平臺，提供了YOLO框架的主流系列模型，包括YOLOv8~v9，以及其系列下的Det、Seg、Pose、Obb、Cls等應用場景，同時支持圖像與視頻檢測。模型部署引擎使用的是OpenVINO™、TensorRT、ONNX runti... ...
  • 十年沉澱，重啟開發之路
    十年沉澱，重啟開發之路 十年前，我沉浸在開發的海洋中，每日與代碼為伍，與演算法共舞。那時的我，滿懷激情，對技術的追求近乎狂熱。然而，隨著歲月的流逝，生活的忙碌逐漸占據了我的大部分時間，讓我無暇顧及技術的沉澱與積累。 十年間，我經歷了職業生涯的起伏和變遷。從初出茅廬的菜鳥到逐漸嶄露頭角的開發者，我見證了 ...
  • C#.NET體系圖文概述—2024最全總結
    C# 是一種簡單、現代、面向對象和類型安全的編程語言。.NET 是由 Microsoft 創建的開發平臺，平臺包含了語言規範、工具、運行，支持開發各種應用，如Web、移動、桌面等。.NET框架有多個實現，如.NET Framework、.NET Core（及後續的.NET 5+版本），以及社區版本M... ...
  • 班級擂臺（光榮）榜 - 極簡教育小工具
    前言 本文介紹瞭如何使用三菱提供的MX Component插件實現對三菱PLC軟元件數據的讀寫，記錄了使用電腦模擬，模擬PLC，直至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1. PLC開發編程環境GX Works2，GX Works2下載鏈接 https:// ...
  • web server apache tomcat11-31-websocket
    前言 整理這個官方翻譯的系列，原因是網上大部分的 tomcat 版本比較舊，此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎，輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • day31-jQuery
    1、jQuery介紹 jQuery是什麼 jQuery是一個快速、簡潔的JavaScript框架，是繼Prototype之後又一個優秀的JavaScript代碼庫（或JavaScript框架）。jQuery設計的宗旨是“write Less，Do More”，即倡導寫更少的代碼，做更多的事情。它封裝 ...
  • aardio爬蟲) 實戰篇：逆向有道翻譯web介面
    前言 之前的文章把js引擎(aardio封裝庫) 微軟開源的js引擎(ChakraCore))寫好了，這篇文章整點js代碼來測一下bug。測試網站：https://fanyi.youdao.com/index.html#/ 逆向思路 逆向思路可以看有道翻譯js逆向（MD5加密，AES加密）附完整源碼 ...
  • 面試官：這就是你理解的Java多線程基礎？
    引言 現代的操作系統（Windows，Linux，Mac OS）等都可以同時打開多個軟體（任務），這些軟體在我們的感知上是同時運行的，例如我們可以一邊瀏覽網頁，一邊聽音樂。而CPU執行代碼同一時間只能執行一條，但即使我們的電腦是單核CPU也可以同時運行多個任務，如下圖所示，這是因為我們的 CPU 的 ...
  • Python文本統計與分析從基礎到進階
    掌握使用Python進行文本英文統計的基本方法，並瞭解如何進一步優化和擴展這些方法，以應對更複雜的文本分析任務。 ...
  • Redis多數據源，看這篇就夠了
    背景 Redis多數據源常見的場景： 分區數據處理：當數據量增長時，單個Redis實例可能無法處理所有的數據。通過使用多個Redis數據源，可以將數據分區存儲在不同的實例中，使得數據處理更加高效。 多租戶應用程式：對於多租戶應用程式，每個租戶可以擁有自己的Redis數據源，以確保數據隔離和安全性。 ...
所有分類