.NET集成DeveloperSharp操作Sql Server資料庫

来源:https://www.cnblogs.com/digital-college/p/18079750
-Advertisement-
Play Games

支持.Net/.Net Core/.Net Framework，可以部署在Docker, Windows, Linux, Mac。 常見的ORM技術（比如：Entity Framework，Dapper，SqlSugar，NHibernate，等…），它們不是在做Sql語句的程式化變種，就是在做Sq ...


支持.Net/.Net Core/.Net Framework，可以部署在Docker, Windows, Linux, Mac。

本文提供了一種結合“原生Sql+輕量級ORM”操作各類資料庫的工具。

該工具幾乎只使用了一個方法/函數，卻實現了幾乎所有的數據操作功能。它已成功應用到了人工智慧、產業互聯網、智慧醫療、等多個大型項目上。

 

此工具在IDataAccess介面中提供。 

IDataAccess所在的命名空間是：DeveloperSharp.Framework.QueryEngine（需從NuGet引用DeveloperSharp包）

它主要提供瞭如下四大功能：

（1）     執行Sql語句

（2）     執行Sp存儲過程

（3）     創建參數(輸入/輸出/返回)

（4）     事務

它初始化的代碼如下：

若是在.Net Core環境下，代碼如下：

using DeveloperSharp.Framework.QueryEngine;
--------------------------

   //在Startup.cs或Program.cs文件中進行
   Services.AddTransient<IDataAccess>((t) => {
       DatabaseInfo DIF;
       DIF.DatabaseType = DatabaseType.SQLServer; //設置資料庫類型
       DIF.ConnectionString = "Server=localhost;Database=YZZ;Uid=sa;Pwd=123";
       return DataAccessFactory.Create(DIF);
   });

若是在.Net Framework環境下，代碼如下：

using DeveloperSharp.Framework.QueryEngine;
--------------------------

   DatabaseInfo DIF;
   DIF.DatabaseType = DatabaseType.SQLServer; //設置資料庫類型
   DIF.ConnectionString = "Server=localhost;Database=YZZ;Uid=sa;Pwd=123";
   IDataAccess IDA = DataAccessFactory.Create(DIF);

註意：通過對DatabaseType屬性的設定，提供了對所有種類資料庫的支持（包括：MySql、Oracle、PostgreSQL、SqlServer、Sqlite、Firebird、達夢、以及人大金倉KingbaseES、神舟通用, 南大通用, 翰高, Access、等）

 

【示例1：查詢】

下麵，首先直接給出一個“查詢多數據+選出單數據+參數”的使用示例，代碼如下：

   //查詢多數據
   var Students1 = IDA.SqlExecute<stu>("select * from t_Student");

   //查詢多數據（帶參數）
   var Students2 = IDA.SqlExecute<stu>("select * from t_Student where Id>@IdMin and Name like @LikeName", new { IdMin = 2, LikeName = "%周%" });
   //另一種寫法1
   var IdMin = IDA.CreateParameterInput("IdMin", DbType.Int32, 2);
   var LikeName = IDA.CreateParameterInput("LikeName", DbType.String, 50, "%周%");
   var Students3 = IDA.SqlExecute<stu>("select * from t_Student where Id>@IdMin and Name like @LikeName", LikeName, IdMin);
   //另一種寫法2
   var Students4 = IDA.SqlExecute<stu>("select * from t_Student").Where(t => t.Id > 2 && t.Name.Contains("周"));

   //選出單數據
   var OneStudent = Students2.FirstOrDefault();

其中stu實體類代碼如下形式：

    //此實體類中的Id、Name、Age、Birth、MyLevel屬性名，要與數據表中的欄位名一一對應
    public class stu
    {
        public int? Id { get; set; }//資料庫中該欄位若存在Null值，類型後需要加問號?
        public string Name { get; set; }
        public int? Age { get; set; }
        public DateTime? Birth { get; set; }
        public Level? MyLevel { get; set; }//也可以使用枚舉，會自動轉換
    }

    public enum Level
    {
        Student=100,//學生
        Teacher=200,//老師
        Manager=300,//管理員
        Principle=400//校長
    }

註意：（1）DbType類型的命名空間是System.Data

           （2）若沒有定義stu實體類，也可以用dynamic替代

 

【示例2：分頁】

承接上面“示例1”的代碼，若我們要對Students1、Students2進行分頁操作（比如：每頁20條，取出第5頁），相關代碼如下：

using DeveloperSharp.Extension;//調用“分頁功能”需要引用此命名空間
--------------------------

   var Page1 = Students1.PagePartition(20, 5);
   var Page2 = Students2.PagePartition(20, 5);

   //一氣呵成的寫法
   var Page3 = IDA.SqlExecute<stu>("select * from t_Student").PagePartition(20, 5);

分頁後獲得的PagePiece對象中所包含的各類屬性/參數，可參看這篇文章：高效分頁

 

【示例3：增/刪/改】

前面談完“查詢”，我們接下來談談“增/刪/改”的使用方式，下麵是一個“修改數據+參數+事務”的使用示例：

   try
   {
       //開啟事務
       IDA.TransactionBegin();

       //修改數據（多語句）
       int affectedRows1 = IDA.SqlExecute("insert into t_Student(Name,Age)values('ww','96');update t_Student set Age=100 where Id=1006");

       //修改數據（帶參數）
       int affectedRows2 = IDA.SqlExecute("insert into t_Student(Name,Age)values(@N,@A)", new { N = "孫悟空", A = 200 });
       //另一種寫法
       var NewAge = IDA.CreateParameterInput("NewAge", DbType.Int32, 200);
       var NewName = IDA.CreateParameterInput("NewName", DbType.String, 50, "孫悟空");
       int affectedRows3 = IDA.SqlExecute("insert into t_Student(Name,Age)values(@NewName,@NewAge)", NewName, NewAge);

       //完成事務
       IDA.TransactionCommit();
   }
   catch
   {
       //回滾事務
       IDA.TransactionRollBack();
   }

 

【示例4：輸出參數】

前面幾個示例都只用到了“輸入參數”，下麵我們看看“輸出參數”怎麼使用，示例代碼如下：

   var op1 = IDA.CreateParameterOutput("TotalCount", DbType.Int32);//此項為輸出參數
   var op2 = IDA.CreateParameterOutput("MyName", DbType.String, 50);//此項為輸出參數

   //以下sql語句混雜了多個“輸入”與“輸出”參數，註意看
   IDA.SqlExecute("insert into Friend(Birth,Name,height)values(@B,@N,@h);" +
       "select @TotalCount=count(*) from Friend;" +
       "select @MyName=Name from Friend where Id=@Id",
       new { N = "楊小偉", B = "1999-02-28 12:03:45", h = 11.023, Id = 2 },
       op1, op2);

   int tc = Convert.ToInt32(op1.Value);
   string mn = op2.Value.ToString();

 

【示例5：存儲過程】

最後，我們來談談如何調用存儲過程。我們創建一個存儲過程，它帶有輸入、輸出、返回三種類型的參數，代碼如下：

CREATE PROCEDURE Test5
    @B as datetime,
    @N as nvarchar(50),
    @h as float,
    @TotalCount as int output,
    @MyName as nvarchar(50) output,
    @Id as int
AS
BEGIN
    insert into Friend(Birth,Name,height)values(@B,@N,@h);
    select @TotalCount=count(*) from Friend;
    select @MyName=Name from Friend where Id=@Id;
    return @TotalCount+100;
END

調用該存儲過程的示例代碼如下：

   var op1 = IDA.CreateParameterOutput("TotalCount", DbType.Int32);//輸出參數
   var op2 = IDA.CreateParameterOutput("MyName", DbType.String, 50);//輸出參數
   var op3 = IDA.CreateParameterReturn();//返回參數

   IDA.SpExecute("Test5", new { N = "楊小偉", B = "1999-02-28 12:03:45", h = 11.023, Id = 2 }, op1, op2, op3);

   int tc = Convert.ToInt32(op1.Value);
   string mn = op2.Value.ToString();
   int ret = Convert.ToInt32(op3.Value);

 

學習+靈活使用以上5個示例，就能滿足幾乎所有的數據操作需求。

另外，你有沒有發現，上述所有的數據操作幾乎只用了一個方法來實現：SqlExecute/ SqlExecute<T>

-----------------------

【後記】

        有讀者問到：本“工具說明”文章過於簡單，缺乏全面、細節功能的詳細介紹，所以很難依據本文內容做全面學習及後續開發。

        回答如下：其實不然，原因有三。

               （1）有一定資料庫開發經驗的人應該能看出，本文介紹的內容，已經能滿足絕大多數情況下資料庫操作的功能需求。

               （2）不像其它第三方工具有很多非標的自定義語法（這些“自定義語法”需要單獨學習，而且往往並不符合微軟規範），本工具順應了原生.Net/C#、Linq、Sql語言的協調性（從幾個示例就能看出），所以無需付出更多學習時間，自己動手簡單用一用，各種功能就能馬上實現。

                 舉例：本文示例中並沒有給出對結果集進行“排序操作”的代碼。但你若會用Linq，順應的應該馬上能猜出如何進行排序？

               （3）已有讀者依據本文內容把技術採用到了具體項目上。

----------------------- 

IDataAccess內功能方法詳細說明（輔助參考）：

SqlExecute<T>  (非同步為:SqlExecuteAsync<T>)
聲明：IEnumerable<T> SqlExecute<T>(string cmdText, params IDataParameter[] Params) where T : class, new()
用途：執行Sql語句(Select類)
參數：（1）string  cmdText              --  Sql語句
     （2）params IDataParameter[] Params --  參數組
返回：IEnumerable<T> --  多數據結果集

SqlExecute<T>  (非同步為:SqlExecuteAsync<T>)
聲明：IEnumerable<T> SqlExecute<T>(string cmdText, object InputParams, params IDataParameter[] Params) where T : class, new()
用途：執行Sql語句(Select類)
參數：（1）string  cmdText              --  Sql語句
     （2）object InputParams            --  輸入參數對象
     （3）params IDataParameter[] Params --  參數組
返回：IEnumerable<T> --  多數據結果集

SqlExecute  (非同步為:SqlExecuteAsync)
聲明：int SqlExecute(string cmdText, params IDataParameter[] Params)
用途：執行Sql語句(Insert/Update/Delete類)
參數：（1）string  cmdText              --  Sql語句
     （2）params IDataParameter[] Params --  參數組
返回：int --  受影響的行數

SqlExecute  (非同步為:SqlExecuteAsync)
聲明：int SqlExecute(string cmdText, object InputParams, params IDataParameter[] Params)
用途：執行Sql語句(Insert/Update/Delete類)
參數：（1）string  cmdText              --  Sql語句
     （2）object InputParams            --  輸入參數對象
     （3）params IDataParameter[] Params --  參數組
返回：int --  受影響的行數

SpExecute<T>  (非同步為:SpExecuteAsync<T>)
聲明：IEnumerable<T> SpExecute<T>(string cmdText, params IDataParameter[] Params) where T : class, new()
用途：執行Sp存儲過程(Select類)
參數：（1）string  cmdText              --  Sp存儲過程名
     （2）params IDataParameter[] Params --  參數組
返回：IEnumerable<T> --  多數據結果集

SpExecute<T>  (非同步為:SpExecuteAsync<T>)
聲明：IEnumerable<T> SpExecute<T>(string cmdText, object InputParams, params IDataParameter[] Params) where T : class, new()
用途：執行Sp存儲過程(Select類)
參數：（1）string  cmdText              --  Sp存儲過程名
     （2）object InputParams            --  輸入參數對象
     （3）params IDataParameter[] Params --  參數組
返回：IEnumerable<T> --  多數據結果集

SpExecute  (非同步為:SpExecuteAsync)
聲明：int SpExecute(string cmdText, params IDataParameter[] Params)
用途：執行Sp存儲過程(Insert/Update/Delete類)
參數：（1）string  cmdText              --  Sp存儲過程名
     （2）params IDataParameter[] Params --  參數組
返回：int --  受影響的行數

SpExecute  (非同步為:SpExecuteAsync)
聲明：int SpExecute(string cmdText, object InputParams, params IDataParameter[] Params)
用途：執行Sp存儲過程(Insert/Update/Delete類)
參數：（1）string  cmdText              --  Sp存儲過程名
     （2）object InputParams            --  輸入參數對象
     （3）params IDataParameter[] Params --  參數組
返回：int --  受影響的行數

 


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

-Advertisement-
Play Games
更多相關文章
  • 還在用Calendar操作Date？Java8都棄用了，還不知道它的這款強大的工具嗎？
    本文深入探討了Java 8引入的全新日期時間API相較於傳統的Date和Calendar類的優勢及實際應用。鑒於Java 8新日期時間API在設計上的先進性和易用性，我們強烈建議開發者積極採納並替換掉陳舊的Date和Calendar類，轉而採用如LocalDate、LocalDateTime、Zon... ...
  • 不要升級！不要升級！MacOS 14.4 引發Java 應用崩潰
    如果最近您收到了MacOS 14.4的升級提醒，那麼建議你暫時先不要升級！ 在x上，Java開發領域的一些大v們，也發現了這個問題，並提醒大家不要升級。 根據Java官方發佈的文章瞭解到，該問題主要是由於macOS上運行的進程可能會訪問受保護記憶體區域中的記憶體。在 macOS 14.4 更新之前，在某 ...
  • 地理探測器R語言實現：geodetector
    本文介紹基於R語言中的geodetector包，依據多張柵格圖像數據，實現地理探測器（Geodetector）操作的詳細方法~ ...
  • 藉助HttpWebRequest 調用第三方介面，獲取Token和數據
    在一次項目中，在給客戶做系統時，需要調用客戶的系統獲取數據，客戶提供了獲取Token和獲取數據的介面，用戶名和密碼，認證方式是基於Bearer的，通過學習和找資料，提供一個C#示例 一個C#示例 1、傳入語句獲取數據 /// <summary> /// 傳入語句獲取數據 /// </summary> ...
  • CYQ.Data 操作 Json 性能測試：對比 Newtonsoft.Json
    在 CYQ.Data 版本更新的這麼多年，中間過程的版本都在完善各種功能。基於需要支持或相容的代碼越多，很多時候，常規思維，都把相關功能完成，就結束了。實現過程中，無法避免的會用到大量的反射、鎖等對性能有所影響的邏輯代碼。CYQ.Data 從V5.9 版本開始，開始大規模的優化調整代碼，目前穩定在 ... ...
  • C#操作Excel文件三種方式詳解
    1.OleDb方式： 使用.NET Framework內置的System.Data.OleDb命名空間中的類，可以將Excel文件當作資料庫來讀取數據。這種方式適用於較舊版本的Excel文件（.xls格式，即Excel 2003及更早版本）。 using System.Data.OleDb; // ...
  • 深入解析C#中的第三方庫NPOI：Excel和Word文件處理的利器
    一、引言 在.NET開發中，操作Office文檔（特別是Excel和Word）是一項常見的需求。然而，在伺服器端或無Microsoft Office環境的場景下，直接使用Office Interop可能會面臨挑戰。為瞭解決這個問題，開源庫NPOI應運而生，它提供了無需安裝Office即可創建、讀取和 ...
  • C#非同步編程：原理與實踐
    一、引言 在現代應用程式開發中，尤其是在涉及I/O操作（如網路請求、文件讀寫等）時，非同步編程成為了提高性能和用戶體驗的關鍵技術。C#作為.NET框架下的主流開發語言，提供了強大的非同步編程支持，通過async/await關鍵字，可以讓開發者以同步的方式編寫非同步代碼，極大地簡化了非同步編程的複雜性。本文將 ...
一周排行
    -Advertisement-
    Play Games
  • C#TMS系統學習（BaseCity頁面）
    C#TMS系統代碼-基礎頁面BaseCity學習 本人純新手，剛進公司跟領導報道，我說我是java全棧，他問我會不會C#，我說大學學過，他說這個TMS系統就給你來管了。外包已經把代碼給我了，這幾天先把增刪改查的代碼背一下，說不定後面就要趕鴨子上架了 Service頁面 //using => impo ...
  • C# - 委托與事件
    委托與事件 委托 委托的定義 委托是C#中的一種類型，用於存儲對方法的引用。它允許將方法作為參數傳遞給其他方法，實現回調、事件處理和動態調用等功能。通俗來講，就是委托包含方法的記憶體地址，方法匹配與委托相同的簽名，因此通過使用正確的參數類型來調用方法。 委托的特性 引用方法：委托允許存儲對方法的引用， ...
  • 解析 ABP vNext 依賴註入實現【屬性註入】的原理
    前言 這幾天閑來沒事看看ABP vNext的文檔和源碼，關於關於依賴註入(屬性註入)這塊兒產生了興趣。 我們都知道。Volo.ABP 依賴註入容器使用了第三方組件Autofac實現的。有三種註入方式，構造函數註入和方法註入和屬性註入。 ABP的屬性註入原則參考如下： 這時候我就開始疑惑了，因為我知道 ...
  • C#TMS系統學習（ShippingNotice頁面）
    C#TMS系統代碼-業務頁面ShippingNotice學習 學一個業務頁面，ok，領導開完會就被裁掉了，很突然啊，他收拾東西的時候我還以為他要旅游提前請假了，還在尋思為什麼回家連自己買的幾箱飲料都要叫跑腿帶走，怕被偷嗎？還好我在他開會之前拿了兩瓶芬達 感覺感覺前面的BaseCity差不太多，這邊的 ...
  • C#動態查詢：巧用Expression組合多條件表達式
    概述：在C#中，通過`Expression`類、`AndAlso`和`OrElse`方法可組合兩個`Expression<Func<T, bool>>`，實現多條件動態查詢。通過創建表達式樹，可輕鬆構建複雜的查詢條件。 在C#中，可以使用AndAlso和OrElse方法組合兩個Expression< ...
  • 在Biwen.QuickApi中整合一個極簡的發佈訂閱(事件匯流排)
    閑來無聊在我的Biwen.QuickApi中實現一下極簡的事件匯流排,其實代碼還是蠻簡單的,對於初學者可能有些幫助 就貼出來,有什麼不足的地方也歡迎板磚交流~ 首先定義一個事件約定的空介面 public interface IEvent{} 然後定義事件訂閱者介面 public interface I ...
  • WPF 穩定的全屏化視窗方法
    1. 案例 成某三甲醫預約系統， 該項目在2024年初進行上線測試，在正常運行了兩天後，業務系統報錯：The connection pool has been exhausted, either raise MaxPoolSize (currently 800) or Timeout (curren ...
  • 在 WPF 中集成 ASP.NET Core 和 WebView2 用於集成 SPA 應用
    背景 我們有些工具在 Web 版中已經有了很好的實踐，而在 WPF 中重新開發也是一種費時費力的操作，那麼直接集成則是最省事省力的方法了。 思路解釋 為什麼要使用 WPF？莫問為什麼，老 C# 開發的堅持，另外因為 Windows 上已經裝了 Webview2/edge 整體打包比 electron ...
  • C#事件
    EDP是一套集組織架構，許可權框架【功能許可權，操作許可權，數據訪問許可權，WebApi許可權】，自動化日誌，動態Interface，WebApi管理等基礎功能於一體的，基於.net的企業應用開發框架。通過友好的編碼方式實現數據行、列許可權的管控。 ...
  • .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 發佈到 Win7+
    .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...
所有分類