.NET 6 跨服务器联表查询 _生活百科

一、大家是否有这个需求1.跨品种查询：比如 MYSQL和一个SQLSERVER进行联表查询，或者SQLITE和MYSQL进行联表查询
2.跨服务器查询： A服务器和B服务器查询
如果想同时支持1和2 相信很多人都没有比较好的解决方案
我的设计是通过多库架构来实现多库操作
二、多库架构ORM什么是多库架构ORM，一个对象可以同时操作和管理多个数据库我们称为多库架构
EF Core一个对象只能操作一个数据库，所以EF Core不能称为多库架构，只能称为支持多种数据库，如果要实现多库
我们就需外部封装，代码如下

文章插图
SqlSugarSqlSugar在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个库联表查询