C#工具類MySqlHelper，基於MySql.Data.MySqlClient封裝

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

源碼： ...


源碼：

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

 


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

-Advertisement-
Play Games
更多相關文章
  • 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 該新增的特性最關鍵的 ...
  • C#工具類SqlServerHelper，基於System.Data.SqlClient封裝
    源碼： ...
一周排行
    -Advertisement-
    Play Games
  • UOS 開啟 VisualStudio 遠程調試 .NET 應用之旅
    前言 在我們開發過程中基本上不可或缺的用到一些敏感機密數據，比如SQL伺服器的連接串或者是OAuth2的Secret等，這些敏感數據在代碼中是不太安全的，我們不應該在源代碼中存儲密碼和其他的敏感數據，一種推薦的方式是通過Asp.Net Core的機密管理器。 機密管理器 在 ASP.NET Core ...
  • C# - 能否讓 SortedSet.RemoveWhere 內傳入的委托非同步執行
    新改進提供的Taurus Rpc 功能，可以簡化微服務間的調用，同時可以不用再手動輸出模塊名稱，或調用路徑，包括負載均衡，這一切，由框架實現並提供了。新的Taurus Rpc 功能，將使得服務間的調用，更加輕鬆、簡約、高效。 ...
  • 順序棧的介面程式
    順序棧的介面程式 目錄順序棧的介面程式頭文件創建順序棧入棧出棧利用棧將10進位轉16進位數驗證 頭文件 #include <stdio.h> #include <stdbool.h> #include <stdlib.h> 創建順序棧 // 指的是順序棧中的元素的數據類型，用戶可以根據需要進行修改 ...
  • mORMot2 獲取數據集1
    前言 整理這個官方翻譯的系列，原因是網上大部分的 tomcat 版本比較舊，此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎，輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • 萬字長文總結與剖析C語言關鍵字 -- <<C語言深度解剖>>
    C總結與剖析:關鍵字篇 -- <<C語言深度解剖>> 目錄C總結與剖析:關鍵字篇 -- <<C語言深度解剖>>程式的本質:二進位文件變數1.變數:記憶體上的某個位置開闢的空間2.變數的初始化3.為什麼要有變數4.局部變數與全局變數5.變數的大小由類型決定6.任何一個變數,記憶體賦值都是從低地址開始往高地 ...
  • 【Flink入門修煉】2-3 Flink Checkpoint 原理機制
    如果讓你來做一個有狀態流式應用的故障恢復，你會如何來做呢？ 單機和多機會遇到什麼不同的問題？ Flink Checkpoint 是做什麼用的？原理是什麼？ ...
  • C++ 多級繼承與多重繼承：代碼組織與靈活性的平衡
    C++ 多級繼承 多級繼承是一種面向對象編程（OOP）特性，允許一個類從多個基類繼承屬性和方法。它使代碼更易於組織和維護，並促進代碼重用。 多級繼承的語法 在 C++ 中，使用 : 符號來指定繼承關係。多級繼承的語法如下： class DerivedClass : public BaseClass1 ...
  • 圖文結合手把手教你創建SpringCloud項目
    前言 什麼是SpringCloud？ Spring Cloud 是一系列框架的有序集合，它利用 Spring Boot 的開發便利性簡化了分散式系統的開發，比如服務註冊、服務發現、網關、路由、鏈路追蹤等。Spring Cloud 並不是重覆造輪子，而是將市面上開發得比較好的模塊集成進去，進行封裝，從 ...
  • 類模板的常見用法
    class_template 類模板和函數模板的定義和使用類似，我們已經進行了介紹。有時，有兩個或多個類，其功能是相同的，僅僅是數據類型不同。類模板用於實現類所需數據的類型參數化 template<class NameType, class AgeType> class Person { publi ...
  • system-v IPC共用記憶體通信
    目錄system v IPC簡介共用記憶體需要用到的函數介面shmget函數--獲取對象IDshmat函數--獲得映射空間shmctl函數--釋放資源共用記憶體實現思路註意 system v IPC簡介 消息隊列、共用記憶體和信號量統稱為system v IPC(進程間通信機制)，V是羅馬數字5，是UNI ...
所有分類