.NET 6 跨服务器联表查询, MySql、Oracle、SqlServer等相互联表

  • .NET 6 跨服务器联表查询, MySql、Oracle、SqlServer等相互联表已关闭评论
  • 45 次浏览
  • A+
所属分类:.NET技术
摘要

1.跨品种查询 :比如 MYSQL和一个SQLSERVER进行联表查询 ,或者SQLITE和MYSQL进行联表查询


一、大家是否有这个需求

1.跨品种查询 :比如 MYSQL和一个SQLSERVER进行联表查询 ,或者SQLITE和MYSQL进行联表查询

2.跨服务器查询 : A服务器和B服务器查询

 如果想同时支持12 相信很多人都没有比较好的解决方案

我的设计是通过多库架构来实现多库操作

 

二、 多库架构ORM

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

EF Core

一个对象只能操作一个数据库,所以EF Core不能称为多库架构,只能称为支持多种数据库,如果要实现多库

我们就需外部封装,代码如下

.NET 6 跨服务器联表查询, MySql、Oracle、SqlServer等相互联表

 

SqlSugar

SqlSugar在2017最火的时候停更了一年半,最大的原因就是因为底层架构影响了SqlSugar的上限,历史遗留问题太多

需要大量重构,如果直接更新对现有用户是不负责的,所以我选择了一年半未更新,让不是特别热爱SqlSugar的用户

先用其他框架,留下对于SqlSugar一直热衷的用户,能支持和一起完善SqlSugar的用户,谢谢有一群这样的用户不离不弃

筹划了一年半的时间终于在2020开始进行重构 每隔一个月就重构一部分 加点功能 , 直到今天终于重构完成

.NET 6 跨服务器联表查询, MySql、Oracle、SqlServer等相互联表

 

代码如下:

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