.NET 5 全自動分表組件，.NET 分表方案 ，分表架構(gòu)與設(shè)計

一、疑問&目的

?1.1?分表使用場景

? （1）可擴展架構(gòu)設(shè)計，比如一個ERP用5年不卡，到了10就卡了因為數(shù)據(jù)太多了，這個時候很多人都是備份然后清空數(shù)據(jù)，這個工作大并且麻煩，以前的數(shù)據(jù)很難在使用

? （2）?數(shù)據(jù)量太多 ，例如每天都有?幾十上百萬的數(shù)據(jù)進入庫，如果不分表后面查詢將會非常緩慢

? ? (3)? ?性能瓶頸 ，數(shù)據(jù)庫現(xiàn)有數(shù)據(jù)超過1個億，很多情況下索引會莫名失效，性能大大下降，如果使用分表，我們只需要針對一個分表進行操作性能大大提升

?1.2? 我的目的

說到ORM很多會想到EF Core Dapper SqlSugar Chloe? Freesql等，但是說到分表組件或許者大家想不到一個名詞

我寫這一篇文章最大的目的是想大家記住?全自動的分表組件 【 SqlSugar 】

沒錯SqlSugar是一個ORM框架，并且已經(jīng)完美支持了自動分表 ，希望你能喜歡

二、SqlSugar分表優(yōu)勢

2.1 簡單?

?CURD和分表一體化 ，小白也能很好的使用分表，只要會使用 ORM?就會使用分表 ，2者語法同步?就多?一個?.SplitTable

?2.2 功能強大

支持?表結(jié)構(gòu)同步，自動建表，強大的查詢語句，插入，更新，刪除

?2.3 組件化設(shè)計

默認集成了按? 日、周、月、季、年的方式表,??比如，我想根據(jù)加密算法分表，或者根據(jù)多個字段分表，或者不滿意現(xiàn)在的分表?都可以已擴展實現(xiàn)

三、?自帶分表的使用

自帶分表支持按年、按月、按日、按季、按周進行分表

?3.1?定義實體

我們定義一個實體，主鍵不能用自增或者int ，設(shè)為long或者guid都可以，我例子就用自帶的雪花ID實現(xiàn)分表

[SplitTable(SplitType.Year)]//按年分表 （自帶分表支持 年、季、月、周、日）

[SugarTable("SplitTestTable_{year}{month}{day}")]//生成表名格式 3個變量必須要有

?publicclassSplitTestTable

?{

?????[SugarColumn(IsPrimaryKey =true)]

?????publiclongId {?get;?set; }

?????publicstringName {?get;?set; }

?????[SplitField]?//分表字段? 在插入的時候會根據(jù)這個字段插入哪個表，在更新刪除的時候也能可方便的用這個字段找出相關(guān)表

?????publicDateTime CreateTime {?get;?set; }

?}

?3.2?初始化和同步結(jié)構(gòu)

?。?）如果一張表沒有?查詢肯定會報錯，所以程序啟動時需要建一張表

? ? （2）假如分了20張表，實體類發(fā)生變更，那么 20張表可以自動同步結(jié)構(gòu)，與實體一致

1db.CodeFirst.SplitTables().InitTables<SplitTestTable>();?//程序啟動時加這一行

?3.2?查詢用法

?（1）按時間自動過濾

通過開始時間和結(jié)束時間自動生成CreateTime的過濾并且找到對應(yīng)時間的表


varlis2t = db.Queryable<OrderSpliteTest>()

.SplitTable(DateTime.Now.Date.AddYears(-1), DateTime.Now)

.ToOffsetPage(1,2);

　(2)精準篩選

根據(jù)分表字段的值可以精準的定位到具體是哪一個分表

比Take(N)性能要高出很多


varname=Db.SplitHelper<SplitTestTable>().GetTableName(data.CreateTime);

Db.Queryable<SplitTestTable>().Where(it => it.Id==data.Id).SplitTable(tas => tas.InTableNames(name)).ToList();

（3）表達式過濾

1Db.Queryable<SplitTestTable>().Where(it => it.Id==data.Id).SplitTable(tas => tas.Where(y=>y.TableName.Contains("2019"))).ToList();

? (4)? 聯(lián)表查詢


//分表使用聯(lián)表查詢

varlist=db.Queryable<Order>()

??????????????.SplitTable(tabs=>tabs.Take(3))//Order表只取最近3張表和Custom JOIN

??????????????.LeftJoin<Custom>((o,c)=>o.CustomId==c.Id).Select((o,c)=>new{ name=o.Name,cname=c.Name }).ToPageList(1,2);

?(5)? 分頁查詢　?


varcount = 0;

db.Queryable<SplitTestTable>().Where(it => it.Name.Contains("a")).SplitTable(tas => tas.Take(3)).ToPageList(1,2,refcount);//

3.3?插入

因為我們用的是Long所以采用雪ID插入(guid也可以禁止使用自增列),?實體結(jié)構(gòu)看上面 3.1


vardata =?newSplitTestTable()

{

??????CreateTime=Convert.ToDateTime("2019-12-1"),

??????Name="jack"

??};

?db.Insertable(data).SplitTable().ExecuteReturnSnowflakeId();//插入并返回雪花ID

因為我們是根據(jù)CreateTime進行的分表，生成的SQL語句如下：


INSERTINTO[SplitTestTable_20190101]?--如果表不存在會自動建表

???????????([Id],[Name],[CreateTime])

?????VALUES

???????????(@Id,@Name,@CreateTime) ;

批量插入

vardatas =?newList<SplitTestTable>(){newSplitTestTable(){CreateTime=Convert.ToDateTime("2019-12-1"),Name="jack"} ,

newSplitTestTable(){CreateTime=Convert.ToDateTime("2022-02-1"),Name="jack"},

newSplitTestTable(){CreateTime=Convert.ToDateTime("2020-02-1"),Name="jack"},

newSplitTestTable(){CreateTime=Convert.ToDateTime("2021-12-1"),Name="jack"}};

db.Insertable(datas).SplitTable().ExecuteReturnSnowflakeIdList();//插入返回雪花ID集合

執(zhí)行完生成的表

生成的Sql:

自動識別4條記錄，分別插入4個不同的表中

?3.4?刪除數(shù)據(jù)

?（1）懶人模式刪除

最近3張表都執(zhí)行一遍刪除

1db.Deleteable<SplitTestTable>().In(id).SplitTable(tas=>tas.Take(3)).ExecuteCommand();

生在的SQL如下：

DELETEFROM[SplitTestTable_20220101]?WHERE[Id]?IN(1454675372531515392)

DELETEFROM[SplitTestTable_20210101]?WHERE[Id]?IN(1454675372531515392)

DELETEFROM[SplitTestTable_20200101]?WHERE[Id]?IN(1454675372531515392)

??（2）精準刪除? ?

?相對于上面的操作性能更高，可以精準找到具體表


var deldata = new SplitTestTable()

????????????{

????????????????Id = id,

????????????????CreateTime = DateTime.Now

????????????};

?var tableName = db.SplitHelper(deldata).GetTableNames();

?db.Deleteable<SplitTestTable>().Where(deldata).SplitTable(tas=>tas.InTableNames(tableName)).ExecuteCommand();

　生成的SQL如下:

1DELETEFROM[SplitTestTable_20210101]?WHERE[Id]?IN(1454676863531089920)

?3.5?更新數(shù)據(jù)

更新的用法基本上和刪除一樣


//更新近3張表

db.Updateable(deldata).SplitTable(tas=>tas.Take(3)).ExecuteCommand();


//精準找到表名并且更新數(shù)據(jù)

vartableName = db.SplitHelper(deldata).GetTableNames();

db.Updateable(deldata).SplitTable(tas => tas.InTableNames(tableName)).ExecuteCommand();

//通過表達式過濾出要更新的表

db.Updateable(deldata).SplitTable(tas => tas.Where(y=>y.TableName.Contains("_2019"))).ExecuteCommand();

四、 自定義分表使用?

?上面的分表功能是我們自帶集成的，比如我想實現(xiàn)自定義的分表我該如何實現(xiàn)呢？

? 4.1 按首字母拼音分表

? 我們就寫個按24個字母進行分表的小例子，來學習一下如何自定義分表

? 4.2? 創(chuàng)建分表類

我們新建一個類繼承成ISplitTableService?接口?

viewcode

? 4.3? 使用自定義分表

代碼：


//使用自定義分表

db.CurrentConnectionConfig.ConfigureExternalServices.SplitTableService =newWordSplitService();

//插入數(shù)據(jù)

db.Insertable(newWordTestTable(){CreateTime=DateTime.Now,Name="BC"}).SplitTable().ExecuteReturnSnowflakeId();

db.Insertable(newWordTestTable(){CreateTime = DateTime.Now,Name =?"AC"}).SplitTable().ExecuteReturnSnowflakeId();

db.Insertable(newWordTestTable(){ CreateTime = DateTime.Now, Name =?"ZBZ"}).SplitTable().ExecuteReturnSnowflakeId();

?執(zhí)行完數(shù)據(jù)庫就多了3張表，因為是按首字母分的表 ，插入了3條記錄自動創(chuàng)建了3張表

插入生成的SQL：

INSERTINTO[WordTestTable_FirstB]

???????????([Id],[Name],[CreateTime])

?????VALUES

???????????(@Id,@Name,@CreateTime) ;

INSERTINTO[WordTestTable_FirstA]

???????????([Id],[Name],[CreateTime])

?????VALUES

???????????(@Id,@Name,@CreateTime) ;

INSERTINTO[WordTestTable_FirstZ]

???????????([Id],[Name],[CreateTime])

?????VALUES

???????????(@Id,@Name,@CreateTime) ;

查詢指定表

1varlistall = db.Queryable<WordTestTable>().Where(it => it.Name ==?"all").SplitTable(tas => tas.ContainsTableNames("_FirstA")).ToList();

生成的SQL:

1SELECT*?FROM(SELECT[Id],[Name],[CreateTime]?FROM[WordTestTable_FirstA]??WHERE( [Name] = @Name0UnionAll1 )) unionTable

SqlSugar ORM 新語法

需要 NUGET安裝 SqlSugarCore? 5.0.4.3-proview-03

以前有些人說SQLSUGAR聯(lián)表不優(yōu)美，所以我也支了最優(yōu)美聯(lián)表語法：

新語法1：

簡單的聯(lián)表

var leftQueryable = db.Queryable<Custom>()

?????.LeftJoin<OrderItem>((c, i) => c.Id == i.ItemId)

????.Select(c =>c).ToList();

SQL如下：

1SELECTc.*?FROM[Custom] c?LeftJOIN[OrderDetail] i?ON( [c].[Id] = [i].[ItemId] )

新語法2:

表? 和 Queryable?進行聯(lián)表

varrigtQueryable = db.Queryable<Custom>()

????.LeftJoin<OrderItem>((o, i) => o.Id == i.ItemId)

????????.Select(o => o);

varList = db.Queryable<Order>()

????.LeftJoin(rigtQueryable, (c, j) => c.CustomId == j.Id)

????.Select(c => c).ToList();

SQL如下：

1SELECTc.*?FROM[Order] c?LeftJOIN(SELECTo.*?FROM[Custom] o?LeftJOIN[OrderDetail] i?ON( [o].[Id] = [i].[ItemId] )? ) j?ON( [c].[CustomId] = [j].[Id] )

新語法3

?Queryable?和表 進行聯(lián)表


varleftQueryable = db.Queryable<Custom>()

????.LeftJoin<OrderItem>((c, i) => c.Id == i.ItemId)

?????.Select(c =>c) ;

varList = db.Queryable(leftQueryable)

????.LeftJoin<Order>((o, cu) => o.Id == cu.Id)

????.Select(o => o).ToList();

SQL如下：

1SELECTo.*?FROM(SELECT*?FROM(SELECTc.*?FROM[Custom] c?LeftJOIN[OrderDetail] i?ON( [c].[Id] = [i].[ItemId] )? ) t ) o?LeftJOIN[Order] cu??ON( [o].[Id] = [cu].[Id] )

總結(jié)

SqlSugar?一直在創(chuàng)新，并且越來越好，相信分表功能，新的語法一定會讓很多人喜歡

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容