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