技術文章 » .NET 6 跨伺服器聯表查詢, MySql、Oracle、SqlServer等相互聯表

.NET 6 跨伺服器聯表查詢, MySql、Oracle、SqlServer等相互聯表

2022-10-08 12:01:21

一、大家是否有這個需求

1.跨品種查詢 ：比如 MYSQL和一個SQLSERVER進行聯表查詢 ，或者SQLITE和MYSQL進行聯表查詢

2.跨伺服器查詢 ： A伺服器和B伺服器查詢

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

我的設計是通過多庫架構來實現多庫操作

 

二、 多庫架構ORM

什麼是多庫架構ORM，一個物件可以同時操作和管理多個資料庫 我們稱為多庫架構

EF Core

一個物件只能操作一個資料庫，所以EF Core不能稱為多庫架構，只能稱為支援多種資料庫，如果要實現多庫

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

 

SqlSugar

SqlSugar在2017最火的時候停更了一年半，最大的原因就是因為底層架構影響了SqlSugar的上限，歷史遺留問題太多

需要大量重構，如果直接更新對現有使用者是不負責的，所以我選擇了一年半未更新，讓不是特別熱愛SqlSugar的使用者

先用其他框架，留下對於SqlSugar一直熱衷的使用者，能支援和一起完善SqlSugar的使用者，謝謝有一群這樣的使用者不離不棄

籌劃了一年半的時間終於在2020開始進行重構 每隔一個月就重構一部分 加點功能 ， 直到今天終於重構完成

 

程式碼如下：

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))//當前上下文不存在則新增
    db.AddConnection(new ConnectionConfig{
                           DbType = DbType.SqlServer,ConfigId = "1", 
                IsAutoCloseConnection = true,
                ConnectionString = 。。 });
//開啟事務
try {
 //db我們稱為主Db 
 db.BeginTran(); //開啟多庫 （db.Ado.BeginTran是單庫事務）事務支援單庫和多庫
 
 db.GetConnection("1").Insertable(new Order()//var childDb=db.GetConnection(1);我們稱為子DB，子DB不具有租戶方法，具有單當庫操作方法
 {
   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();
 
 //提交事務 
 db.CommitTran();  
 
}
catch(Exception ex)
{
  //回滾事務
  db.Rollback();
}

多庫架構可以在底層做到相容，比如事務不需要參照外部DLL，比如我可以讓底層語法支援多庫，像EF CORE你能改他的

Include 語法嗎？改不了，我只能封裝他的語法，或者新增擴充套件方法。

 

三、跨伺服器跨庫聯表查詢

SqlSugar來實現跨伺服器聯表查詢

3.1 跨庫查詢之一對一

 [Tenant("db2")]//在類的特性設定當前類屬於哪個庫
  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))] //設定關係 對應Order表主鍵
            public Order Order { get; set; }
 }



//通過ConfigId進行區分是哪個庫
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 }
});

//通過實體類特性[Tenant("db2")]自動對映不同資料庫進行查詢
var list=db.QueryableWithAttr<OrderItem>()
.Includes(z => z.Order)
.ToList(); //1行程式碼就搞定了2個庫聯表查詢

3.2 跨庫查詢之一對多

 [Tenant("db1")]//指定是db1  (OrderItem類設定為 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; }
  }

  var list = db.QueryableWithAttr<Order>()
                    .Includes(z => z.Items)//跨庫一對多
                    .ToList();

3.3 跨庫查詢之多對多　　

我們將3個表扔進3個不同的庫裡面

 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  }
  });p　

　實體

       [Tenant("A")]//指定為A庫
        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))]//設定導航
            public List<Role> Roles { get; set; }
        }


        [Tenant("B")]//指定為B庫
        public partial class Role
        {
            /// <summary>
            /// 角色
            /// </summary>
            [SugarColumn(IsPrimaryKey = true )]
            public int id { get; set; }

            /// <summary>
            /// 角色名稱
            /// </summary>
            public string name { get; set; }
 
        }
 

        [Tenant("AB")]//指定為AB庫
        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個庫3個表進行多對多查詢
var x=db.QueryableWithAttr<OperatorInfo>()
.Includes(z => z.Roles).ToList();

3.4 多個表查詢我們可以這麼寫

//多個表聯表
var x=db.QueryableWithAttr<TB>()
.Includes(z => z.A1)
.Includes(z => z.A2)
.Includes(z => z.A3).ToList();

//多個表巢狀聯表
var x=db.QueryableWithAttr<TB>()
.Includes(z =>z.A1, z.Province,z=>z.City)//4個層級
.Includes(z => z.A2)
.Includes(z => z.A3).ToList();

3.5 手動指定多庫

上面都是通多特性實現的多庫查詢，我們也可以手動指定資料庫進行多庫查詢

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

3.6是否有效能問題

不會SqlSugar跨庫導航和不跨庫導航是一套演演算法，效能有保障，也就是單庫和多庫效能是一樣的

原理：一次獲取需要的資料，在記憶體分設定，資料多可進行拆分讀取

　

如今的成績

    企業認可以：

　 51job 搜尋 簡歷數 僅次 EF 和 Dapper 超過國外的 　Nhibernate PetaPoco ， 佔Dapper 40%簡歷數

    知名收費框架  JNPF 和 力軟 都有使用 SqlSugar

    培訓機構開始 講解SqlSugar

    使用者認可

   擁有強大的生態，3k以上的專案就有4個，基本都在500星以上，不算生態就擁有5個2000人群

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

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

   Viper  FamilyBucket    SmartSql  vboot-net   WMS倉庫管理系統  magic.net   

 

原始碼地址：

SqlSugar一直在努力創新，喜歡的Github關注一下，文章推薦或轉發 

https://github.com/donet5/SqlSugar