服务器查询-.NET 6 跨服务器联表查询MySql、Oracle、SqlServer

限 时 特 惠： 本站每日持续稳定更新内部创业教程，一年会员只需98元，全站资源免费下载 点击查看详情
站 长 微 信： muyang-0410

一、大家是否有这个需求

1、跨品种查询 ：比如 MYSQL和一个进行联表查询 ，或者和MYSQL进行联表查询

‍

2、跨服务器查询 ：A服务器和B服务器查询如果想同时支持1和2 相信很多人都没有比较好的解决方案我的设计是通过多库架构来实现多库操作

二、 多库架构ORM

什么是多库架构ORM，一个对象可以同时操作和管理多个数据库 我们称为多库架构

EF Core

一个对象只能操作一个数据库，所以EF Core不能称为多库架构，只能称为支持多种数据库，如果要实现多库我们就需外部封装，代码如下

在2017最火的时候停更了一年半，最大的原因就是因为底层架构影响了的上限，历史遗留问题太多需要大量重构，如果直接更新对现有用户是不负责的，所以我选择了一年半未更新，让不是特别热爱的用户先用其他框架，留下对于一直热衷的用户，能支持和一起完善的用户服务器查询，谢谢有一群这样的用户不离不弃筹划了一年半的时间终于在2020开始进行重构 每隔一个月就重构一部分 加点功能 ， 直到今天终于重构完成

代码如下：

var db = new SqlSugarClient(new List()
{
 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你能改他的 语法吗？改不了，我只能封装他的语法，或者添加扩展方法。

三、跨服务器跨库联表查询

来实现跨服务器联表查询

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()
{
  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()
.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 Items { get; set; }
 }
 
 var list = db.QueryableWithAttr()
                   .Includes(z => z.Items)//跨库一对多
                   .ToList();

3.3、跨库查询之多对多

我们将3个表扔进3个不同的库里面

var db = new SqlSugarClient(new List()
   {
       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  }
 });

实体

[Tenant("A")]//指定为A库
public partial class OperatorInfo
{
    /// 

    /// 主键
    /// 
    [SugarColumn(IsPrimaryKey = true)]
    public int id { get; set; }

    /// 

    /// 姓名
    /// 
    public string realname { get; set; }

    /// 

    /// 多角色
    /// 
    [Navigate(typeof(OptRole), nameof(OptRole.operId), nameof(OptRole.roleId))]//配置导航
    public List Roles { get; set;     }
}

[Tenant("B")]//指定为B库
public partial class Role
{
    /// 

    /// 角色
    /// 
    [SugarColumn(IsPrimaryKey = true )]
    public int id { get; set; }

    /// 

    /// 角色名称
    /// 
    public string name { get; set; }

}

[Tenant("AB")]//指定为AB库
public partial class OptRole
{
    /// 

    ///
    /// 
    [SugarColumn(IsPrimaryKey = true)]
    public int id { get; set; }

    /// 

    ///
    /// 
    public int operId { get; set; }

    /// 

    ///
    /// 
    public int roleId { get; set; }


}
 
//3个库3个表进行多对多查询
var x=db.QueryableWithAttr()
.Includes(z => z.Roles).ToList();

3.4、多个表查询我们可以这么写

//多个表联表
var x=db.QueryableWithAttr()
.Includes(z => z.A1)
.Includes(z => z.A2)
.Includes(z => z.A3).ToList();
 
//多个表嵌套联表
var x=db.QueryableWithAttr()
.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是db1
               .CrossQuery(typeof(Order), "db2")//Order是db2
               .Includes(z => z.Order)
               .ToList();

3.6、是否有性能问题

不会跨库导航和不跨库导航是一套算法，性能有保障，也就是单库和多库性能是一样的原理：一次获取需要的数据，在内存分配置，数据多可进行拆分读取

源码

一直在努力创新，喜欢的关注一下

限 时 特 惠： 本站每日持续稳定更新内部创业教程，一年会员只需98元，全站资源免费下载 点击查看详情
站 长 微 信： muyang-0410

admin普通

收藏 海报 链接