一、大家是否有这个需求
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; }
?}<br>
?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关注一下,文章推荐或转发?
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
|