目錄

• 一、大家是否有這個(gè)需求
• 二、 多庫(kù)架構(gòu)ORM
• 三、跨服務(wù)器跨庫(kù)聯(lián)表查詢
• 3.1 跨庫(kù)查詢之一對(duì)一
• 3.2 跨庫(kù)查詢之一對(duì)多
• 3.3 跨庫(kù)查詢之多對(duì)多　　
• 3.4 多個(gè)表查詢我們可以這么寫
• 3.5 手動(dòng)指定多庫(kù)
• 3.6是否有性能問題

.NET 6 跨服務(wù)器聯(lián)表查詢, MySql、Oracle、SqlServer等相互聯(lián)表

一、大家是否有這個(gè)需求

1.跨品種查詢 ：比如 MYSQL和一個(gè)SQLSERVER進(jìn)行聯(lián)表查詢 ，或者SQLITE和MYSQL進(jìn)行聯(lián)表查詢

2.跨服務(wù)器查詢 ： A服務(wù)器和B服務(wù)器查詢

如果想同時(shí)支持1和2 相信很多人都沒有比較好的解決方案

我的設(shè)計(jì)是通過多庫(kù)架構(gòu)來實(shí)現(xiàn)多庫(kù)操作

二、 多庫(kù)架構(gòu)ORM

什么是多庫(kù)架構(gòu)ORM，一個(gè)對(duì)象可以同時(shí)操作和管理多個(gè)數(shù)據(jù)庫(kù) 我們稱為多庫(kù)架構(gòu)

EF Core

一個(gè)對(duì)象只能操作一個(gè)數(shù)據(jù)庫(kù)，所以EF Core不能稱為多庫(kù)架構(gòu)，只能稱為支持多種數(shù)據(jù)庫(kù)，如果要實(shí)現(xiàn)多庫(kù)

我們就需外部封裝，代碼如下

SqlSugar

SqlSugar在2017最火的時(shí)候停更了一年半，最大的原因就是因?yàn)榈讓蛹軜?gòu)影響了SqlSugar的上限，歷史遺留問題太多

需要大量重構(gòu)，如果直接更新對(duì)現(xiàn)有用戶是不負(fù)責(zé)的，所以我選擇了一年半未更新，讓不是特別熱愛SqlSugar的用戶

先用其他框架，留下對(duì)于SqlSugar一直熱衷的用戶，能支持和一起完善SqlSugar的用戶，謝謝有一群這樣的用戶不離不棄

籌劃了一年半的時(shí)間終于在2020開始進(jìn)行重構(gòu) 每隔一個(gè)月就重構(gòu)一部分 加點(diǎn)功能 ， 直到今天終于重構(gòu)完成

代碼如下：

var db = new SqlSugarClient(new List<ConnectionConfig>(){ new ConnectionConfig(){ConfigId="0",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true}, new ConnectionConfig(){ConfigId="1",DbType=DbType.MySql,ConnectionString=..,IsAutoCloseConnection=true  }});  if(!db.IsAnyConnection(configId))//當(dāng)前上下文不存在則添加    db.AddConnection(new ConnectionConfig{   DbType = DbType.SqlServer,ConfigId = "1",IsAutoCloseConnection = true,ConnectionString = 。。 });//開啟事務(wù)try { //db我們稱為主Db db.BeginTran(); //開啟多庫(kù) （db.Ado.BeginTran是單庫(kù)事務(wù)）事務(wù)支持單庫(kù)和多庫(kù)   db.GetConnection("1").Insertable(new Order()//var childDb=db.GetConnection(1);我們稱為子DB，子DB不具有租戶方法，具有單當(dāng)庫(kù)操作方法 {   CreateTime = DateTime.Now,   CustomId = 1,   Name = "a",   Price = 1 }).ExecuteCommand();   db.GetConnection("2").Insertable(new Order() {   CreateTime = DateTime.Now,   CustomId = 1,   Name = "a",   Price = 1 }).ExecuteCommand();   //提交事務(wù) db.CommitTran();   }catch(Exception ex){  //回滾事務(wù)  db.Rollback();}

多庫(kù)架構(gòu)可以在底層做到兼容，比如事務(wù)不需要引用外部DLL，比如我可以讓底層語法支持多庫(kù)，像EF CORE你能改他的

Include 語法嗎？改不了，我只能封裝他的語法，或者添加擴(kuò)展方法。

三、跨服務(wù)器跨庫(kù)聯(lián)表查詢

SqlSugar來實(shí)現(xiàn)跨服務(wù)器聯(lián)表查詢

3.1 跨庫(kù)查詢之一對(duì)一

[Tenant("db2")]//在類的特性設(shè)置當(dāng)前類屬于哪個(gè)庫(kù)  public class OrderItem {    [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]    public int ItemId { get; set; }    public int OrderId { get; set; }    public decimal? Price { get; set; }    [SqlSugar.SugarColumn(IsNullable = true)]    public DateTime? CreateTime { get; set; }    [Navigate(NavigateType.OneToOne,nameof(OrderId))] //設(shè)置關(guān)系 對(duì)應(yīng)Order表主鍵    public Order Order { get; set; } }//通過ConfigId進(jìn)行區(qū)分是哪個(gè)庫(kù)var db = new SqlSugarClient(new List<ConnectionConfig>(){  new ConnectionConfig(){ConfigId="db1",DbType=DbType.Sqlite,ConnectionString="DataSource=/Db_OrderDb.sqlite",IsAutoCloseConnection=true},  new ConnectionConfig(){ConfigId="db2",DbType=DbType.Sqlite,ConnectionString="DataSource=/Db_OrderItemDb.sqlite",IsAutoCloseConnection=true }}); //通過實(shí)體類特性[Tenant("db2")]自動(dòng)映射不同數(shù)據(jù)庫(kù)進(jìn)行查詢var list=db.QueryableWithAttr<OrderItem>().Includes(z => z.Order).ToList(); //1行代碼就搞定了2個(gè)庫(kù)聯(lián)表查詢

3.2 跨庫(kù)查詢之一對(duì)多

[Tenant("db1")]//指定是db1  (OrderItem類設(shè)置為 db2) public class Order {   [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]   public int Id { get; set; }   public string Name { get; set; }   public decimal Price { get; set; }   [SugarColumn(IsNullable = true)]   public DateTime CreateTime { get; set; }   [SugarColumn(IsNullable = true)]   public int CustomId { get; set; }   [Navigate(NavigateType.OneToMany, nameof(OrderItem.OrderId))]//   public List<OrderItem> Items { get; set; } }<br> var list = db.QueryableWithAttr<Order>()   .Includes(z => z.Items)//跨庫(kù)一對(duì)多   .ToList();

3.3 跨庫(kù)查詢之多對(duì)多　　

我們將3個(gè)表扔進(jìn)3個(gè)不同的庫(kù)里面

var db = new SqlSugarClient(new List<ConnectionConfig>()   {       new ConnectionConfig(){ConfigId="A",DbType=DbType.Sqlite,ConnectionString="DataSource=/A_DB.sqlite",IsAutoCloseConnection=true},       new ConnectionConfig(){ConfigId="B",DbType=DbType.Sqlite,ConnectionString="DataSource=/B_DB.sqlite",IsAutoCloseConnection=true  },       new ConnectionConfig(){ConfigId="AB",DbType=DbType.Sqlite,ConnectionString="DataSource=/AB_DB.sqlite",IsAutoCloseConnection=true  } });

　實(shí)體

 [Tenant("A")]//指定為A庫(kù)public partial class OperatorInfo{    /// <summary>    /// 主鍵    /// </summary>    [SugarColumn(IsPrimaryKey = true)]    public int id { get; set; }     /// <summary>    /// 姓名    /// </summary>    public string realname { get; set; }     /// <summary>    /// 多角色    /// </summary>    [Navigate(typeof(OptRole), nameof(OptRole.operId), nameof(OptRole.roleId))]//配置導(dǎo)航    public List<Role> Roles { get; set; }}  [Tenant("B")]//指定為B庫(kù)public partial class Role{    /// <summary>    /// 角色    /// </summary>    [SugarColumn(IsPrimaryKey = true )]    public int id { get; set; }     /// <summary>    /// 角色名稱    /// </summary>    public string name { get; set; }  }[Tenant("AB")]//指定為AB庫(kù)public partial class OptRole{    /// <summary>    ///    /// </summary>    [SugarColumn(IsPrimaryKey = true)]    public int id { get; set; }     /// <summary>    ///    /// </summary>    public int operId { get; set; }     /// <summary>    ///    /// </summary>    public int roleId { get; set; }  } //3個(gè)庫(kù)3個(gè)表進(jìn)行多對(duì)多查詢var x=db.QueryableWithAttr<OperatorInfo>().Includes(z => z.Roles).ToList();

3.4 多個(gè)表查詢我們可以這么寫

//多個(gè)表聯(lián)表var x=db.QueryableWithAttr<TB>().Includes(z => z.A1).Includes(z => z.A2).Includes(z => z.A3).ToList(); //多個(gè)表嵌套聯(lián)表var x=db.QueryableWithAttr<TB>().Includes(z =>z.A1, z.Province,z=>z.City)//4個(gè)層級(jí).Includes(z => z.A2).Includes(z => z.A3).ToList();

3.5 手動(dòng)指定多庫(kù)

上面都是通多特性實(shí)現(xiàn)的多庫(kù)查詢，我們也可以手動(dòng)指定數(shù)據(jù)庫(kù)進(jìn)行多庫(kù)查詢

var list =db.GetConnection("db1").Queryable<OrderItem>()//Orderitem是db1       .CrossQuery(typeof(Order), "db2")//Order是db2       .Includes(z => z.Order)       .ToList();

3.6是否有性能問題

不會(huì)SqlSugar跨庫(kù)導(dǎo)航和不跨庫(kù)導(dǎo)航是一套算法，性能有保障，也就是單庫(kù)和多庫(kù)性能是一樣的

原理：一次獲取需要的數(shù)據(jù)，在內(nèi)存分配置，數(shù)據(jù)多可進(jìn)行拆分讀取

如今的成績(jī)

企業(yè)認(rèn)可以：

　 51job 搜索 簡(jiǎn)歷數(shù) 僅次 EF 和 Dapper 超過國(guó)外的 　Nhibernate PetaPoco ， 占Dapper 40%簡(jiǎn)歷數(shù)

知名收費(fèi)框架 JNPF 和 力軟 都有使用 SqlSugar

培訓(xùn)機(jī)構(gòu)開始 講解SqlSugar

用戶認(rèn)可

擁有強(qiáng)大的生態(tài)，3k以上的項(xiàng)目就有4個(gè)，基本都在500星以上，不算生態(tài)就擁有5個(gè)2000人群

　RuYiAdmin 、ZrAdminNetCore 、Admin.NET通用管理平臺(tái)(gitee 3k) Yi框架(Ruoyi Vue) CoreShop商城(gitee 3k) Blog.Core(github 4k)

YuebonCore Furion(gitee8k) WebFirst 騰訊 APIJSON.NET WaterCloud微服務(wù)

ViperFamilyBucket SmartSqlvboot-net WMS倉(cāng)庫(kù)管理系統(tǒng)magic.net

源碼地址：

SqlSugar一直在努力創(chuàng)新，喜歡的Github關(guān)注一下，文章推薦或轉(zhuǎn)發(fā)

到此這篇關(guān)于.NET 6 跨服務(wù)器聯(lián)表查詢操作MySql、Oracle、SqlServer等相互聯(lián)表的文章就介紹到這了,更多相關(guān).NET 6 跨服務(wù)器聯(lián)表查詢內(nèi)容請(qǐng)搜索以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持！