.NET？6？跨服务器联表查询操作MySql、Oracle、SqlServer等相互联表（sqlserver跨服务器插数据）居然可以这样

随心笔谈2年前发布编辑

173 0

🌐 经济型：买域名、轻量云服务器、用途：游戏网站等《腾讯云》特点：特价机便宜适合初学者用点我优惠购买

🚀 拓展型：买域名、轻量云服务器、用途：游戏网站等《阿里云》特点：中档服务器便宜域名备案事多点我优惠购买

🛡️ 稳定型：买域名、轻量云服务器、用途：游戏网站等《西部数码》特点：比上两家略贵但是稳定性超好事也少点我优惠购买

目录一、大家是否有这个需求二、多库架构ORM三、跨服务器跨库联表查询3.1 跨库查询之一对一3.2 跨库查询之一对多3.3 跨库查询之多对多　　3.4 多个表查询我们可以这么写3.5 手动指定多库3.6是否有性能问题

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

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

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

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

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

什么是多库架构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来实现跨服务器联表查询

[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个库联表查询

[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个不同的库里面

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 }
});

　实体

[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();

//多个表联表
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();

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

var list=db.GetConnection(“db1”).Queryable<OrderItem>()//Orderitem是db1
.CrossQuery(typeof(Order), “db2”)//Order是db2
.Includes(z=> z.Order)
.ToList();

不会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微服务

ViperFamilyBucket SmartSqlvboot-net WMS仓库管理系统magic.net

源码地址：

SqlSugar一直在努力创新，喜欢的Github关注一下，文章推荐或转发

https://github.com/donet5/SqlSugar

到此这篇关于.NET 6 跨服务器联表查询操作MySql、Oracle、SqlServer等相互联表的文章就介绍到这了,更多相关.NET 6 跨服务器联表查询内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:SQL Server实现跨库跨服务器访问的方法SQL Server 跨库同步数据MSSQLSERVER跨服务器连接(远程登录)的示例代码深入SQL Server 跨数据库查询的详解SQLServer 跨库查询实现方法SQL Server跨服务器操作数据库的图文方法(LinkedServer)