【跨库查询、多库查询】.NET开源 ORM 框架 SqlSugar 系列

ops/2024/12/16 21:24:27/

文章目录

  • 一、跨库方式1：跨库导航
  • 二、手动跨库查询
  • 三、同服务器：自动查询跨库查询
    • 3.1 Mysql和SqlServer自动
    • 3.2 自动: PgSql跨Scheme查询
    • 3.3 其他库同服务器
  • 四、跨服务器：自动跨库查询
    • 4.1 配置SqlServer dblink
    • 4.2 配置 Oracle dblink
    • 4.3 配置 PgSql Pwd外部表
    • 4.4 其他跨服务器联表
  • 五、跨库子查询
    • 5.1 用ThenMapper实现
    • 5.2 Subqueryable
    • 5.3 嵌套查询或者Unionall
  • 六、.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列🪭🪭🪭

一、跨库方式1：跨库导航

最低版本支持：（5.1.3.24）

  • ✅优点1：支持跨服务器，支持跨数据库品种, 支持任何类型数据库
  • ✅优点2: 超级强大的性能，能达到本库联表性能
  • 🚫缺点：不支持 子表过滤主表 (方案有 ToList 后在内存过滤， 如果分页可以查 前1000条 主表在内存分页 前端只显示 前10页 )
[Tenant("db2")] //实体标为db2
public class OrderItem{[SQLSUGAR.html" title=SqlSugar>SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]public int ItemId { get; set; }public int OrderId { get; set; }public decimal? Price { get; set; }[SQLSUGAR.html" title=SqlSugar>SqlSugar.SugarColumn(IsNullable = true)]public DateTime? CreateTime { get; set; }[Navigate(NavigateType.OneToOne,nameof(OrderId))] //设置关系 对应Order表主键public Order Order { get; set; }}
[Tenant("db1")] //实体标为db1
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; }}//通过ConfigId进行区分是哪个库
var db = new SQLSUGAR.html" title=SqlSugar>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 }
});//注意：如果是接口需要
//db.AsTenant().QueryableWithAttr<OrderItem>()//通过实体类特性Tenant自动映射不同数据库进行查询
var list=db.QueryableWithAttr<OrderItem>()
.Includes(z => z.Order)
.ToList(); //1行代码就搞定了2个库联表查询//不通过特性实现跨库导航
var list =db.GetConnection("db1").Queryable<OrderItem>()//Orderitem是db1.CrossQuery(typeof(Order), "db2")//Order是db2.Includes(z => z.Order).ToList();

如果想详细了解，请移步 详细教程 (5.1.3.25)

二、手动跨库查询

  • ✅优点：联表语法100%可以用

  • 🚫缺点：只支持个别数据库，并且跨服务器比较麻烦需要配置dblink

大多数的数据库支持下面的写法，我们可以通过 As 指定是哪个库, 查询的时候用别名

🎯注意：不同数据库写法有区别 下面是 SqlServer 例子 ： 库名 .dbo.表名

//单表跨库
var  list=db.Queryable<Order>().AS("xx.dbo.Order2019").ToList();//SqlServer (跨库用dblink)
var list1 = db.Queryable<Order>() //主表用当前db就行了.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId,"yy.dbo.OrderItem")  .LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId,"zz.dbo.Custom") .Where((o,i,c)=> o.TypeId==1).Select((o,i,c)=>new classA() { oid=o.Id , iname=i.Name }).ToList();//MySql (只能同服务器)       
var list1 = db.Queryable<Order>().  //如果跨服务器需要配置dblink，语法上每种数据库有点小差异.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId,"yy.OrderItem")  .LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId,"zz.Custom") .Where((o,i,c)=> o.TypeId==1).Select((o,i,c)=>new classA() { oid=o.Id , iname=i.Name }).ToList(); //Oracle  
var list1 = db.Queryable<Order>() .LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId,"\"ORDERITEM\"@dblink_name")  .LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId,"\"CUSTEM\"@dblink_name") .Where((o,i,c)=> o.TypeId==1).Select((o,i,c)=>new classA() { oid=o.Id , iname=i.Name }).ToList();     //其他库同理//老版本：多表跨库
var list1 = db.Queryable<Order>().AS("xx.dbo.order") // AS("").LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId).AS<OrderItem>("yy.dbo.OrderItem") //AS<T>.LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId) .AS<Custom>("zz.dbo.Custom")//AS<T>.Select((o,i,c)=>new classA() { oid=o.Id , iname=i.Name }).ToList();//获取表名可以减少字符串操作var tableName=db.EntityMaintenance.GetTableName<T>()       //如果有2个AS<T>是相同我们可以这么写.LeftJoin(db.Queryable<T>().AS("xx.dbo.zzzz"),(o,i)=>o.id==i.id)

请升级到5.1.4.86-preview01+

三、同服务器：自动查询跨库查询

3.1 Mysql和SqlServer自动

🎯注意：

  1. 只支持 MySql 和 SqlServer 同服务器并且是同一种类型的库（你有办法支持其他库可以反馈给我）
  2. 查询用的是 QueryableWithAttr 不是 Queryable
//声名SQLSUGAR.html" title=SqlSugar>SqlSugar对象
var db = new SQLSUGAR.html" title=SqlSugar>SqlSugarClient(new List<ConnectionConfig>()
{new ConnectionConfig(){ConfigId="A",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true},new ConnectionConfig(){ConfigId="B",DbType=DbType.MySql,ConnectionString=..,IsAutoCloseConnection=true  },new ConnectionConfig(){ConfigId="C",DbType=DbType.MySql,ConnectionString=..,IsAutoCloseConnection=true  }
});//实体配置是哪个库
[Tenant("A")] //实体标为A表示是A库
public class OrderItem
[Tenant("B")] //实体标为B表示是B库
public class Order//联表查询要5.1.4.66+才支持
var list = db.QueryableWithAttr<Order>() //根根据ConfigId自动实现跨库.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId)  .LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId) .Where((o,i,c)=> o.TypeId==1).Select((o,i,c)=>new classA() { oid=o.Id , iname=i.Name }).ToList();//ISQLSUGAR.html" title=SqlSugar>SqlSugarClient需要转一下租户接口，才能用租户方法
var list =db.AsTenant().QueryableWithAttr<Order>()....

3.2 自动: PgSql跨Scheme查询

var db = new SQLSUGAR.html" title=SqlSugar>SqlSugarClient(new List<ConnectionConfig>()
{new ConnectionConfig(){ConfigId="A",DbType=DbType.PostgreSQL,ConnectionString="..",IsAutoCloseConnection=true},new ConnectionConfig(){ConfigId="B",DbType=DbType.PostgreSQL,DbLinkName="public",//重点ConnectionString=".....;searchpath=public"//重点 ,IsAutoCloseConnection=true  },     
});
var x3 = db.QueryableWithAttr<OptRole>().LeftJoin<Role>((x1, y1) => x1.roleId == y1.id)//Left Join时会加上public..ToList();//ISQLSUGAR.html" title=SqlSugar>SqlSugarClient需要转一下租户接口，才能用租户方法
var list =db.AsTenant().QueryableWithAttr<Order>()....

3.3 其他库同服务器

🕹️找库规则3种：

  1. SqlServer: 库名.dbo.表名
  2. PgSql或者同类库:有配置 DbLinkName 和 searchpath : DbLinkName.表名
  3. 其他库: 库名.表名

用法就上面3种用法，如果发现哪个数据库不支持可以和我反馈。

四、跨服务器：自动跨库查询

除了 sqlite，其他的应该都支持 dblink 配置，只要能配置 dblink 就能跨库查询，也支持同服务器跨库。

4.1 配置SqlServer dblink

请升级5.1.4.72-preview02+

var db = new SQLSUGAR.html" title=SqlSugar>SqlSugarClient(new List<ConnectionConfig>()
{new ConnectionConfig(){ConfigId="A",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true  },new ConnectionConfig(){ConfigId="B",DbType=DbType.SqlServer,//有些用户可以用IP跨库//DbLinkName="[192.168.1.110].db240425.dbo."DbLinkName="db1.ecology2013_SHQC2.dbo",//IP不能连在配置DbLinkConnectionString="..",IsAutoCloseConnection=true  }
});
//实体配置是哪个库
[Tenant("B")] //实体标为A表示是A库
public class OrderItem//联表查询要5.1.4.66+才支持
var list1 = db.QueryableWithAttr<Order>() //根根据ConfigId自动实现跨库.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId)  .ToList();
//生成Sql        
//Left join db1.ecology2013_SHQC2.dbo.OrderItem

下面是 SqlServer 的例子

  • ✅ 可以企业管理器里添加 linkserver 实现。
  • ✅ 使用 sp_addlinkedserver 创建一个链接的服务器，使其允许对分布式的、针对 OLEDB 数据源的异类查询进行访问。
  • ✅ 在使用 sp_addlinkedserver 创建链接的服务器之后，此服务器就可以执行分布式查询。

🎢 步骤：

  1. 创建 linkserver
 EXEC sp_addlinkedserver@server='DB1',--被访问的服务器别名@srvproduct='', --sqlserver不需要指定@provider='SQLOLEDB',5@datasrc='192.168.1.102' --要访问的服务器
  1. 登录链接服务器
EXEC sp_addlinkedsrvlogin 'DB1', --被访问的服务器别名'false', --useselfNULL, --locallogin'sa', --帐号 '123456' --密码

4.2 配置 Oracle dblink

请升级到5.1.4.86-preview02+

var db = new SQLSUGAR.html" title=SqlSugar>SqlSugarClient(new List<ConnectionConfig>()
{new ConnectionConfig(){ConfigId="A",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true  },new ConnectionConfig(){ConfigId="B",DbType=DbType.SqlServer,DbLinkName="@dblink_name",//配置dblink名字要@开头ConnectionString=..,IsAutoCloseConnection=true  }
});
//实体配置是哪个库
[Tenant("B")] //实体标为A表示是A库
public class OrderItem//联表查询要5.1.4.66+才支持
var list1 = db.QueryableWithAttr<Order>() //根根据ConfigId自动实现跨库.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId)  .ToList();
//生成Sql        
//Left join  OrderItem@dblink_name

下面是 Oracle 的例子

CREATE DATABASE LINK dblink_name
CONNECT TO target_usernameIDENTIFIED BY target_passwordUSING'(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=target_host)(PORT=target_port))(CONNECT_DATA=(SERVICE_NAME=target_service_name)))';

4.3 配置 PgSql Pwd外部表

请升级到 5.1.4.86-preview02+

var db = new SQLSUGAR.html" title=SqlSugar>SqlSugarClient(new List<ConnectionConfig>()
{new ConnectionConfig(){ConfigId="A",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true  },new ConnectionConfig(){ConfigId="B",DbType=DbType.SqlServer,DbLinkName="remote_",//命名要以_结尾ConnectionString=..,IsAutoCloseConnection=true  }
});
//实体配置是哪个库
[Tenant("B")] //实体标为A表示是A库
public class OrderItem//联表查询要5.1.4.66+才支持
var list1 = db.QueryableWithAttr<Order>() //根根据ConfigId自动实现跨库.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId)  .ToList();
//生成Sql        
//Left join  remote_OrderItem

下面是 PgSql 的例子

首先，在源数据库中创建 postgres_fdw 扩展：

CREATE EXTENSION postgres_fdw;

在源数据库中创建外部服务器对象，指定目标数据库的连接信息：

CREATE SERVER target_serverFOREIGN DATA WRAPPER postgres_fdwOPTIONS (dbname 'targetdb', host 'targethost', port 'targetport');

在上面的示例中，target_server 是外部服务器的名称，你需要提供目标数据库的连接信息，如目标数据库的名称、主机和端口。

创建用户映射，将源数据库的用户映射到目标服务器的用户：


CREATE USER MAPPING FOR current_userSERVER target_serverOPTIONS (user 'targetuser', password 'targetpassword');

确保提供正确的目标服务器的用户名和密码。

创建外部表，在源数据库中创建一个外部表，该表将映射到目标数据库中的表：

CREATE FOREIGN TABLE IF NOT EXISTS remote_OrderItem (column1 INT,column2 TEXT,...
) SERVER target_server;

字段结构要一样才能同步

现在，你可以在源数据库中查询外部表，就像查询本地表一样：


SELECT * FROM remote_table;

请升级到5.1.4.86-preview02+

4.4 其他跨服务器联表

只要配置好 dblinkName 找表规则：

  1. 默认: dblinkName.[表名]

  2. dblinkName 以 _ 结尾: dblinkName表名 (这个表名是没有转释符号的，像`` 、[]、 “” 我们称为转释符号)

  3. dblinkName 以 @ 开头： [表名]@dblinkName

var list1 = db.QueryableWithAttr<Order>() //根根据ConfigId自动实现跨库.LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId)  .ToList();
//生成Sql        
//Left join  规则生成的表名

请升级到5.1.4.86-preview02+

五、跨库子查询

5.1 用ThenMapper实现

支持跨库的类型，只能用在 Select 对象填充

//跨库 
var mydb=db.GetConnection(1);
mydb.ThenMapper(root,item=>{...});

5.2 Subqueryable

请升级:5.1.4.107-preview11+

 db.Queryable<Order>().Select(it => new { x= SqlFunc.Subqueryable<OrderItem>().AsWithAttr().Select(s => s.OrderId)//生成表名规则看：4.4和3.3}).ToList();//也可以用AS("表名")SqlFunc.Subqueryable<Order>().AS("yyy.Order01").InnerJoin<OrderItem>((x,y)=>x.Id==y.OrderId, "yyy.OrderItem01").Select(x=>x.Id)

5.3 嵌套查询或者Unionall

 //强制名库+表名一般在嵌套或者unionall不能切换库中用
var q=db.Queryable<Order>().AsWithAttr().Where(it=>it.Id>10);
var  q2=db.Queryable<Order>().AsWithAttr().Where(it=>it.Id<2);
db.UnionAll(q,q2).ToList();
//下面用于嵌套查询或者union all

ORM__SQLSUGAR.html" title=SqlSugar>SqlSugar__409">六、.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列🪭🪭🪭

  1. 【开篇】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  2. 【入门必看】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  3. 【实体配置】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  4. 【Db First】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  5. 【Code First】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  6. 【数据事务】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  7. 【连接池】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  8. 【查询目录】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  9. 【查询基础】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  10. 【排序用法】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  11. 【分组去重】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  12. 【联表查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  13. 【导航查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  14. 【子查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  15. 【嵌套查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  16. 【配置查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  17. 【并集查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  18. 【树型查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  19. 【表格查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  20. 【动态表达式】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  21. 【查询函数】.NET开源ORM框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  22. 【过滤器】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  23. 【跨库查询、多库查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列
  24. 【分页查询】.NET开源 ORM 框架 SQLSUGAR.html" title=SqlSugar>SqlSugar 系列

在这里插入图片描述


http://www.ppmy.cn/ops/142465.html

相关文章

BGP-面试

BGP-面试

简单介绍一下BGP BGP&#xff0c;边界网关协议&#xff0c;属于路径矢量路由协议。属于触发式更新或者增量更新。具有丰富的路由策略&#xff0c;能够灵活的进行路由选择。重心不是在路由学习&#xff0c;而是路由优选、更高效的传递路由和维护大量的路由信息。基于TCP&#xf…
阅读更多...
webrtc学习----前端推流拉流，局域网socket版，一对一

webrtc学习----前端推流拉流，局域网socket版，一对一

提示&#xff1a;局域网socket版 文章目录 [TOC](文章目录) 前言一、教程二、webrtc工作流程三、推流端四、拉流五、socket服务六、效果七、备注总结 前言 ‌‌‌‌‌WebRTC&#xff08;Web Real-Time Communication&#xff09;‌是一种实时通讯技术&#xff0c;允许网络应用或…
阅读更多...
安全防御之备份恢复技术

安全防御之备份恢复技术

随着计算机和网络的不断普及&#xff0c;人们更多的通过网络来传递大量信息。在网络环境下&#xff0c;还有各种各样的病毒感染、系统故障、线路故障等&#xff0c;使得数据信息的安全无法得到保障。由于安全风险的动态性&#xff0c;安全不是绝对的&#xff0c;信息系统不可能…
阅读更多...
游戏引擎学习第41天

游戏引擎学习第41天

这一节就讨论了一些数学知识 讨论为什么要进行数学讨论 现在到了需要真正开始讨论数学的时候了&#xff0c;因为从这一步开始&#xff0c;几乎所有计划做的事情都将涉及比基本代数更复杂的数学内容。到目前为止所做的一切基本都可以用基础代数技能理解&#xff0c;但从现在开…
阅读更多...
Linux更改远程默认SSL端口

Linux更改远程默认SSL端口

1、登录Linux服务器 2、编辑ssh服务配置文件&#xff1a;vi /etc/ssh/sshd_config 光标移至“#Port 22”位置&#xff0c;按“i”进入编辑模式&#xff0c;然后键盘按一下回车键&#xff0c;新增一行 Port 2022 编辑好&#xff0c;先按ESC键&#xff0c;再输入:wq 保存退出.&…
阅读更多...
git回退到指定提交版本

git回退到指定提交版本

当把代码部署到服务器上后&#xff0c;发现有问题&#xff0c;代码跑不起来&#xff0c;要回退怎么办&#xff1f; 首先看git 日志 git log然后&#xff0c;找到具体要回退的commit号&#xff0c;使用git reset --hard xxx号 命令 git reset --hard aff2ebdb9c80ba7a5473152…
阅读更多...
.net 8.0项目创建数据库链接

.net 8.0项目创建数据库链接

1 在项目的appsettings.json 文件中&#xff0c;添加 数据库链接字符串 "ConnectionStrings": {"DefaultConnection": "Server.;DatabaseDatabasename;User Idsa;Password123456;Encryptfalse;TrustServerCertificatetrue; " }, 注意 Encrypt…
阅读更多...
初识行数据库与列数据库

初识行数据库与列数据库

在数据管理和处理领域&#xff0c;行数据库&#xff08;Row-oriented Database&#xff09;和列数据库&#xff08;Column-oriented Database&#xff09;是两种重要的数据组织方式。它们各自拥有独特的特性&#xff0c;适用于不同类型的应用场景。本文将深入探讨这两种数据库的…
阅读更多...
最新文章

Copyright @ 2022~2023