You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
100 lines
4.4 KiB
100 lines
4.4 KiB
using SqlSugar;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace OrmTest
|
|
{
|
|
public partial class NewUnitTest
|
|
{
|
|
[SugarTable("UnitUser")]
|
|
public class User2
|
|
{
|
|
[SugarColumn(IsPrimaryKey = true)]
|
|
public int Id { set; get; }
|
|
public string Name { set; get; }
|
|
public int DepartmentId { set; get; }
|
|
}
|
|
[SugarTable("UnitOrder")]
|
|
public class Order2
|
|
{
|
|
[SugarColumn(IsPrimaryKey = true)]
|
|
public int Id { set; get; }
|
|
public string Name { set; get; }
|
|
public int UserId { set; get; }
|
|
}
|
|
[SugarTable("UnitDepartment")]
|
|
public class Department2
|
|
{
|
|
[SugarColumn(IsPrimaryKey = true)]
|
|
public int Id { set; get; }
|
|
public string Name { set; get; }
|
|
}
|
|
public static async Task QueryableAsync2()
|
|
{
|
|
DataBaseInitialize();
|
|
var context = new SqlSugarClient(new ConnectionConfig()
|
|
{
|
|
ConnectionString = "Data Source=.;Initial Catalog=test2222;User id=sa;Password=haosql;pooling=true;min pool size = 2;max pool size=100;",
|
|
DbType = DbType.SqlServer,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = InitKeyType.Attribute,
|
|
});
|
|
//调式代码 用来打印SQL
|
|
context.Aop.OnLogExecuting = (sql, pars) =>
|
|
{
|
|
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss") + "开始\r\n" + sql + "\r\n" + context.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
|
|
};
|
|
context.Aop.OnLogExecuted = (sql, pars) =>
|
|
{
|
|
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss") + "结束\r\n" + sql + "\r\n" + context.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
|
|
};
|
|
var recordCount = new RefAsync<int>();
|
|
//var result = await context.Queryable<Order, User, Department>((o, u, d) => new JoinQueryInfos
|
|
var result = await context.Queryable<Order2, User2>((o, u) => new JoinQueryInfos
|
|
(
|
|
JoinType.Left, o.UserId == u.Id
|
|
//,JoinType.Left, u.DepartmentId == d.Id
|
|
))
|
|
.AS<Order2>("dbo.UnitOrder")
|
|
.AS<User2>("test1111.dbo.UnitUser")
|
|
//.AS<Department>("test1.dbo.Department")
|
|
.Select(o => new User2() { Id = o.Id, Name = o.Name })
|
|
.ToPageListAsync(1, 10, recordCount);
|
|
|
|
Console.ReadLine();
|
|
}
|
|
public static void DataBaseInitialize()
|
|
{
|
|
//数据库1
|
|
var context1 = new SqlSugarClient(new ConnectionConfig()
|
|
{
|
|
ConnectionString = "Data Source=.;Initial Catalog=test1111;User id=sa;Password=haosql;pooling=true;min pool size = 2;max pool size=100;",
|
|
DbType = DbType.SqlServer,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = InitKeyType.Attribute,
|
|
});
|
|
context1.DbMaintenance.CreateDatabase();
|
|
context1.CodeFirst.InitTables(typeof(User2));
|
|
context1.CodeFirst.InitTables(typeof(Department2));
|
|
if (context1.Queryable<User2>().Where(t => t.Id == 1).Count() == 0)
|
|
context1.Insertable(new User2() { Id = 1, Name = "TestUser", DepartmentId = 1 }).ExecuteCommand();
|
|
if (context1.Queryable<Department2>().Where(t => t.Id == 1).Count() == 0)
|
|
context1.Insertable(new Department2() { Id = 1, Name = "TestDepartment" }).ExecuteCommand();
|
|
//数据库2
|
|
var context2 = new SqlSugarClient(new ConnectionConfig()
|
|
{
|
|
ConnectionString = "Data Source=.;Initial Catalog=test2222;User id=sa;Password=haosql;pooling=true;min pool size = 2;max pool size=100;",
|
|
DbType = DbType.SqlServer,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = InitKeyType.Attribute,
|
|
});
|
|
context2.DbMaintenance.CreateDatabase();
|
|
context2.CodeFirst.InitTables(typeof(Order2));
|
|
if (context1.Queryable<User2>().Where(t => t.Id == 1).Count() == 0)
|
|
context2.Insertable(new Order2() { Id = 1, Name = "Order", UserId = 1 }).ExecuteCommand();
|
|
}
|
|
}
|
|
}
|
|
|