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
  • 移動開發（一）：使用.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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類