.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
  • 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 ...
所有分類