优点1:支持跨服务器,支持跨数据库品种, 支持任何类型数据库
优点2: 超级强大的性能,能达到本库联表性能
缺点:不支持子表过滤主表 (方案有ToList后在内存过滤, 如果分页可以查前1000条主表在内存分页 前端只显示前10页)
[Tenant("db2")] //实体标为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; } } [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 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自动映射不同数据库进行查询 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):
https://www.cnblogs.com/sunkaixuan/p/16767798.html
优点:联表语法100%可以用
缺点:只支持个别数据库,并且跨服务器比较麻烦需要配置dblink
大多数的数据库支持下面的写法,我们可以通过As指定是哪个库, 查询的时候用别名
注意:不同数据库写法有区别 下面是SqlServer例子 : 库名.dbo.表名
//单表跨库 var list=db.Queryable<Order>().AS("xx.dbo.Order2019").ToList(); //新版本:多表跨库 var list1 = db.Queryable<Order>().AS("xx.dbo.order") //如果跨服务器需要配置dblink,语法上每种数据库有点小差异 .LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId,"yy.dbo.OrderItem") .LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId,"zz.dbo.Custom") .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)
注意:
1.只支持MySql和SqlServer同服务器并且是同一种类型的库(你有办法支持其他库可以反馈给我)
2.查询用的是QueryableWithAttr不是Queryable
//声名SqlSugar对象 var db = new 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 //联表查询要5.1.4.66+才支持 var list1 = db.QueryableWithAttr<Order>() //根根据ConfigId自动实现跨库 .LeftJoin<OrderItem>((o,i)=> o.Id == i.OrderId) .LeftJoin<Custom>((o, i, c) => c.Id == o.CustomId) .Select((o,i,c)=>new classA() { oid=o.Id , iname=i.Name }) .ToList();
像PGSQL ORACLE 等看标题4
除了sqlite,其他的应该都支持dblink配置,只要能配置dblink就能跨库查询
请升级5.1.4.72-preview02+
var db = new SqlSugarClient(new List<ConnectionConfig>() { new ConnectionConfig(){ConfigId="A",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true }, new ConnectionConfig(){ ConfigId="B", DbType=DbType.SqlServer, DbLinkName="db1.ecology2013_SHQC2.dbo",//配置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 db1.ecology2013_SHQC2.dbo.OrderItem
下面是SqlServer的例子
可以企业管理器里添加linkserver实现。
使用sp_addlinkedserver创建一个链接的服务器,使其允许对分布式的、针对 OLEDB 数据源的异类查询进行访问。
在使用 sp_addlinkedserver 创建链接的服务器之后,此服务器就可以执行分布式查询。
步骤:
EXEC sp_addlinkedserver
@server='DB1',--被访问的服务器别名
@srvproduct='', --sqlserver不需要指定
@provider='SQLOLEDB',
5@datasrc='192.168.1.102' --要访问的服务器
EXEC sp_addlinkedsrvlogin
'DB1', --被访问的服务器别名
'false', --useself
NULL, --locallogin
'sa', --帐号
'123456' --密码
2016 © donet5.comApache Licence 2.0