當前位置：首頁 > 运维知识 > 数据库 >内容正文

数据库

基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中

發布時間：2023/12/9 数据库 44 豆豆

生活随笔收集整理的這篇文章主要介紹了基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

Python微信訂餐小程序課程視頻

https://edu.csdn.net/course/detail/36074

Python實戰量化交易理財系統

https://edu.csdn.net/course/detail/35475
在我的各種開發框架中，數據訪問有的基于微軟企業庫，有的基于EFCore的實體框架，兩者各有其應用場景，不過多的去比較。最近在使用SqlSugar的時候，覺得這個數據訪問處理的組件確實很靈活，據說性能也是很不錯，于是用來整合測試一下，它對多種關系型數據庫如SqlServer、Oracle、Mysql、SQLite、PostgreSQL都很容易提供支持，通過特性標注的方式，可以很好的實現數據訪問的處理，這點很類似EfCore的處理，同時SqlSugar又提供很靈活的SQL處理操作。因此多花了一些時間，把SqlSugar的數據訪問操作進行一定的封裝處理，最后使之適應更廣泛的應用。在這個處理過程中，我編寫一些單元測試用來測試其相關功能，并編寫了幾個模塊的Winform界面進行測試，效果還是很不錯，借此總結分享一下。

1、SQLSugar的相關介紹

SqlSugar是一款老牌 .NET 開源ORM框架，由果糖大數據科技團隊維護和更新，使用文檔可以參考官方文檔：https://www.donet5.com/Home/Doc, GitHub的地址是：https://github.com/donet5/SqlSugar

優點：簡單易用、功能齊全、高性能、輕量級，支持數據庫：MySql、SqlServer、Sqlite、Oracle 、 postgresql、達夢、人大金倉。

由于它是ORM的框架組件，因此標識性的處理也是常規的操作，一般的SQLSugar對數據實體對象提供和數據庫信息的標注處理。

如對于數據庫表的標注：

[**SugarTable**("TB\_DictData")] public class DictDataInfo { }

以及對字段信息主鍵的標注

/// /// 編號/// [SugarColumn(**IsPrimaryKey** = true)]public virtual string ID { get; set; }

或者是自增字段的標注處理

public class Person {//數據庫字段[SqlSugar.SugarColumn(IsPrimaryKey =true,**IsIdentity** =true)]public int Id { get; set; }

而有些字段，和數據庫字段是沒有對應關系的，可以設置忽略標識，如下所示。

public class Person {//數據庫字段[SqlSugar.SugarColumn(IsPrimaryKey =true,IsIdentity =true)]public int Id { get; set; }public int SexId { get; set; }//非數據庫字段[SqlSugar.SugarColumn(**IsIgnore =true**)]public string SexName { get; set; }.......

定義了這些實體和數據庫關系后，我們操作數據庫，可以使用?SqlSugarClient?或者?SqlSugarScope?對數據庫進行增、刪、查、改等功能，SqlSugarClient 和SqlSugarScope 幾乎一樣，兩者差異之處，是后者使用單例（單件）模式，如果我們的對象也是單件模式，就考慮使用SqlSugarScope 對象操作數據庫。

例如我們創建一個SqlSugarClient的對象實例，用它來操作數據庫獲取信息。

那接下來，我們就可以利用db來進行數據的增刪改查處理操作了。

//查詢表的所有var list = db.Queryable().ToList();//插入db.Insertable(new Student() { SchoolId = 1, Name = "jack" }).ExecuteCommand();//更新db.Updateable(new Student() { Id = 1, SchoolId = 2, Name = "jack2" }).ExecuteCommand();//刪除db.Deleteable().Where(it => it.Id == 1).ExecuteCommand();

一般來說，我們可能傾向于把操作封裝為一個函數處理，如下所示

/// /// 保存數據到數據庫 /// /// /// public async Task<bool> SaveData(LongVoiceResultDto dto) {bool result = false;if(dto != null){using(var db = CreateDb()){var info = new ConsultationInfo();info.DiscernStatus = dto.taskId;info.OperateStatus = "未識別";if (dto.data != null && dto.data.speechResult != null){if (dto.data.statusCode == 3){info.OperateStatus = "已識別";}var speechResult = dto.data.speechResult;info.DiscernText = speechResult.resultText;}result = await db.Insertable(info).ExecuteCommandAsync() > 0;}}return result; }

從上面的代碼來看，我們定義好實體信息后，就可以直接用SqlSugarClient的對象實例來處理數據庫信息了，過程非常簡單高效，特別對于一些簡單的單表操作，非常簡潔。

2、SQLSugar的基類封裝

上面的簡單代碼，我們可以看到SqlSugarClient的對象實例的快捷操作數據庫操作，非常方便。

不過一般來說，對于一個成熟的項目，我們一般是要盡可能的重用一些處理代碼，并提供最大程度的簡化封裝。因此我們在實際使用來開發項目的時候，需要對?SqlSugar數據庫的處理進行一定的封裝操作，以期最大程度的優化代碼。

首先我們定義一個對象用來承載數據庫SqlSugarScope(或者SqlSugarClient)實例的信息，用于數據訪問的基類上下文方便使用的目的。

/// /// 數據庫上下文信息/// public class DbContext{/// /// 數據庫類型。/// public DbType DbType { get; set; }/// /// 連接字符串。/// public string ConnectionString { get; set; }/// /// 數據庫類型。/// public SqlSugarScope Client { get; set; }public DbContext(){//默認采用配置項名//appSettings/DefaultDb 配置項為指定連接字符串的namevar dbConfigName = ConfigurationManager.AppSettings["DefaultDb"];Init(dbConfigName);}public DbContext(string dbConfigName){Init(dbConfigName);}

我們為了方便配置不同的數據庫信息，因此通過定義一個默認的鍵?DefaultDb 來確定具體使用那個連接字符串。如下是我們的數據庫連接字符串。

</spanxml version="1.0" encoding="utf-8"?> <configuration><connectionStrings><add name="sqlserver" providerName="System.Data.SqlClient" connectionString="Persist Security Info=False;Data Source=(local);Initial Catalog=WinFramework;Integrated Security=SSPI" /><add name="mysql" providerName="MySql.Data.MySqlClient" connectionString="Server=localhost;Database=winframework;Uid=root;Pwd=123456;SslMode=none" /><add name="sqlite" providerName="System.Data.SQLite" connectionString="Data Source=|DataDirectory|\WinFramework.db;Version=3;" /><add name="npgsql" providerName="Npgsql" connectionString="Server=localhost;Port=5432;Database=winframework;User Id=postgres;Password=123456" /><add name="oracle" providerName="OracleManaged" connectionString="Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=localhost)(PORT=1521))(CONNECT\_DATA=(SERVER=DEDICATED)(SERVICE\_NAME=orcl)));User ID=win;Password=win" /><add name="Dm" providerName="Dm" connectionString="Server=localhost;User ID=SYSDBA;PWD=SYSDBA;Database=WINFRAMEWORK;" />connectionStrings><appSettings><add key="DefaultDb" value="sqlserver" />appSettings><startup><supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.8" />startup> configuration>

其中我們通過連接字符串中的?providerName 的類別來確定具體使用那種數據庫類型。

/// /// 根據鏈接字符串的providerName決定那種數據庫類型/// /// /// private DbType GetSugarDbType(ConnectionStringSettings setting){DbType dbType = DbType.SqlServer; //默認值var providerName = setting.ProviderName;if (providerName != null){//數據庫providerName：SqlClient MySqlClient SQLite OracleManaged/OracleClient Npgsqlif (providerName.EndsWith(".SqlClient", StringComparison.OrdinalIgnoreCase)){dbType = DbType.SqlServer;}else if (providerName.EndsWith(".MySqlClient", StringComparison.OrdinalIgnoreCase)){dbType = DbType.MySql;}else if (providerName.EndsWith(".SQLite", StringComparison.OrdinalIgnoreCase)){dbType = DbType.Sqlite;}else if (providerName.EndsWith("OracleManaged", StringComparison.OrdinalIgnoreCase)){dbType = DbType.Oracle;}else if (providerName.EndsWith(".OracleClient", StringComparison.OrdinalIgnoreCase)){dbType = DbType.Oracle;}else if (providerName.EndsWith("Npgsql", StringComparison.OrdinalIgnoreCase)){dbType = DbType.PostgreSQL;}else if (providerName.EndsWith("Dm", StringComparison.OrdinalIgnoreCase)){dbType = DbType.Dm;}}return dbType;}

這樣我們就可以動態設置數據庫的配置信息了，我們可以使用配置信息，初始化數據庫操作實例的代碼邏輯。

數據庫上下文對象處理好后，我們就來設計我們的數據庫操作基類對象了，基類對象需要基于實體信息來定義一些常規的CRUD接口，并應最大程度的提供一些重寫或者設置處理。

/// /// 基于SqlSugar的數據庫訪問操作的基類對象/// /// 定義映射的實體類/// 主鍵的類型，如int，string等/// 或者分頁信息的條件對象public class MyCrudServicewhere TEntity : class, new()where TGetListInput : IPagedAndSortedResultRequest{/// /// 數據庫上下文信息/// protected DbContext dbContent;/// /// 簡化SugarClient 的 ADO對象/// protected IAdo Ado{get{return dbContent.Client.Ado;}}/// /// 實體對象處理類/// protected SimpleClient EntityDb{get{return dbContent.Client.GetSimpleClient();}}/// /// 數據庫配置名稱，默認為空。/// 可在子類指定不同的配置名稱，用于訪問不同的數據庫/// public string DbConfigName { get; set; }public MyCrudService(){dbContent = new DbContext();}

我們看到基類提供一些SqlSugarClient對象的應用，以方便對數據的處理操作。

我們看看獲取所有，以及根據Lamda條件表達式獲取列表的操作代碼，非常方便的。

/// /// 獲取所有記錄/// public virtual async Task> GetAllAsync(){var list = await EntityDb.GetListAsync();return new ListResultDto(){Items = list};}/// /// 根據條件，獲取所有記錄/// public virtual async Task> GetAllAsync(Expressionbool>> input, string orderBy = null){var query = EntityDb.AsQueryable().Where(input);query = query.OrderByIF(!string.IsNullOrEmpty(orderBy), orderBy);var list = await query.ToListAsync();return new ListResultDto(){Items = list};}

由于本身的SqlSugarClient/SqlSugarScope提供了很多接口函數，因此我們的基類只需要在它的基礎上進行一些簡單的封裝即可，如刪除處理代碼。

/// /// 刪除指定ID的對象/// /// 記錄ID/// public virtual async Task<bool> DeleteAsync(TEntity input){return await EntityDb.DeleteAsync(input);}/// /// 根據指定條件，刪除集合/// /// /// public virtual async Task<bool> DeleteAsync(Expressionbool>> input){var result = await EntityDb.DeleteAsync(input);return result;}/// /// 刪除指定ID的對象/// /// 記錄ID/// public virtual async Task<bool> DeleteByIdAsync(TKey id){return await EntityDb.DeleteByIdAsync(id);}/// /// 刪除集合/// /// 刪除條件集合/// public async virtual Task<bool> DeleteByIdsAsync(IEnumerable input){dynamic ids = input.ToArray();return await EntityDb.DeleteByIdsAsync(ids);}

上面刪除，可以根據實體類，Lamda條件表達式，主鍵或者主鍵列表等，簡單封裝一下就可以了。

根據相關的數據操作需要，我們為該基類定義很多常規通用的基類接口，包含很多常規的CRUD等的方法，列出一個列表方便參考即可。

3、SQLSugar數據訪問的單元測試

為了對不同數據庫類型的不同操作進行檢查，看其是否能夠正常工作，我們需要編寫一些測試的代碼用于檢查我們基類函數封裝的有效性，只有對每一個基類接口進行測試了，才能夠放心的使用。

為了編寫單元測試，我們需要為幾個表編寫對應的實體類和相應的服務類（繼承自SQLSugar的數據訪問基類），我們可以使用代碼生成工具Database2Sharp來快速生成實體類代碼，如下所示。

生成代碼直接顯示在代碼工具上，可以復制下來使用。

后面有空會調整一下代碼生成工具Database2Sharp，把SQLSugar的ORM實體類和基于CRUD基類的服務類一并生成代碼出來就完美了（和其他項目開發一樣，快速生成項目代碼即可）。

完成了實體類信息的處理后，我們來繼承一下基類服務類并重寫查詢條件處理和列表排序的函數即可，如下代碼所示。

/// /// 應用層服務接口實現/// public class DictDataService : MyCrudServicestring, DictDataPagedDto>{/// /// 自定義條件處理/// /// 查詢條件Dto/// protected override ISugarQueryable CreateFilteredQueryAsync(DictDataPagedDto input){var query = base.CreateFilteredQueryAsync(input);query = query.WhereIF(!input.Name.IsNullOrWhiteSpace(), t => t.Name.Contains(input.Name)).WhereIF(!string.IsNullOrEmpty(input.Remark), t => t.Remark.Contains(input.Remark)).WhereIF(!string.IsNullOrEmpty(input.Value), t => t.Value == input.Value).WhereIF(!string.IsNullOrEmpty(input.DictType\_ID), t => t.DictType\_ID == input.DictType\_ID);return query;}/// /// 自定義排序處理/// /// 可查詢LINQ/// 查詢條件Dto/// protected override ISugarQueryable ApplySorting(ISugarQueryable query, DictDataPagedDto input){return base.ApplySorting(query, input).OrderBy(s => s.DictType\_ID).OrderBy(s => s.Seq);//先按第一個字段排序，然后再按第二字段排序//return base.ApplySorting(query, input).OrderBy(s=>s.DictData\_ID).OrderBy(s => s.Seq);}}

其中?CreateFilteredQueryAsync 代碼是重寫構建查詢條件處理的邏輯，而ApplySorting函數用于指定列表的排序規則。

有了代碼生成工具的輔助，因此我們編寫一些單元測試函數用于測試，編寫單元測試也是非常方便的事情。

代碼的單元測試，編寫如下所示。

[**TestClass**]public class UnitTest1{/// /// 測試查找記錄/// /// [**TestMethod**]public async Task TestMethod1()

創建單元測試項目，并指定測試類為[Testclass]以及測試方法[TestMethod]即可，測試方法我們根據實際要求編寫覆蓋所有方法的測試即可。

例如我對于測試返回列表和單體數據的接口，編寫單元代碼如下所示。

[TestClass]public class UnitTest1{/// /// 測試查找記錄/// /// [TestMethod]public async Task TestMethod1(){var input = new DictTypePagedDto(){Name = "客戶"};//可以使用BLLFactory工廠類處理var service = BLLFactory.Instance;//new DictTypeService();var count = await service.CountAsync(s=> true);Assert.AreNotEqual(0, count);var list = await service.GetAllAsync();Assert.IsNotNull(list);Assert.IsNotNull(list.Items);Assert.IsTrue(list.Items.Count > 0);list = await service.GetListAsync(input);Assert.IsNotNull(list);Assert.IsNotNull(list.Items);Assert.IsTrue(list.Items.Count > 0);var ids = list.Items.Select(s => { return s.ID; }).Take(2);list = await service.GetAllByIdsAsync(ids);Assert.IsNotNull(list);Assert.IsNotNull(list.Items);Assert.IsTrue(list.Items.Count > 0);var id = list.Items[0].ID;var info = await service.GetAsync(id);Assert.IsNotNull(info);Assert.AreEqual(id, info.ID);info = await service.GetFirstAsync(s => true);Assert.IsNotNull(info);await Task.CompletedTask;}

測試增刪改查的接口的單元測試代碼如下所示。

/// /// 測試增刪改查/// /// [TestMethod]public async Task TestMethod2(){var info = new DictTypeInfo(){ID = Guid.NewGuid().ToString(),Code = "test",Name = "test",Remark = "test",PID = "-1", Seq = "001"};var service = new DictTypeService();var insert = await service.InsertAsync(info);Assert.IsTrue(insert);info.Name = "test2";var update = await service.UpdateAsync(info);Assert.IsTrue(update);var deleted = await service.DeleteByIdAsync(info.ID);Assert.IsTrue(deleted);var entity = await service.GetAsync(info.ID);Assert.IsNull(entity);}

測試對SQL語句執行過程的單元測試代碼如下

/// /// 測試執行語句的處理/// /// [TestMethod]public async Task TestMethod3(){var service = new DictTypeService();var sql = string.Format("Select * from TB\_DictType");var table = service.SqlTable(sql);Assert.IsNotNull(table);Assert.IsTrue(table.Rows.Count > 0);var ds = service.SqlDataSet(sql);Assert.IsNotNull(ds);Assert.IsTrue(ds.Tables.Count > 0);sql = string.Format("Select Name from TB\_DictType");var list = service.SqlValueList(sql);Assert.IsNotNull(list);//完全沒有執行任何更新、插入，返回-1var result = service.SqlExecute(sql);Assert.IsTrue(result == -1);await Task.CompletedTask;}

測試數據庫參數化及多數據庫切換處理的單元測試代碼如下所示。

/// /// 測試數據庫參數化及多數據處理/// /// [TestMethod]public async Task TestMethod4(){var service = new DictTypeService();var sql = string.Format("Select * from TB\_DictType Where PID = @pid");var parameters = new List() { new SugarParameter("pid", "-1") };//默認SQLServer數據庫var table = service.SqlTable(sql, parameters);Console.WriteLine(table.Rows.Count);Assert.IsNotNull(table);Assert.IsTrue(table.Rows.Count > 0);//切換到MySQL數據庫service.SetDbConfigName("**mysql**");var list = service.SqlQuery(sql, parameters);Assert.IsNotNull(list);Assert.IsNotNull(list.Items);Assert.IsTrue(list.Items.Count > 0);//切換到SQLITE數據庫service.SetDbConfigName("**sqlite**");var list2 = service.SqlQuery(sql, parameters);Assert.IsNotNull(list2);Assert.IsNotNull(list2.Items);Assert.IsTrue(list2.Items.Count > 0);//切換到npgsql數據庫service.SetDbConfigName("**npgsql**");var list3 = service.SqlQuery(sql, parameters);Assert.IsNotNull(list3);Assert.IsNotNull(list3.Items);Assert.IsTrue(list3.Items.Count > 0);await Task.CompletedTask;}

在開發機器上安裝幾個不同的關系數據庫，用于測試，并準備好數據庫文件導入。

在單元測試項目中右鍵運行測試，如下圖所示。

全部測試通過，這幾個單元測試覆蓋了我們的所有方法的測試了。

以上就是我們基于SqlSugar的ORM處理的封裝，并提供了豐富的基類接口和彈性化的實體類泛型約束，因此子類代碼非常簡潔，只需要實現條件查詢和排序的處理即可，因此代碼生成的時候，會更加簡便。

通過上面的預演，我們基本上了解了SqlSugar的使用操作，確實非常方便，特別是我們基于代碼生成工具的輔助開發之后，會更加省事快捷，使用基于強大的CRUD基類，我們子類的代碼更少，更容易維護。

而對于一些多表關聯的操作，我們可以在子類額外定義一些處理函數即可。

總結

以上是生活随笔為你收集整理的基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： Windows Server 2008
下一篇：转： MySQL 赋予用户权限（gran