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

    一、大家是否有这个需求

    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
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    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你能改他的

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

     

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

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

    3.1 跨库查询之一对一

    ?
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    [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 跨库查询之一对多

    ?
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    [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个不同的库里面

    ?
    1
    2
    3
    4
    5
    6
    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  }
     });p　

    　实体

    ?
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
           [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 多个表查询我们可以这么写

    ?
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    //多个表联表
    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 手动指定多库

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

    ?
    1
    2
    3
    4
    var list =db.GetConnection("db1").Queryable()//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

    　

     

  • 相关阅读:
    计算机丢失mfc140.dll是什么意思？附送修复教程
    mysql 查询优化 、索引失效
    chatgpt相关问题解答
    使用HTML+CSS实现一个静态页面——面包蛋糕 (9页)
    阿里云云安全中心有必要买吗？ 这些功能值得吗？
    金仓数据库KingbaseES客户端编程接口指南-Nodejs（4. 示例）
    边缘技术和小程序容器在智能家居中的应用
    call、apply、bind用法及区别
    (续)SSM整合之spring笔记(AOP AOP概念及相关术语)（P099）
    "科来杯"第十届山东省大学生网络安全技能大赛决赛复现WP
  • 原文地址：https://www.cnblogs.com/sunkaixuan/p/16767798.html