devbox
从前慢现在也慢
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

跨库多表联查 SqlServer postgresql MySQL SQLITE .NET ORM_跨库关联查询

作者：从前慢现在也慢 | 2024-07-25 07:27:27

赞

踩

跨库关联查询

一、大家是否有这个需求

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

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

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

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

二、 多库架构ORM

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

EF Core

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

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

SqlSugar

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

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

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

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

代码如下：

  1. var db = new SqlSugarClient(new List<ConnectionConfig>()
  2.  
  3. {
  4.  
  5.  new ConnectionConfig(){ConfigId="0",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true},
  6.  
  7.  new ConnectionConfig(){ConfigId="1",DbType=DbType.MySql,ConnectionString=..,IsAutoCloseConnection=true  }
  8.  
  9. });
  10.  
  11.  
  12.  
  13.  if(!db.IsAnyConnection(configId))//当前上下文不存在则添加
  14.  
  15.     db.AddConnection(new ConnectionConfig{
  16.  
  17.                            DbType = DbType.SqlServer,ConfigId = "1",
  18.  
  19.                 IsAutoCloseConnection = true,
  20.  
  21.                 ConnectionString = 。。 });
  22.  
  23. //开启事务
  24.  
  25. try {
  26.  
  27.  //db我们称为主Db
  28.  
  29.  db.BeginTran(); //开启多库 （db.Ado.BeginTran是单库事务）事务支持单库和多库
  30.  
  31.   
  32.  
  33.  db.GetConnection("1").Insertable(new Order()//var childDb=db.GetConnection(1);我们称为子DB，子DB不具有租户方法，具有单当库操作方法
  34.  
  35.  {
  36.  
  37.    CreateTime = DateTime.Now,
  38.  
  39.    CustomId = 1,
  40.  
  41.    Name = "a",
  42.  
  43.    Price = 1
  44.  
  45.  }).ExecuteCommand();
  46.  
  47.   
  48.  
  49.  db.GetConnection("2").Insertable(new Order()
  50.  
  51.  {
  52.  
  53.    CreateTime = DateTime.Now,
  54.  
  55.    CustomId = 1,
  56.  
  57.    Name = "a",
  58.  
  59.    Price = 1
  60.  
  61.  }).ExecuteCommand();
  62.  
  63.   
  64.  
  65.  //提交事务
  66.  
  67.  db.CommitTran(); 
  68.  
  69.   
  70.  
  71. }
  72.  
  73. catch(Exception ex)
  74.  
  75. {
  76.  
  77.   //回滚事务
  78.  
  79.   db.Rollback();
  80.  
  81. }

 

多库架构可以在底层做到兼容，比如事务不需要引用外部DLL，比如我可以让底层语法支持多库，像EF CORE你能改他的

Include 语法吗？改不了，我只能封装他的语法，或者添加扩展方法。

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

SqlSugar来实现跨服务器联表查询

3.1 跨库查询之一对一

  1. [Tenant("db2")]//在类的特性设置当前类属于哪个库
  2.  
  3.   public class OrderItem
  4.  
  5.  {
  6.  
  7.             [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
  8.  
  9.             public int ItemId { get; set; }
  10.  
  11.             public int OrderId { get; set; }
  12.  
  13.             public decimal? Price { get; set; }
  14.  
  15.             [SqlSugar.SugarColumn(IsNullable = true)]
  16.  
  17.             public DateTime? CreateTime { get; set; }
  18.  
  19.             [Navigate(NavigateType.OneToOne,nameof(OrderId))] //设置关系 对应Order表主键
  20.  
  21.             public Order Order { get; set; }
  22.  
  23.  }
  24.  
  25.  
  26.  
  27.  
  28.  
  29.  
  30.  
  31. //通过ConfigId进行区分是哪个库
  32.  
  33. var db = new SqlSugarClient(new List<ConnectionConfig>()
  34.  
  35. {
  36.  
  37.   new ConnectionConfig(){ConfigId="db1",DbType=DbType.Sqlite,ConnectionString="DataSource=/Db_OrderDb.sqlite",IsAutoCloseConnection=true},
  38.  
  39.   new ConnectionConfig(){ConfigId="db2",DbType=DbType.Sqlite,ConnectionString="DataSource=/Db_OrderItemDb.sqlite",IsAutoCloseConnection=true }
  40.  
  41. });
  42.  
  43.  
  44.  
  45. //通过实体类特性[Tenant("db2")]自动映射不同数据库进行查询
  46.  
  47. var list=db.QueryableWithAttr<OrderItem>()
  48.  
  49. .Includes(z => z.Order)
  50.  
  51. .ToList(); //1行代码就搞定了2个库联表查询

 

3.2 跨库查询之一对多

  1. [Tenant("db1")]//指定是db1  (OrderItem类设置为 db2)
  2.  
  3.  public class Order
  4.  
  5.  {
  6.  
  7.            [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
  8.  
  9.            public int Id { get; set; }
  10.  
  11.            public string Name { get; set; }
  12.  
  13.            public decimal Price { get; set; }
  14.  
  15.            [SugarColumn(IsNullable = true)]
  16.  
  17.            public DateTime CreateTime { get; set; }
  18.  
  19.            [SugarColumn(IsNullable = true)]
  20.  
  21.            public int CustomId { get; set; }
  22.  
  23.            [Navigate(NavigateType.OneToMany, nameof(OrderItem.OrderId))]//
  24.  
  25.            public List<OrderItem> Items { get; set; }
  26.  
  27.  }<br>
  28.  
  29.  var list = db.QueryableWithAttr<Order>()
  30.  
  31.                    .Includes(z => z.Items)//跨库一对多
  32.  
  33.                    .ToList();

 

3.3 跨库查询之多对多　　

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

  1. var db = new SqlSugarClient(new List<ConnectionConfig>()
  2.  
  3.    {
  4.  
  5.        new ConnectionConfig(){ConfigId="A",DbType=DbType.Sqlite,ConnectionString="DataSource=/A_DB.sqlite",IsAutoCloseConnection=true},
  6.  
  7.        new ConnectionConfig(){ConfigId="B",DbType=DbType.Sqlite,ConnectionString="DataSource=/B_DB.sqlite",IsAutoCloseConnection=true  },
  8.  
  9.        new ConnectionConfig(){ConfigId="AB",DbType=DbType.Sqlite,ConnectionString="DataSource=/AB_DB.sqlite",IsAutoCloseConnection=true  }
  10.  
  11.  });p　

 

　实体

  1.  [Tenant("A")]//指定为A库
  2.  
  3.         public partial class OperatorInfo
  4.  
  5.         {
  6.  
  7.             /// <summary>
  8.  
  9.             /// 主键
  10.  
  11.             /// </summary>
  12.  
  13.             [SugarColumn(IsPrimaryKey = true)]
  14.  
  15.             public int id { get; set; }
  16.  
  17.  
  18.  
  19.             /// <summary>
  20.  
  21.             /// 姓名
  22.  
  23.             /// </summary>
  24.  
  25.             public string realname { get; set; }
  26.  
  27.  
  28.  
  29.             /// <summary>
  30.  
  31.             /// 多角色
  32.  
  33.             /// </summary>
  34.  
  35.             [Navigate(typeof(OptRole), nameof(OptRole.operId), nameof(OptRole.roleId))]//配置导航
  36.  
  37.             public List<Role> Roles { get; set; }
  38.  
  39.         }
  40.  
  41.  
  42.  
  43.  
  44.  
  45.         [Tenant("B")]//指定为B库
  46.  
  47.         public partial class Role
  48.  
  49.         {
  50.  
  51.             /// <summary>
  52.  
  53.             /// 角色
  54.  
  55.             /// </summary>
  56.  
  57.             [SugarColumn(IsPrimaryKey = true )]
  58.  
  59.             public int id { get; set; }
  60.  
  61.  
  62.  
  63.             /// <summary>
  64.  
  65.             /// 角色名称
  66.  
  67.             /// </summary>
  68.  
  69.             public string name { get; set; }
  70.  
  71.   
  72.  
  73.         }
  74.  
  75.   
  76.  
  77.  
  78.  
  79.         [Tenant("AB")]//指定为AB库
  80.  
  81.         public partial class OptRole
  82.  
  83.         {
  84.  
  85.             /// <summary>
  86.  
  87.             ///
  88.  
  89.             /// </summary>
  90.  
  91.             [SugarColumn(IsPrimaryKey = true)]
  92.  
  93.             public int id { get; set; }
  94.  
  95.  
  96.  
  97.             /// <summary>
  98.  
  99.             ///
  100.  
  101.             /// </summary>
  102.  
  103.             public int operId { get; set; }
  104.  
  105.  
  106.  
  107.             /// <summary>
  108.  
  109.             ///
  110.  
  111.             /// </summary>
  112.  
  113.             public int roleId { get; set; }
  114.  
  115.  
  116.  
  117.  
  118.  
  119.         }
  120.  
  121.  
  122.  
  123. //3个库3个表进行多对多查询
  124.  
  125. var x=db.QueryableWithAttr<OperatorInfo>()
  126.  
  127. .Includes(z => z.Roles).ToList();

 

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

  1. //多个表联表
  2.  
  3. var x=db.QueryableWithAttr<TB>()
  4.  
  5. .Includes(z => z.A1)
  6.  
  7. .Includes(z => z.A2)
  8.  
  9. .Includes(z => z.A3).ToList();
  10.  
  11.  
  12.  
  13. //多个表嵌套联表
  14.  
  15. var x=db.QueryableWithAttr<TB>()
  16.  
  17. .Includes(z =>z.A1, z.Province,z=>z.City)//4个层级
  18.  
  19. .Includes(z => z.A2)
  20.  
  21. .Includes(z => z.A3).ToList();

 

3.5 手动指定多库

上面都是通多特性实现的多库查询，我们也可以手动指定数据库进行多库查询

  1. var list =db.GetConnection("db1").Queryable<OrderItem>()//Orderitem是db1
  2.  
  3.                .CrossQuery(typeof(Order), "db2")//Order是db2
  4.  
  5.                .Includes(z => z.Order)
  6.  
  7.                .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关注一下，文章推荐或转发 

GitHub - donet5/SqlSugar: Best ORM Fastest ORM Simple Easy Sqlite orm Oracle ORM Mysql Orm postgresql ORm SqlServer oRm 达梦 ORM 人大金仓 ORM 神通ORM C# ORM , C# ORM .NET ORM NET5 ORM .NET6 ORM ClickHouse orm QuestDb

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/878986
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号