[TOC]
请下载 最新版本.zip =======================以下内容可做参考===============================================
-
kQL.orm产品采用 (db first) 数据库优先模式进行处理，即您需要先建好数据库。
-
配套模型层生成工具（kQL.orm.cmdTool.exe）。通过该工具可以自动生成实体层（或者叫Entity层或Model层或...），即：表>>实体，视图>>实体，存储过程>> 实体。当数据库表结构修改后，只需重新执行一遍该工具，就自动同步了映射的实体。使用方便，可以使开发者更加专注于数据库本身的设计，更加集中精力关注于多个实体模型之间的逻辑处理。
-
简化数据访问操作，提升开发效率。支持扩展函数的嵌套调用，支持存储过程、视图、表的操作，支持复杂的嵌套查询（多表join、In子查询、Exists子查询），支持大批量数据插入（bulk insert），支持复杂的更新操作（update..from..）。
-
使项目结构和代码更加精炼，减少30%+的数据访问层代码量。
-
支持实例对象的混合操作（即A类型实例a，B类型实例b，...，可以在同一批次中提交增、删、改），支持实例类型条件的操作
（如：更新、删除表无需定义主键 ，只根据条件）
-
自动版本控制（基于数据库TIMESTAMP类型）或（框架内定义的v字段，支持两种类型int,guid。int用于自增长的版本、guid用于无需自增的版本控制）
-
对数据库内置函数做了扩展，扩展函数可多层嵌套调用，字段支持四则运算，几乎支持所有的数据库内置函数，包括：字符串函数, 时间日期函数, 数学函数, 转型函数, 聚合函数, 系统函数, 扩展函数
-
支持上下文环境中调用方法、属性等动态计算的变量。（如：Where(user=>user.name == GetUserName() )，其中GetUserName()是上下文中的方法。
-
实例对象的增、删、改，内置事务处理。对于所有的查询，使用的事务隔离级别READ UNCOMMITTED.
-
支持不同SQL Server数据库之间的数据同步，通过框架内CopyToRemote方法实现数据库之间的同步。 强大之处在于通过定义DyQuery表达式，就可以实现大数据量的复制。非常灵活，很多应用场景下很有用。
-
支持标量函数、表值函数 ，如果数据库中含有用户自定义函数（UDF），模型生成工具，会将自定义函数（UDF）生一个Dy_UDF.cs文件，标量函数和表值函数会生成相应的函数在该文件中。（表值函数还会生成一个FModel_开头的模型类）
-
支持中间表，框架中定义了DyXTable类型作为中间表处理的类型，可以适应更加复杂的场景。当[主表]的某个[字段]需要[子表聚合查询]结果去更新时比较有用。如：当需要通过[订单明细表]的总数量、合计总价=>更新[订单表]的数量、总价 时，可以通过DyXTable中间表的方式去处理。
生成单条SQL语句一次连接 数据库就完成操作了。
批插、和数据同步时注意需要设置超时时间，因为默认只有30秒。
- 批量插入
//本地库数据初始化 插入10万条用户数据
var localDy = new Dy();//本地库执行者
int insertCount = 100000;//插入数据的数量
Console.WriteLine("开始测试_导数据,本地库插入{0}条用户数据", insertCount);
Console.WriteLine("开始生成数据");
List<tb_user> userlist = new List<tb_user>();
for (int i = 200; i < insertCount + 200; i++)
{
userlist.Add(
new tb_user
{
自增NO = i, //自增列 框架不会去插入
账号 = string.Format("U{0:D4}", i),
密码 = "12345678",
用户名 = string.Format("Tester{0:D3}", i),
性别 = i % 2 == 0,
年龄 = RNG.Next(20, 60),
会员等级 = (byte)(RNG.Next(1, 255)),
积分 = RNG.Next(1000, 10000),
消费能力 = Math.Abs((short)RNG.Next(1, 100)),
头像 = 获取头像(i),//byte[]数据,照片大小8k左右每张
注册日期 = DateTime.Now
});
}
Console.WriteLine("完成生成数据，开始执行插入本地库");
long ms = localDy.BulkInsert(userlist); //本地库插入10万条数据
Console.WriteLine("插入本地库{1}条数据执行:{0}毫秒", ms, insertCount);
Console.WriteLine();
- 数据同步、字段的四则运算
//场景一：本地库与远程库 表结构一致>>单表->同步到远程服务器
//kQL.orm.demo命名空间下为本地库的实体类
//kQL.orm.remotemodels命名空间下为远程库的实体类
var localDy = new Dy();//本地库执行者
var remoteDy = new Dy("remoteServer");//远程库执行者
Console.WriteLine("开始执行导入远程服务器");
var query1 = new DyQuery<kQL.orm.demo.tb_user>().AsQuery();
var result = localDy
.CopyToRemote<kQL.orm.demo.remotemodels.tb_user>(query1, remoteDy);
Console.WriteLine("完成导入远程服务器，本次执行毫秒:{0}", result.Item1);
Console.WriteLine();
//场景二：本地库与远程库 表结构不一致>>多表的组合->同步到远程服务器
//****灵活定义、快速同步
var query2 = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3)
.On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Having<tb_order_detail>(WhereWay.And,
t3 => t3.订单ID.Dy_Count() > 5
).Select<tb_order, tb_order_detail>(
(t2, t3) => new
{
t2.订单ID,
t2.账号,
明细数量 = t3.订单ID.Dy_Count(),
总金额Max = t3.支付价.Dy_Max(),
总金额Min = t3.支付价.Dy_Min(),
总金额Sum = t3.支付价.Dy_Sum(),
总金额Avg = t3.支付价.Dy_Avg(),
R金额 = ((t3.支付价.Dy_Max() + t3.支付价.Dy_Min() - t3.支付价.Dy_Sum() * t3.支付价.Dy_Avg()) / t3.支付价.Dy_Min()).Dy_Convert<decimal, decimal>("decimal(18,2)") //四则运算及转型
}
).AsQuery();
var result = localDy.CopyToRemote<kQL.orm.demo.remotemodels.tb_order_info>(query2, remoteDy);
Console.WriteLine("本地多表的组合->同步到远程服务器->本次执行毫秒:{0}", result.Item1);
- Exists子查询
//Exists 子查询
var query5 = new DyQuery<tb_user>()
.Exists(WhereWay.And
, new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3)
.On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
//与下面等价
//.Join<tb_order_detail>(JoinWay.InnerJoin, (t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Having<tb_order_detail>(WhereWay.And, t3 => t3.订单ID.Dy_Count() > 5)
//.Select<tb_order, tb_order_detail>((t2, t3) => new { t2.订单ID, t2.账号, 明细数量 = t3.订单ID.Dy_Count() })
.Where<tb_order, tb_user>((t2, t1) => t2.账号 == t1.账号)
.Select(t2 => 1).AsQuery()
)
.Select(t1 => new { t1.账号, t1.用户名 })
.AsQuery();
Console.WriteLine(localDy.Done(query5).AsJson());
- 嵌套In子查询，扩展函数的嵌套调用
//IN 查询
var query4 = new DyQuery<tb_user>()
.Where(t1 => t1.用户名.Dy_Substring(1, 6).Dy_Right(1).Dy_In(new List<string> { "1", "2", "3" }))
.Where(t1 => t1.账号.Dy_In(new DyQuery<tb_order>(t2 => t2).Select(t2 => t2.账号)))
.Select(t1 => t1.账号).AsQuery();
Console.WriteLine(localDy.Done(query4).AsJson());
- 组合的Where条件
var query8 = new DyQuery<tb_user>()
.Where(t1 =>
(t1.用户名.Dy_EndsWith("1") || t1.账号.Dy_Right(1) == "2")
&&
(t1.用户名.Dy_Contains("3") || t1.账号.Dy_Contains("3"))
).Select(t1 => t1.账号).AsQuery();
- 中间表DyXTable
//根据中间表更新>>>>>>更新订单总金额
//定义中间表
var xTable1 = new DyQuery<tb_order_detail>(t2 => t2)
.Group(t2 => t2.订单ID)
.Select(t2 => new { t2.订单ID, 总金额 = t2.支付价.Dy_Sum(), })
.AsXTable();
//update from 方式更新 需要JOIN表
var query1 = new DyQuery<tb_order>().Update()
.Set<DyXTable>((t1, xt1) => t1.总金额 == xt1.Dy_X_Column<decimal>("总金额")) //总金额，中间表的字段
.Join<DyXTable>( JoinWay.InnerJoin, (t1, xt1) => t1.订单ID == xt1.Dy_X_Column<tb_order, Guid>(m => m.订单ID))
.MapXTable<DyXTable>(xt1 => xt1, xTable1) //**映射别名与中间表**
.AsQuery();
Console.WriteLine(new Dy().Done(query1).AsJson());
- 创建数据库 db-demo,执行演示程序中的建表脚本db-demo.sql、其中db-demo-remote.sql用于模拟本地到远程库的数据同步
- 打开演示项目，这里使用控制台程序，其中依赖组件【kQL.orm.dll】，app.config配置文件，配置连接字符串
<appSettings>
<add key="kQL.orm.connstr" value="server=local;database=db_demo;uid=sa;pwd=sa;"/>
</appSettings>
- 找到模型生成工具中kQL.orm.cmdTool.exe.config文件，配置如下节点
<appSettings>
<add key="kQL.orm.connstr" value="server=local;database=db_demo;uid=sa;pwd=sa;"/>
<add key="Namespace" value="k.dbtool.test.demo.models"/>
<add key="ModelsOutputs" value="D:\demo\models"/>
</appSettings>
kQL.orm.connstr：连接字符串（连到刚才那个db-demo库）
Namespace：您项目中实体层的命名空间名称
ModelsOutputs：实体文件输出目录
- 打开kQL.orm.cmdTool.exe，运行modelmake命令，实体层就生成了（切换到demo项目，显示所有文件，将生成的实体类型文件引用进来即可）
- 在demo项目Program.cs > Main函数中，导入命名空间 kQL.orm.expr、kQL.orm 使用kQL进行数据访问，分为两个步骤： 定义查询，即 var dyQuery = new kQL.orm.expr.DyQuery().AsQuery(); 执行查询，即 var result = new kQL.orm.Dy().Done(dyQuery);
- 增加演示
//单条插入、添加一个用户
var user1 = new tb_user
{
账号 = string.Format("U{0:D4}", 1),
密码 = "12345678",
用户名 = string.Format("Tester{0:D3}", 1),
性别 = true,
年龄 = new Random().Next(20, 60),
会员等级 = (byte)(new Random().Next(1, 255)),
积分 = new Random().Next(1000, 10000),
消费能力 = Math.Abs((short)new Random().Next(1, 100)),
头像 = 获取头像(1),
注册日期 = DateTime.Now
};
var query1 = new DyQuery<tb_user>().Insert(user1).AsQuery();
var result = new Dy().Done(query1);
Console.WriteLine(result.AsJson());
- 查询演示
//根据账号查找用户
var query1 = new DyQuery<tb_user>().Where(t1 => t1.账号 == "U0001").AsQuery();
var result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
- 修改演示
/*方法一：通过实体修改*/
//根据账号查找用户
var query1 = new DyQuery<tb_user>().Where(t1 => t1.账号 == "U0001").AsQuery();
var result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
var user = result1.AsT<tb_user>();
//修改用户密码
user.密码 = "00000000";
query1 = new DyQuery<tb_user>().Update(user).AsQuery();
result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
/*方法二：通过条件修改*/
query1 = new DyQuery<tb_user>().Update(t1=>t1.密码 == "00000000").Where(t1 => t1.账号 == "U0001").AsQuery();
result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
- 删除演示
/*方法一：通过实体删除*/
//根据账号查找用户
var query1 = new DyQuery<tb_user>().Where(t1 => t1.账号 == "U0001").AsQuery();
var result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
var user = result1.AsT<tb_user>();
query1 = new DyQuery<tb_user>().Delete(user).AsQuery();
result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
/*方法二：通过条件删除*/
query1 = new DyQuery<tb_user>().Delete().Where(t1 => t1.账号 == "U0001").AsQuery();
result1 = new Dy().Done(query1);
Console.WriteLine(result1.AsJson());
通过命令行工具，可以生成实体模型层代码。几乎支持数据库全部数据类型。
public class tb_product
{
[Description]
public Guid 产品ID { get; set; }
public String 产品名称 { get; set; }
public String 分类编号 { get; set; }
public Single 进价 { get; set; }
public Decimal 运费 { get; set; }
public Decimal 税率 { get; set; }
public Decimal 零售价 { get; set; }
public Double 会员折扣 { get; set; }
public String 产品描述_中文 { get; set; }
public String 产品描述_英文 { get; set; }
[Category("XML")]
public String RSS { get; set; }
public Byte[] 附件1 { get; set; }
public Byte[] 附件2 { get; set; }
[Category("TIMESTAMP")]
public String 版本 { get; set; }
}
1. [Description]标记为主键，如果表有联合主键，则实体类型中将会有多个属性被[Description]特性标签标记。
2. [Category]标记描述二级类别，目前仅三种 XML、TIMESTAMP、IDENTITY
3. 数据库XML类型，c#中映射为string类型，当增删改时需要c#类型去映射到数据库类型。
4. 数据库TIMESTAMP类型，严格来讲应该映射为byte[8],但为了更方便的进行值比较，框架内做了处理，将返回16进制字符串。
5. IDENTITY自增列
DyQuery<T>类型：定义各种查询的入口，一般形式：var query = new DyQuery<T>() ; //T为具体的类型
public class DyQuery<TLeft> : AbsDyQuery , ICriteria<TLeft>
public interface ICriteria<TLeft>
: IDyQuery
, IJoin<TLeft>,IOn<TLeft>
, IWhere<TLeft>, IGroup<TLeft>, IHaving<TLeft>, IOrder<TLeft>, ISelect<TLeft>
, IInsertInst<TLeft>
, IDelete<TLeft> , IDeleteInst<TLeft>
, IUpdate<TLeft>, IUpdateInst<TLeft>,ISet<TLeft>
, ITruncate<TLeft>
, IProc<TLeft>
, IMapXTable<TLeft>
Dy类型：执行DyQuery的操作类，真正执行数据库访问操作，一般形式：var result = new Dy().Done(query); //返回DyResult类型
**不管DyQuery怎样定义，都不会去执行数据库的操作。只有Dy调用相关方法的时候才会真正去执行数据库操作！！**
public class Dy
{
public DyResult Done(IDyQuery dyQuery);
public void BulkInsert<T>(List<T> models, int perCommitRowCount = 102400, bool tableLock = true); //批量插入
/// <summary>
/// 返回 Item1:执行毫秒数,Item2:执行的消息
/// </summary>
public Tuple<long,string> CopyToRemote<T>(IDyQuery sourceDyQuery, Dy destinationDy) where T : class;
}
DyResult类型：查询的结果，执行dy操作后，将结果集DataSet保存至DyResult内部，DyResult提供了很多将结果集转成特定结构的函数，一般形式：
1. result.AsJson();//将结果转为json字符串，byte[]将进行Base64编码，除了byte[8]将返回16进制字符串（TIMESTAMP）
2. result.TList<T>();//将结果转为对象列表
3. 更多.....
public interface IDyResult
{
object AsRC(int tableIndex = 0);
string AsJson();
T AsT<T>(int tableIndex = 0) where T : new();
List<T> AsTList<T>(int tableIndex = 0) where T : new();
PagedList<T> AsTPageList<T>(int tableIndex = 0) where T : new();
//TreeNode<T> AsTree<T>(Expression<Func<T, T, bool>> mapping = null, int tableIndex = 0) where T : new();
TreeNode<T> AsTree<T>(Expression<Func<T, T, bool>> mapping = null, string dictClassName = "", object dictClassVal = null, int tableIndex = 0) where T : new();
Dictionary<string, ArrayList> AsKeyValues(int tableIndex = 0);
dynamic AsDyT(int tableIndex = 0);
List<dynamic> AsDyTList(int tableIndex = 0);
Tuple<T0, T1> AsT_OneOne<T0, T1>(int tableIndex = 0) where T0 : new() where T1 : new();
Tuple<T0, T1, T2> AsT_OneOne<T0, T1, T2>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new();
Tuple<T0, T1, T2, T3> AsT_OneOne<T0, T1, T2, T3>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new();
Tuple<T0, T1, T2, T3, T4> AsT_OneOne<T0, T1, T2, T3, T4>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new();
Tuple<T0, T1, T2, T3, T4, T5> AsT_OneOne<T0, T1, T2, T3, T4, T5>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new();
Tuple<T0, T1, T2, T3, T4, T5, T6> AsT_OneOne<T0, T1, T2, T3, T4, T5, T6>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new();
Tuple<T0, T1, T2, T3, T4, T5, T6, T7> AsT_OneOne<T0, T1, T2, T3, T4, T5, T6, T7>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new() where T7 : new();
List<Tuple<T0, T1>> AsTList_OneOne<T0, T1>(int tableIndex = 0) where T0 : new() where T1 : new();
List<Tuple<T0, T1, T2>> AsTList_OneOne<T0, T1, T2>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new();
List<Tuple<T0, T1, T2, T3>> AsTList_OneOne<T0, T1, T2, T3>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new();
List<Tuple<T0, T1, T2, T3, T4>> AsTList_OneOne<T0, T1, T2, T3, T4>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new();
List<Tuple<T0, T1, T2, T3, T4, T5>> AsTList_OneOne<T0, T1, T2, T3, T4, T5>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new();
List<Tuple<T0, T1, T2, T3, T4, T5, T6>> AsTList_OneOne<T0, T1, T2, T3, T4, T5, T6>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new();
List<Tuple<T0, T1, T2, T3, T4, T5, T6, T7>> AsTList_OneOne<T0, T1, T2, T3, T4, T5, T6, T7>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new() where T7 : new();
Tuple<One, List<Many>> AsT_OneMany<One, Many>(Expression<Func<One, One>> oneGroupExpr = null, int tableIndex = 0) where One : new() where Many : new();
List<Tuple<One, List<Many>>> AsTList_OneMany<One, Many>(Expression<Func<One, One>> oneGroupExpr = null, int tableIndex = 0) where One : new() where Many : new();
}
**DyXTable** 即中间表，有时候对数据库进行操作的时候，我们需要一个零时的中间表。通过DyXTable可以实现更复杂的操作，如：表值函数的使用，更复杂的更新（[订单表].总金额 = sum([明细表].金额)），详见进阶篇
/*以下方法都是对已经查询后的结果集，做进一步处理*/
//RowCount 返回影响的行数，只对 增、删、改 有效，查询返回结果永远是0
List<int> idlist = new List<int>();
for (int i = 0; i < 100; i++)
{
idlist.Add(i + 50);
}
var multi_user_batch = idlist.Select(i =>
{
Thread.Sleep(50);
return new tb_user
{
账号 = string.Format("U{0:D4}", i),
密码 = "12345678",
用户名 = string.Format("Tester{0:D3}", i),
性别 = i % 2 == 0,
年龄 = new Random().Next(20, 60),
会员等级 = (byte)(new Random().Next(1, 255)),
积分 = new Random().Next(1000, 10000),
消费能力 = Math.Abs((short)new Random().Next(1, 100)),
头像 = 获取头像(i),
注册日期 = DateTime.Now,
};
}).ToList();
//var q0 = new DyQuery<tb_user>().Insert(multi_user_batch).AsQuery();
//var result0 = dy.Query(q0);
//Console.WriteLine("影响的行数：" + result0.RowCount);
//Records返回结果集
var q1 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var result = localDy.Done(q1);
Console.WriteLine("影响的行数：" + result.RowCount);//返回0
Console.WriteLine("结果集中表的数量：" + result.Records.Tables.Count);
//AsT -> 如果查询有多条记录，返回记录的第一条
var query1 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var user1 = localDy.Done(query1).AsDyT();
Console.WriteLine("账号:{0},用户名:{1}", user1.账号,user1.用户名);
//AsTList ->返回记录列表
var query2 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var user2list = localDy.Done(query2).AsDyTList();
foreach (var user2 in user2list)
{
Console.WriteLine("账号:{0},用户名:{1}", user2.账号, user2.用户名);
}
//AsRC ->返回首行首列
var query3 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var 首行首列= localDy.Done(query3).AsRC();
Console.WriteLine(首行首列);
//AsJson ->将Records结果集，直接转成标准json字符串格式 ajax请求的时候返回json格式很方便
var query4 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
Console.WriteLine(localDy.Done(query4).AsJson());
//AsTPageList
int pIndex = 1;
int pSize = 5;
var criteria = new DyQuery<tb_user>()
.Order(OrderWay.Asc, t1 => t1.账号)
.Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 });
var query5 = criteria.AsQueryPaged(pIndex, pSize);
var plist1 = localDy.Done(query5).AsTPageList<tb_user>();
Console.WriteLine("当前页:{0},每页大小:{1},总记录数:{2},总页数:{3},是否有下一页:{4},是否有上一页:{5}", plist1.PageIndex, plist1.PageSize, plist1.TotalCount, plist1.TotalPages, plist1.HasNextPage, plist1.HasPreviousPage);
pIndex = 3;
var query6 = criteria.AsQueryPaged(pIndex, pSize);
var plist2 = localDy.Done(query6).AsTPageList<tb_user>();
Console.WriteLine("当前页:{0},每页大小:{1},总记录数:{2},总页数:{3},是否有下一页:{4},是否有上一页:{5}", plist2.PageIndex, plist2.PageSize, plist2.TotalCount, plist2.TotalPages, plist2.HasNextPage, plist2.HasPreviousPage);
//AsKeyValues 转置输出，画图、统计时比较有用
/*
colName1 | colName2 | colName3
------------------------------
1 | 2 | 3
4 | 5 | 6
7 | 8 | 9
==>
colName1:[1,4,7]
colName2:[2,5,8]
colName3:[3,6,9]
*/
var query7 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("0")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var keyValues = localDy.Done(query7).AsKeyValues();
foreach (var key in keyValues.Keys) {
Console.WriteLine("Key:{0},Values:{1}", key, string.Join(",", keyValues[key].ToArray()));
}
//AsDyT 动态对象 与 AsT类似 返回第一行数据
var query8 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var dynamicObj = localDy.Done(query8).AsDyT();
Console.WriteLine("账号:{0},用户名:{1},消费能力:{2}", dynamicObj.账号, dynamicObj.用户名, dynamicObj.消费能力);
//AsDyTList 与 AsTList类似 返回列表
var query9 = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Contains("00")).Select(t1 => new { t1.账号, t1.用户名, t1.消费能力 }).AsQuery();
var dynamicObjList = localDy.Done(query9).AsDyTList();
foreach (var dyObj in dynamicObjList) {
Console.WriteLine("账号:{0},用户名:{1},消费能力:{2}", dyObj.账号, dyObj.用户名, dyObj.消费能力);
}
//AsTree 树结构 分类处理、如省市区、商品的分类
var query10 = new DyQuery<tb_categories>().AsQuery();
var treeNodeRoot = localDy.Done(query10).AsTree<tb_categories>((t1, t2) => t1.父ID == t2.子ID);
Console.WriteLine(treeNodeRoot.ToString());
//树搜索 引入 kQL.orm.results 命名空间
//ConvertTTreeToTList 树节点转成List列表
//var treeToList = tree.ConvertTTreeToTList();//不输出跟节点
var treeToList = treeNodeRoot.ConvertTTreeToTList(true); //输出跟节点
Console.WriteLine("treeToList数量:{0}",treeToList.Count);
//FindTTreeNode
tb_categories category = new tb_categories {
分类名称 = "台式机"
};
var findTreeNode = treeNodeRoot.FindTTreeNode(category, (treeNode, searchCategoryInstance) => treeNode.Current.分类名称 == searchCategoryInstance.分类名称);//其中searchCategoryInstance 就是 category
Console.WriteLine(findTreeNode.ToString());
//DFS_FlagTree 深度优先将路径上的[TreeNode->Flag]标记为1，应用场景 树型复选框，选中某节点，节点上级和下级节点都要选中
treeNodeRoot.DFS_FlagTree(category, (treeNode, searchCategoryInstance) => treeNode.Current.分类名称 == searchCategoryInstance.分类名称);
Console.WriteLine("---------DFS_FlagTree 节点标记------");
Console.WriteLine(treeNodeRoot.ToString());
//BFS_CutFlagTree 广度优先路径上的[TreeNode->Flag]进行剪枝，应用场景 树型复选框，选中某节点，节点上级和下级节点都要选中，将所有选中的节点返回
treeNodeRoot.BFS_CutFlagTree();
Console.WriteLine("---------BFS_CutFlagTree 节点剪枝------");
Console.WriteLine(treeNodeRoot.ToString());
/****** DFS_FlagTree 与 BFS_CutFlagTree 一般情况都是要配合使用，先对节点标记，再对节点剪枝 ******/
//一对一、一对多 AsT_OneOne、AsTList_OneOne、AsT_OneMany、AsTList_OneMany
var query11 = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, (t2, t3) => t2.订单ID == t3.订单ID)
.Order<DateTime>(OrderWay.Asc, t2 => t2.订单时间)
.Select<tb_order>(t2 => new { t2.订单ID, t2.账号 ,t2.订单名称})
.Select<tb_order_detail>(t3 => new { t3.订单ID, t3.订单明细ID, t3.产品名称, t3.支付价 })
.AsQuery();
//AsT_OneOne 单条
var r0 = localDy.Done(query11).AsT_OneOne<tb_order, tb_order_detail>();
Console.WriteLine("AsT_OneOne");
Console.WriteLine("{0},{1}", r0.Item1.订单ID, r0.Item1.账号);
Console.WriteLine("{0},{1},{2}", r0.Item2.订单ID, r0.Item2.产品名称, r0.Item2.支付价);
//AsTList_OneOne 多条
var r1 = localDy.Done(query11).AsTList_OneOne<tb_order, tb_order_detail>();
Console.WriteLine("AsTList_OneOne");
foreach (var r in r1) {
Console.WriteLine("{0},{1}", r.Item1.订单ID, r.Item1.账号);
Console.WriteLine("{0},{1},{2},{3}", r.Item2.订单ID, r.Item2.订单明细ID, r.Item2.产品名称, r.Item2.支付价);
}
//AsT_OneMany 返回单条,一般情况下无什么意义
var r2 = localDy.Done(query11).AsT_OneMany<tb_order, tb_order_detail>();
Console.WriteLine("{0},{1}", r2.Item1.订单ID, r2.Item1.账号);
foreach (var r2_0 in r2.Item2) {
Console.WriteLine("--{0},{1},{2}", r0.Item2.订单ID, r0.Item2.产品名称, r0.Item2.支付价);
}
//AsTList_OneMany 返回多条
// 指定分组 one => new tb_order { 账号 = one.账号 }，即对结果集Table的，主表字段进行过滤
var r3 = localDy.Done(query11).AsTList_OneMany<tb_order, tb_order_detail>(one => new tb_order { 账号 = one.账号 });
/** new 主表类型，这里 new tb_order , 只要属性字段，“one.账号”无实际意义 ，也可以写成以下形式，与上一条等价 **/
/****即，只认对象类型中的属性名称 ****/
var r4 = localDy.Done(query11).AsTList_OneMany<tb_order, tb_order_detail>(one => new tb_order { 账号 = "" });
foreach (var oneMany in r4) {
Console.WriteLine("账号:{0},订单数量:{1}", oneMany.Item1.账号, oneMany.Item2.Count);
}
//AsTList_OneMany 根据多个字段分组
var r5 = localDy.Done(query11).AsTList_OneMany<tb_order, tb_order_detail>(one => new tb_order { 账号 = one.账号, 订单ID = one.订单ID });
//以下等价
var r6 = localDy.Done(query11).AsTList_OneMany<tb_order, tb_order_detail>(one => new tb_order { 账号 = "", 订单ID = Guid.Empty });
foreach (var oneMany in r6)
{
Console.WriteLine("订单名称:{0},账号:{1},订单数量:{2}", oneMany.Item1.订单名称, oneMany.Item1.账号, oneMany.Item2.Count);
}
综上，不管怎样，当你需要访问数据库时就3个步骤
1. var query = new DyQuery<T>().AsQuery();//定义DyQuery
2. var result = new Dy().Done(query);//执行数据库访问
3. var jsonResult = result.AsJson();//将结果集，转成json字符串
直接上代码说明：
//DyQuery<tb_user>未指定别名，默认为t1,即指定tb_user表的别名为t1
var query = new DyQuery<tb_user>()
.Where(t1 => t1.用户名=="Test" )
.Select(t1 => t1.账号)
.AsQuery();
//DyQuery<tb_user>显式指定别名t1,即指定tb_user表的别名为t1
var query = new DyQuery<tb_user>(t1=>t1)
.Where(t1 => t1.用户名=="Test" )
.Select(t1 => t1.账号)
.AsQuery();
//DyQuery<tb_user>显式指定别名t2,即指定tb_user表的别名为t2
var query = new DyQuery<tb_user>(t2=>t2)
.Where(t2 => t2.用户名=="Test" )
.Select(t2 => t2.账号)
.AsQuery();
//DyQuery<tb_user>显式指定别名t2,Join<tb_user>表的别名为t3
//自连接的操作，其中第一个tb_user别名为t2，第二个tb_user别名为t3
var query = new DyQuery<tb_user>(t2=>t2)
.Join<tb_user>(JoinWay.InnerJoin,
(t2, t3) => t2.用户名 == t3.用户名
)
.Where(t2 => t2.用户名=="Test" )
.Select(t2 => t2.账号)
.AsQuery();
//更复杂点的例子，DyQuery<tb_user>未指定tb_user别名，默认为t1;Exists子查询中，DyQuery<tb_order>显式指定别名为t2，Join<tb_order_detail>别名为t3; 通过Where<tb_order, tb_user>((t2, t1) => t2.账号 == t1.账号) 显式指定表别名，实现跨表条件组合查询。
var query5 = new DyQuery<tb_user>()
.Exists(WhereWay.And
, new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3).On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
//与下面等价
//.Join<tb_order_detail>(JoinWay.InnerJoin, (t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Having<tb_order_detail>(WhereWay.And, t3 => t3.订单ID.Dy_Count() > 5)
//.Select<tb_order, tb_order_detail>((t2, t3) => new { t2.订单ID, t2.账号, 明细数量 = t3.订单ID.Dy_Count() })
.Where<tb_order, tb_user>((t2, t1) => t2.账号 == t1.账号)
.Select(t2 => 1).AsQuery()
)
.Select(t1 => new { t1.账号, t1.用户名 })
.AsQuery();
当指定了表别名后，之后的Join,Where,Group,Select等方法中，表别名都要保持一致
/// <summary>
/// 标准DyQuery
/// </summary>
IDyQuery AsQuery();
/// <summary>
/// 分页DyQuery pageIndex:从1开始
/// </summary>
IDyQuery AsQueryPaged(int pageIndex, int pageSize);
/// <summary>
/// TopN DyQuery
/// </summary>
IDyQuery AsQueryTopN(int N);
/// <summary>
/// 中间表方式
/// </summary>
DyXTable AsXTable();
var query = new DyQuery()....AsQuery();//通用标准接口，【增、删、改、查】 var query = new DyQuery()....AsQueryPaged();//分页接口，【查】 var query = new DyQuery()....AsQueryTopN();//前N条数据接口，【查】 var xTable = new DyQuery()....AsXTable();//定义中间表
kQL.orm使用存储过程很方便，因为通过kQL.orm.cmdTool工具，将存储过程生成了实体类。
//数据库中存储过程名：sp_add_order 将生成以下实体类
public class sp_add_order
{
public Guid 订单号 { get; set; }
public String 订单名称 { get; set; }
public String 账号 { get; set; }
public Decimal 金额 { get; set; }
}
//调用无参数存储过程
var query1 = new DyQuery<sp_get_order_all>().Proc(new sp_get_order_all { });
var result1 = dy.Query(query1);
Console.WriteLine(result1.AsJson());
//调用有参数存储过程
var query2 = new DyQuery<sp_add_order>().Proc(new sp_add_order
{
订单号 = Guid.NewGuid(),//存储过程的参数
订单名称 = "O" + DateTime.Now.ToString("yyyyMMddHHmm"),//存储过程的参数
账号 = "U0005", //存储过程的参数
金额 = 1200.00m //存储过程的参数
});
var result2 = dy.Query(query2);
Console.WriteLine(result2.AsJson());
必须遵守的约定，自定义的存储过程不能使用 return value 作为返回值，因为这样框架无法接收到返回结果。如果存储过程有值返回，请在存储过程最后一句中使用 select value 的形式，在通过获取result.AsRC()方法获取首行首列，或result.AsT()，或result.AsTList()...等形式
public interface IInsertInst<TLeft> : IDyQuery
{
IInsertInst<TLeft> Insert(TLeft inst);
IInsertInst<TLeft> Insert(List<TLeft> insts);
IInsertInst<TLeft> Insert<TRight>(TRight inst);
IInsertInst<TLeft> Insert<TRight>(List<TRight> insts);
}
Insert支持实体对象或实体对象列表的混合插入，混合插入即可以使用不同类型的实体对象进行插入 Insert插入永远在同一个事务中，框架内自动加了事务。其他的Orm框架可能要要显示定义Transaction。 如大批量插入可以通过，Dy类的BlukInsert方法
//单个实体对象插入
var user1 = new tb_user
{
账号 = string.Format("U{0:D4}", 1),
密码 = "12345678",
用户名 = string.Format("Tester{0:D3}", 1),
性别 = true,
年龄 = new Random().Next(20, 60),
会员等级 = (byte)(new Random().Next(1, 255)),
积分 = new Random().Next(1000, 10000),
消费能力 = Math.Abs((short)new Random().Next(1, 100)),
头像 = 获取头像(1),
注册日期 = DateTime.Now
};
var query1 = new DyQuery<tb_user>().Insert(user1).AsQuery();
var result = new Dy().Done(query1);
//result.RowCount;//影响的行数
//混合不同类型实体对象插入
var multi_category = new List<tb_categories> {
new tb_categories {
子ID = "100",
父ID = "",
分类名称="数码",
顺序=1
}
, new tb_categories {
子ID = "100100",
父ID = "100",
分类名称="电脑",
顺序=1
}
, new tb_categories {
子ID = "100101",
父ID = "100",
分类名称="手机",
顺序=1
}
, new tb_categories {
子ID = "100100100",
父ID = "100100",
分类名称="笔记本",
顺序=1
}
, new tb_categories {
子ID = "100100101",
父ID = "100100",
分类名称="台式机",
顺序=1
}
, new tb_categories {
子ID = "100101100",
父ID = "100101",
分类名称="苹果",
顺序=1
}
, new tb_categories {
子ID = "100101101",
父ID = "100101",
分类名称="小米",
顺序=1
}
};
var multi_products = new List<int> { 11, 12, 13, 14, 15, 16, 17, 18, 19, 20 }.Select(i =>
{
Thread.Sleep(50);
return new tb_product
{
产品ID = Guid.NewGuid(),
产品名称 = string.Format("Product{0:D6}", i),
分类编号 = multi_category[i % 7].子ID,
进价 = (float)new Random().NextDouble(),
运费 = (decimal)new Random().NextDouble(),
税率 = (decimal)new Random().NextDouble(),
零售价 = (decimal)new Random().NextDouble() * 100,
会员折扣 = new Random().NextDouble(),
产品描述_中文 = "中文",
产品描述_英文 = "English",
RSS = "<root><product></product></root>",
//附件1 = "", //参考[头像]
//附件2 = "",
//版本 timestamp //无须指定
};
}).ToList();
var dyQuery = new DyQuery<tb_user>()
.Insert(user1).Insert(multi_user).Insert(multi_category)
.Insert(multi_products).AsQuery();
var result = dy.Query(dyQuery);
if(result.RowCount == 1 /*user1*/ + multi_user.Count + multi_category.Count + multi_products.Count){
//插入成功
}else{
//插入失败
}
//大批量数据插入
var multi_user_batch = new List<int> { 11, 12, 13, 14, 15, 16, 17, 18, 19, 20 }.Select(i =>
{
Thread.Sleep(50);
return new tb_user
{
账号 = string.Format("U{0:D4}", i),
密码 = "12345678",
用户名 = string.Format("Tester{0:D3}", i),
性别 = i % 2 == 0,
年龄 = new Random().Next(20, 60),
会员等级 = (byte)(new Random().Next(1, 255)),
积分 = new Random().Next(1000, 10000),
消费能力 = Math.Abs((short)new Random().Next(1, 100)),
头像 = 获取头像(i),
注册日期 = DateTime.Now,
};
}).ToList();
dy.BulkInsert(multi_user_batch);
public interface IDelete<TLeft>
{
ICriteria<TLeft> Delete();
}
public interface IDeleteInst<TLeft> : IDyQuery
{
IDeleteInst<TLeft> Delete(TLeft inst);
IDeleteInst<TLeft> Delete(List<TLeft> insts);
IDeleteInst<TLeft> Delete<TRight>(TRight inst);
IDeleteInst<TLeft> Delete<TRight>(List<TRight> insts);
}
根据实体对象删除，实体必须定义主键，框架会检测实体T类型的[Description]主键标记，根据主键进行删除 根据条件删除，无须实体定义主键
//根据主键删除
var query = new DyQuery<tb_user>().Delete(new tb_user { 账号 = "U0001" }).AsQuery();
var rowCount = dy.Query(query).RowCount;
if (rowCount == 1)
{
//成功
}
else {
//失败
}
//多实体删除 根据主键
List<tb_user> userList = new List<tb_user>()
{
new tb_user { 账号 = "U0002" },
new tb_user { 账号 = "U0003" }
};
var query = new DyQuery<tb_user>().Delete(new tb_user { 账号 = "U0001" }).Delete(userList).AsQuery();
var rowCount = dy.Query(query).RowCount;
if (rowCount == 1 /*new tb_user { 账号 = "U0001" }*/+ userList.Count)
{
//成功
}
else {
//失败
}
//根据条件删除
var query = new DyQuery<tb_user>().Delete().Where(t1 => t1.用户名.Dy_EndsWith("3") && t1.年龄 > 20).AsQuery();
var rowCount = dy.Query(query).RowCount;
public interface IUpdate<TLeft>
{
ISet<TLeft> Update();
ICriteria<TLeft> Update(Expression<Func<TLeft, bool>> setExpr);
}
public interface ISet<TLeft>
{
ICriteria<TLeft> Set(Expression<Func<TLeft, bool>> setExpr);
ICriteria<TLeft> Set<TRight>(Expression<Func<TLeft, TRight, bool>> setExpr);
ICriteria<TLeft> Set<TRight1, TRight2>(Expression<Func<TLeft, TRight1, TRight2, bool>> setExpr);
ICriteria<TLeft> Set<TRight1, TRight2, TRight3>(Expression<Func<TLeft, TRight1, TRight2, TRight3, bool>> setExpr);
ICriteria<TLeft> Set<TRight1, TRight2, TRight3, TRight4>(Expression<Func<TLeft, TRight1, TRight2, TRight3, TRight4, bool>> setExpr);
ICriteria<TLeft> Set<TRight1, TRight2, TRight3, TRight4, TRight5>(Expression<Func<TLeft, TRight1, TRight2, TRight3, TRight4, TRight5, bool>> setExpr);
}
public interface IUpdateInst<TLeft> : IDyQuery
{
IUpdateInst<TLeft> Update(TLeft inst);
IUpdateInst<TLeft> Update(List<TLeft> insts);
IUpdateInst<TLeft> Update<TRight>(TRight inst);
IUpdateInst<TLeft> Update<TRight>(List<TRight> insts);
}
根据实体对象更新，实体必须定义主键，框架会检测实体T类型的[Description]主键标记，根据主键进行更新 根据条件更新，无须实体定义主键 更新字段时使用等号赋值；更新多个字段，使用 | 分割；
//实体更新 通过主键
var query = new DyQuery<tb_user>().AsQuery();
var userList = dy.Query(query).AsTList<tb_user>();
foreach (var user in userList)
{
user.年龄 = user.年龄 + 2;
user.用户名 = user.用户名 + "N";
}
var query0 = new DyQuery<tb_user>().Update(userList).AsQuery();
var rowCount = dy.Query(query0).RowCount;
//根据条件更新
var query = new DyQuery<tb_user>()
.Update(t1 =>
t1.账号 == "xxx" | t1.年龄 == 0
).Where(t1 =>
t1.账号.Dy_Contains("00")
).AsQuery();
var rowCount = dy.Query(query).RowCount;
//update from 更新 [产品名称]变更需要将订单明细中[产品名称]同时变更
var query = new DyQuery<tb_order_detail>().Update()
.Set<tb_product>(
(t1, t2) =>
t1.产品名称 == t2.产品名称.Dy_Substring(1, 4)
).Join<tb_product>(JoinWay.InnerJoin,
(t1, t2) => t1.产品ID == t2.产品ID
).Where(t1 => t1.支付价 > 30).AsQuery();
var rowCount = dy.Query(query).RowCount;
public interface ISelect<TLeft>
{
ICriteria<TLeft> Select();
ICriteria<TLeft> Select(Expression<Func<TLeft, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight>(Expression<Func<TRight, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2>(Expression<Func<TRight1, TRight2, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2, TRight3>(Expression<Func<TRight1, TRight2, TRight3, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2, TRight3, TRight4>(Expression<Func<TRight1, TRight2, TRight3, TRight4, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2, TRight3, TRight4, TRight5>(Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6>(Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7>(Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7, dynamic>> selectExpr);
ICriteria<TLeft> Select<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7, TRight8>(Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7, TRight8, dynamic>> selectExpr);
}
> Select<tb_user>(t1=>t1) //查询tb_user表的所有字段 => select t1.*
> Select<tb_user>(t1=>new tb_user{ 用户名 = t1.用户名,账号 = t1.账号}) //查询tb_user表的指定字段 => select t1.用户名,t1.账号
> Select<tb_user>(t1=>1) //查询=> select 1
> Select<tb_user>(t1=> new { 总计 = DyExtFn.Dy_CountN(1) ) //查询=> select count(1) as 总计
> Select<tb_user>(t1=> new { 总计 = t1.账号.Dy_CountN(1) ) //查询=> select count(t1.账号) as 总计
> Select<tb_order, tb_order_detail>((t1, t2) => new { t1.订单ID, t1.账号, 明细数量 = t2.订单ID.Dy_Count() }) //=> select t1.订单ID, t1.账号,count(t2.订单ID) as 明细数量
public interface IOrder<TLeft>
{
ICriteria<TLeft> Order<TField>(OrderWay orderWay, Expression<Func<TLeft, TField>> orderExpr);
ICriteria<TLeft> Order<TRight, TRightField>(OrderWay orderWay, Expression<Func<TRight, TRightField>> orderExpr);
}
//指定排序
var query = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(
JoinWay.InnerJoin,
(t2, t3) => t2.订单ID == t3.订单ID
)
.Order<DateTime>(OrderWay.Desc, t2 => t2.订单时间)
.Order<Decimal>(OrderWay.Asc, t3 => t3.支付价)
public interface IJoin<TLeft>
{
IOn<TLeft> Join<TRight>(JoinWay joinWay, Expression<Func<TRight, TRight>> aliasExpr);
ICriteria<TLeft> Join<TRight>(JoinWay joinWay, Expression<Func<TLeft, TRight, bool>> onExpr);
ICriteria<TLeft> Join<TRight1, TRight2>(JoinWay joinWay, Expression<Func<TRight1, TRight2, bool>> onExpr);
}
public interface IOn<TLeft>
{
ICriteria<TLeft> On<TRight1, TRight2>(Expression<Func<TRight1, TRight2, bool>> onExpr);
}
var query = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3)
.On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
public interface IWhere<TLeft>
{
#region 基本条件
ICriteria<TLeft> Where(Expression<Func<TLeft, bool>> whereExpr);
ICriteria<TLeft> Where<TRight>(Expression<Func<TRight, bool>> whereExpr);
ICriteria<TLeft> Where<TRight1, TRight2>(Expression<Func<TRight1, TRight2, bool>> whereExpr);
//==============================================================>>>>>>>>>>>>>>>>>>>>>>>>>>>
ICriteria<TLeft> Where(WhereWay whereWay, Expression<Func<TLeft, bool>> whereExpr);
ICriteria<TLeft> Where<TRight>(WhereWay whereWay, Expression<Func<TRight, bool>> whereExpr);
ICriteria<TLeft> Where<TRight1, TRight2>(WhereWay whereWay, Expression<Func<TRight1, TRight2, bool>> whereExpr);
#endregion
#region Exists 子查询
ICriteria<TLeft> Exists(WhereWay whereWay, IDyQuery existsDyQuery);
ICriteria<TLeft> ExistsNot(WhereWay whereWay, IDyQuery existsDyQuery);
#endregion
}
//条件过滤
private static string GetUserId() //上下文计算函数
{
return "U0005";
}
var query =
//new DyQuery<tb_order_detail>()
//or
new DyQuery<tb_order_detail>(t1 => t1) //指定表别名
.Join<tb_order>(JoinWay.InnerJoin, (t1, t2) => t1.订单ID == t2.订单ID)
.Join<tb_product>(JoinWay.InnerJoin, (t1, t3) => t1.产品ID == t3.产品ID)
.Join<tb_order, tb_user>(JoinWay.InnerJoin, (t2, t4) => t2.账号 == t4.账号)
.Where<tb_user>(t4 => t4.账号 == GetUserId()) //=> GetUserId() /*上下文计算函数*/
.Where<tb_order>(t2 =>
t2.订单时间.Dy_DateDiff(DateTime.Now, "dd") >= 0
&&
t2.订单时间.Dy_DateAdd(-5, "mm").Dy_DateDiff(DateTime.Now, "dd") > 0
)
.Select<tb_order_detail, tb_order, tb_product, tb_user>
(
(t1, t2, t3, t4) =>
new
{
t4.账号,
产品简称 = t3.产品名称.Dy_Substring(1, 2),
t2.订单名称,
支付价 = t1.支付价.Dy_M_Floor(),
}
)
.AsQuery();
Where推导类型如：t1，t2...类型字段，如需通过直接数据库进行字段处理，必须使用扩展函数【Dy_】开头的扩展函数。 Where中支持上下文环境的计算函数、变量、属性等 如上例：GetUserId()
public interface IGroup<TLeft>
{
ICriteria<TLeft> Group<TField>(Expression<Func<TLeft, TField>> groupExpr);
ICriteria<TLeft> Group<TModel, TField>(Expression<Func<TModel, TField>> groupExpr);
}
public interface IHaving<TLeft>
{
ICriteria<TLeft> Having(WhereWay whereWay, Expression<Func<TLeft, bool>> havingExpr);
ICriteria<TLeft> Having<TModel>(WhereWay whereWay, Expression<Func<TModel, bool>> havingExpr);
}
//group,having
var query = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3) //定义tb_order_detail表别名 t3
.On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
//与下面等价
//.Join<tb_order_detail>(JoinWay.InnerJoin, (t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Having<tb_order_detail>(WhereWay.And, t3 => t3.订单ID.Dy_Count() > 5)
.Select<tb_order, tb_order_detail>(
(t2, t3) => new
{
t2.订单ID,
t2.账号,
明细数量 = t3.订单ID.Dy_Count(),
总金额Max = t3.支付价.Dy_Max(),
总金额Min = t3.支付价.Dy_Min(),
总金额Sum = t3.支付价.Dy_Sum(),
总金额Avg = t3.支付价.Dy_Avg(),
R金额 = ((t3.支付价.Dy_Max() + t3.支付价.Dy_Min() - t3.支付价.Dy_Sum() * t3.支付价.Dy_Avg()) / t3.支付价.Dy_Min()).Dy_Convert<decimal, decimal>("decimal(18,2)")
}
)
.AsQuery();
- 通过别名 与 DyXTable 实例映射。
- 通过别名 与 DyXTable 表达式 映射，通常用于表值函数 。其中TRight类型表示表值函数中需要用到的对应表的计算字段。
public interface IMapXTable<TLeft>
{
ICriteria<TLeft> MapXTable<AliasType>(Expression<Func<AliasType, AliasType>> aliasExpr, DyXTable xTable);
ICriteria<TLeft> MapXTable<AliasType, TRight>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2, TRight3>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, TRight3, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2, TRight3, TRight4>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, TRight3, TRight4, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2, TRight3, TRight4, TRight5>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2, TRight3, TRight4, TRight5, TRight6>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7, DyXTable>> Dy_UDF_xTableExpr);
ICriteria<TLeft> MapXTable<AliasType, TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7, TRight8>(Expression<Func<AliasType, AliasType>> aliasExpr,
Expression<Func<TRight1, TRight2, TRight3, TRight4, TRight5, TRight6, TRight7, TRight8, DyXTable>> Dy_UDF_xTableExpr);
}
public interface IDyResult
{
object AsRC(int tableIndex = 0);//首行首列
string AsJson();//转json字符串
T AsT<T>(int tableIndex = 0) where T : new();//转对象，通常与 AsQueryTopN(1)一起使用
List<T> AsTList<T>(int tableIndex = 0) where T : new();//转对象列表
PagedList<T> AsTPageList<T>(int tableIndex = 0) where T : new();//转分页对象列表，通常与AsQueryPaged()一起使用
TreeNode<T> AsTree<T>(Expression<Func<T, T, bool>> mapping = null, string dictClassName = "", object dictClassVal = null, int tableIndex = 0) where T : new();//将结果转成树结构，分类数据处理的时候很方便
Dictionary<string, ArrayList> AsKeyValues(int tableIndex = 0);//将数据结果转置，画图和统计时比较有用
dynamic AsDyT(int tableIndex = 0);//转动态对象
List<dynamic> AsDyTList(int tableIndex = 0);//转动态对象列表
//以下是一对一关系的数据处理
Tuple<T0, T1> AsT_OneOne<T0, T1>(int tableIndex = 0) where T0 : new() where T1 : new();
Tuple<T0, T1, T2> AsT_OneOne<T0, T1, T2>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new();
Tuple<T0, T1, T2, T3> AsT_OneOne<T0, T1, T2, T3>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new();
Tuple<T0, T1, T2, T3, T4> AsT_OneOne<T0, T1, T2, T3, T4>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new();
Tuple<T0, T1, T2, T3, T4, T5> AsT_OneOne<T0, T1, T2, T3, T4, T5>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new();
Tuple<T0, T1, T2, T3, T4, T5, T6> AsT_OneOne<T0, T1, T2, T3, T4, T5, T6>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new();
Tuple<T0, T1, T2, T3, T4, T5, T6, T7> AsT_OneOne<T0, T1, T2, T3, T4, T5, T6, T7>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new() where T7 : new();
List<Tuple<T0, T1>> AsTList_OneOne<T0, T1>(int tableIndex = 0) where T0 : new() where T1 : new();
List<Tuple<T0, T1, T2>> AsTList_OneOne<T0, T1, T2>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new();
List<Tuple<T0, T1, T2, T3>> AsTList_OneOne<T0, T1, T2, T3>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new();
List<Tuple<T0, T1, T2, T3, T4>> AsTList_OneOne<T0, T1, T2, T3, T4>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new();
List<Tuple<T0, T1, T2, T3, T4, T5>> AsTList_OneOne<T0, T1, T2, T3, T4, T5>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new();
List<Tuple<T0, T1, T2, T3, T4, T5, T6>> AsTList_OneOne<T0, T1, T2, T3, T4, T5, T6>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new();
List<Tuple<T0, T1, T2, T3, T4, T5, T6, T7>> AsTList_OneOne<T0, T1, T2, T3, T4, T5, T6, T7>(int tableIndex = 0) where T0 : new() where T1 : new() where T2 : new() where T3 : new() where T4 : new() where T5 : new() where T6 : new() where T7 : new();
//以下是一对多关系的数据处理，oneGroupExpr指定主表的分组字段
Tuple<One, List<Many>> AsT_OneMany<One, Many>(Expression<Func<One, One>> oneGroupExpr = null, int tableIndex = 0) where One : new() where Many : new();
List<Tuple<One, List<Many>>> AsTList_OneMany<One, Many>(Expression<Func<One, One>> oneGroupExpr = null, int tableIndex = 0) where One : new() where Many : new();
}
DyResult对象有两个属性，
/// <summary>
/// 记录影响的行数, 只对 增、删、改 有效，查询返回结果永远是0
/// </summary>
public int RowCount { get; set; }
/// <summary>
/// 结果集
/// </summary>
public DataSet Records { get; set; }
通过实现IDyResult接口，将结果转化为各种常用的数据结构
PagedList<T> AsTPageList<T>();
PagedList<T>.PageIndex ==>> 分页索引
PagedList<T>.PageSize ==>> 页大小
PagedList<T>.TotalCount ==>> 总记录数
PagedList<T>.TotalPages ==>> 总行数
PagedList<T>.HasPreviousPage ==>> 是否有前一页
PagedList<T>.HasNextPage ==>> 是否有后一页
TreeNode<T> AsTree<T>();
TreeNode<T>.Parent ==>> 父节点T类型对象
TreeNode<T>.Current ==>> 当前节点对象
TreeNode<T>.Level ==>> 当前层次
TreeNode<T>.Flag ==>> 标记，默认-1；剪枝时有用
TreeNode<T>.IsLeaf ==>> 是否叶子节点
TreeNode<T>.ParentNode ==>> 父节点TreeNode类型
TreeNode<T>.Children ==>> 子节点TreeNode类型
DyResult内容较多，具体请下载后，查看demo程序中SampleCode->测试_结果集
有时我们在开发的过程中查看生成的SQL语句，可以通过如下方式： var query = new DyQuery().AsQuery(); var SQL = query.ToString();//生成的SQL语句
版本控制通过两种方式进行控制
- 方法一：设计数据表的时，将字段定义为timestamp类型，实体文件中生成 [Category(TIMESTAMP)] string 类型、将转为16进制字符串
- 方法二：设计数据表的时，添加v字段，设置为int类型或uniqueidentifier类型；v为其他类型时框架不会截取处理 int类型，可以作为增长的版本控制，从1开始一直往上累加 uniqueidentifier类型，可以作为变化控制，版本不需要累计的时候可以使用
- 当你使用了版本控制，增、改 数据的时候，改版本字段不需要你去手动维护。
- 其中TIMESTAMP类型的版本由数据库自动维护；其中v字段为int或uniqueidentifier类型时，框架会截取处理。
使用方式：
public class tb_product
{
[Description]
public Guid 产品ID { get; set; }
public String 产品名称 { get; set; }
public String 分类编号 { get; set; }
public Single 进价 { get; set; }
public Decimal 运费 { get; set; }
public Decimal 税率 { get; set; }
public Decimal 零售价 { get; set; }
public Double 会员折扣 { get; set; }
public String 产品描述_中文 { get; set; }
public String 产品描述_英文 { get; set; }
[Category("XML")]
public String RSS { get; set; }
public Byte[] 附件1 { get; set; }
public Byte[] 附件2 { get; set; }
[Category("TIMESTAMP")]
public String 版本 { get; set; }
}
//TIMESTAMP演示 （v字段类似 ）
var query = new DyQuery<tb_product>()
.Where(t1 => t1.产品ID == "E4EB08C5-0CBC-432A-B410-01C40BD9D1E9" ).AsQuery();
var product = dy.Query(query).AsT<tb_product>();
//现在需要修改 进价
product.进价 = 100;
//**并发环境下，另一个线程已经修改了这条数据
query = new DyQuery<tb_product>().Update(product).AsQuery();
var rowCount = dy.Query(query).RowCount;//rowCount == 0 修改失败
//存储过程
create proc sp_get_order_all
as
begin
select top 3 * from tb_order(nolock)
end
go
==>>生成实体
public class sp_get_order_all
{
}
//视图 => 具体操作跟【表】实体对象一致
create view v_user_order
as
select t1.订单名称,t1.订单ID,t2.购买数量,t1.账号 from tb_order t1
join tb_order_detail t2
on t1.订单ID = t2.订单ID
==>>生成实体
public class v_user_order
{
public String 订单名称 { get; set; }
public Guid 订单ID { get; set; }
public Int32 购买数量 { get; set; }
public String 账号 { get; set; }
}
//用户自定义函数
1. 标量函数
CREATE FUNCTION [dbo].[fn_IsDateout] (@BDate datetime) returns nvarchar(20)
AS
BEGIN
DECLARE @myresult nvarchar(20)
IF (datediff(day,@BDate,getdate())>30)
BEGIN
SET @myresult='已过期'
end
else
begin
set @myresult='未到期'
end
RETURN (@myresult)
END
go
CREATE function [dbo].[fn_IsOut](@val int) returns varchar(20)
as
begin
declare @ret varchar(20)
if @val > 5
set @ret = '偏大'
else
set @ret = '偏小'
return @ret
end
2. 表值函数
CREATE function [dbo].[fn_test1]() returns @t table( 账号 varchar(20),用户名 varchar(20) )
as
begin
insert into @t(账号,用户名)
select top 100 账号,用户名 from tb_user
return ;
end
go
CREATE function [dbo].[fn_test2](@账号 varchar(20),@用户名 varchar(20)) returns @t table( 账号 varchar(20),用户名 varchar(20) )
as
begin
insert into @t(账号,用户名)
select top 100 账号,用户名 from tb_user
return ;
end
将生成Dy_UDF.cs文件=====>>>>>>
/* 本代码由kQL.orm.cmdTool工具自动生成
contact:[email protected]
created time:2017-06-12 22:20:59*/
using System;
using System.ComponentModel;
using kQL.orm.expr;
namespace kQL.orm.demo.models
{
public class Dy_UDF
{
public static String fn_IsDateout ( DateTime @BDate ) { throw new Exception();}
public static DyXTable fn_test1 ( ) { throw new Exception();} public class FModel_fn_test1 { public String 账号{get;set;} public String 用户名{get;set;} }
public static String fn_IsOut ( Int32 @val ) { throw new Exception();}
public static DyXTable fn_test2 ( String @账号,String @用户名 ) { throw new Exception();} public class FModel_fn_test2 { public String 账号{get;set;} public String 用户名{get;set;} }
}
}
其中 ：
1. 标量函数生成静态方法
2. 表值函数生成静态方法，和一个 FModel_ 开头的模型类
**约定，下划线_开头的表、视图、存储过程、用户自定义函数（UDF），将不会生成实体文件。有时为了维护方便，会在数据库中建立一些日常维护的脚本，不需要给程序调用，这种场景下，可以使用下划线_开头的表、视图、存储过程、用户自定义函数（UDF） 约定通常表以tb开头、视图以v开头、存储过程以sp开头、自定义函数（udf）以fn开头
IDyResult接口中的大多数方法，都有一个默认形参tableIndex=0，默认取结果集的第一张表。大多数情况都可以得到满足。但有些场景下需要返回多张表，kQL.orm处理的方式，通过存储过程。
//存储过程
create proc sp_multi_tb
as
begin
select * from tb_user
select * from tb_categories
select * from tb_product
end
==>>生成实体
public class sp_multi_tb
{
}
var query = new DyQuery<sp_multi_tb>().Proc(new sp_multi_tb { }).AsQuery();
var result = dy.Query(query);
var userList = result4.AsTList<tb_user>(0);//第一张表的数据
var categoryList = result4.AsTList<tb_categories>(1);//第二张表的数据
var productList = result4.AsTList<tb_product>(2);//第三张表的数据
Console.WriteLine("tb_user count:{0},tb_categories count:{1},tb_product count:{2}"
, userList.Count, categoryList.Count, productList.Count);
//IN 查询
var query = new DyQuery<tb_user>().Where(t1 => t1.用户名.Dy_Right(1).Dy_In(new List<string> { "1", "2", "3" }))
.Select(t1 => t1.账号).AsQuery();
//Exists 子查询
var query = new DyQuery<tb_user>()
.Exists(WhereWay.And
, new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3)
.On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
//与下面等价
//.Join<tb_order_detail>(JoinWay.InnerJoin, (t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Having<tb_order_detail>(WhereWay.And, t3 => t3.订单ID.Dy_Count() > 5)
//.Select<tb_order, tb_order_detail>((t2, t3) => new { t2.订单ID, t2.账号, 明细数量 = t3.订单ID.Dy_Count() })
.Where<tb_order, tb_user>((t2, t1) => t2.账号 == t1.账号)
.Select(t2 => 1).AsQuery()
)
.Select(t1 => new { t1.账号, t1.用户名 })
.AsQuery();
**如果子查询中定义了与父查询相同的表别名会引起别名冲突， .Exists(WhereWay.And, new DyQuery<tb_order>(t2 => t2) ..//定义与父查询不同的别名
通过ISet接口实现
var query = new DyQuery<tb_order_detail>().Update()
.Set<tb_product>((t1, t2)
=> t1.产品名称 == t2.产品名称.Dy_Substring(1, 4)
).Join<tb_product>(JoinWay.InnerJoin,
(t1, t2) => t1.产品ID == t2.产品ID
).Where(t1 => t1.支付价 > 30)
.AsQuery();
t1.产品名称 == t2.产品名称.Dy_Substring(1, 4) //使用t2表进行更新t1表的字段，可以通过DyXTable 操作更加复杂的更新。
如果一个存储过程返回多个同名字段
create proc sp_user_selfjoin
as
begin
select * from tb_user t1 join tb_user t2
on t1.账号 = t2.账号
end
==>>结果集中， 将会有多个同名字段，如：账号,账号1,用户名,用户名1
默认情况下，使用第一个字段填充，即：账号、用户名
var query = new DyQuery<tb_user>().Proc(new sp_user_selfjoin{} ).AsQuery();
var user = dy.Query(query).AsT<tb_user>();//默认使用第一个字段填充 账号、用户名.....
/*如果想要取得所有字段，包括 账号1、用户名1 */
使用 AsT_OneOne方法,返回Tuple元组
var tupleUser = dy.Query(query).AsT_OneOne<tb_user,tb_user>();
var user1 = tupleUser.Item1 => 账号、用户名.....
var user2 = tupleUser.Item2 => 账号1、用户名1.....
另一种方式，使用动态对象
var query = new DyQuery<tb_user>().Proc(new sp_user_selfjoin{} ).AsQuery();
var user = dy.Query(query).AsDyT<tb_user>();
//user.账号
//user.账号1
//.......
**Where条件中bool类型必须使用二元表达式
var query = new DyQuery<tb_user>()
.Where(t1 =>
t1.性别 == true //必须使用二元表达式
&& t1.注册日期 == null // is null
&& t1.上次登录日期 !=null //is not null
).AsQuery()
业务中页面查询条件动态组合，简单演示动态查询
var criteria = new DyQuery<tb_user>();
if(!string.IsNullOrEmpty( Request["user_name"])){
criteria.Where(t1=>t1.用户名 == Request["user_name"] )
}
if(!string.IsNullOrEmpty( Request["user_age"])){
criteria.Where(t1=>t1.年龄 == int.Parse(Request["user_age"]) )
}
...
var top1Query = criteria.Select(t1=>t1.账号).AsQueryTopN(1);
var result = dy.Query(top1Query);
以上所有演示，AsT...相关方法都使用的是kQL.orm.cmdTool生成的实体对象 **您可以自动定义类型进行映射，不一定使用生成的实体对象 **映射的规则，通过结果集字段查找T类型中同名的属性
//如 在项目中定义了一个Order_DTO,用来接收tb_order,tb_order_detail的结果
public class Order_DTO {
public string 订单ID{get;set;}
public string 订单名称{get;set;}
public string 订单明细ID{get;set;}
public string 产品名称{get;set;}
public decimal 支付价{get;set;}
}
var query = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin,
(t2, t3) => t2.订单ID == t3.订单ID
).Order<DateTime>(OrderWay.Asc, t2 => t2.订单时间)
.Select<tb_order>(t2 => new { t2.订单ID, t2.账号 ,t2.订单名称})
.Select<tb_order_detail>(t3 =>
new { t3.订单明细ID, t3.产品名称, t3.支付价 }
).AsQuery();
var dtoList = dy.Query(query).AsTList<Order_DTO>();
public interface ITruncate<TLeft> : IDyQuery
{
IDyQuery Truncate();
}
//清空操作
dy.Query(new DyQuery<tb_user>().Truncate().AsQuery());
dy.Query(new DyQuery<tb_categories>().Truncate());
dy.Query(new DyQuery<tb_order>().Truncate());
dy.Query(new DyQuery<tb_order_detail>().Truncate());
dy.Query(new DyQuery<tb_product>().Truncate());
kQL.orm.command.timeout：sql command命令执行超时时间，默认30秒 kQL.orm.bulk.timeout：批量插入超时时间，默认0不超时
<appSettings>
<add key="kQL.orm.command.timeout" value="30"/>
<add key="kQL.orm.bulk.timeout" value="0"/>
<add key="kQL.orm.connstr" value="server=local;database=db_demo;uid=sa;pwd=sa;"/>
<--key可以使用你喜欢的名字 new Dy("remoteServer")-->
<add key="remoteServer" value="server=local;database=db_demo_remote;uid=sa;pwd=sa;"/>
</appSettings>
再次认识Dy类，Dy类是数据库操作的直接类，可以通过Dy类的构造函数连接不同的数据库
如上节，配置了remoteServer配置项，var remoteDy = new Dy("remoteServer"); 就构造好新的Dy操作类了。
默认情况下，Dy类直接取kQL.orm.connstr配置项。即 var localDy = new Dy();
//场景一：本地库与远程库 表结构一致>>单表->同步到远程服务器
//kQL.orm.demo命名空间下为本地库的实体类
//kQL.orm.remotemodels命名空间下为远程库的实体类
var localDy = new Dy();//本地库执行者
var remoteDy = new Dy("remoteServer");//远程库执行者
Console.WriteLine("开始执行导入远程服务器");
var query1 = new DyQuery<kQL.orm.demo.tb_user>().AsQuery();
var result = localDy
.CopyToRemote<kQL.orm.demo.remotemodels.tb_user>(query1, remoteDy);
Console.WriteLine("完成导入远程服务器，本次执行毫秒:{0}", result.Item1);
Console.WriteLine();
//场景二：本地库与远程库 表结构不一致>>多表的组合->同步到远程服务器
//****灵活定义、快速同步
var query2 = new DyQuery<tb_order>(t2 => t2)
.Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3)
.On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Having<tb_order_detail>(WhereWay.And,
t3 => t3.订单ID.Dy_Count() > 5
).Select<tb_order, tb_order_detail>(
(t2, t3) => new
{
t2.订单ID,
t2.账号,
明细数量 = t3.订单ID.Dy_Count(),
总金额Max = t3.支付价.Dy_Max(),
总金额Min = t3.支付价.Dy_Min(),
总金额Sum = t3.支付价.Dy_Sum(),
总金额Avg = t3.支付价.Dy_Avg(),
R金额 = ((t3.支付价.Dy_Max() + t3.支付价.Dy_Min() - t3.支付价.Dy_Sum() * t3.支付价.Dy_Avg()) / t3.支付价.Dy_Min()).Dy_Convert<decimal, decimal>("decimal(18,2)") //四则运算及转型
}
).AsQuery();
var result = localDy.CopyToRemote<kQL.orm.demo.remotemodels.tb_order_info>(query2, remoteDy);
Console.WriteLine("本地多表的组合->同步到远程服务器->本次执行毫秒:{0}", result.Item1);
//标量函数=>Dy_UDF.fn_IsDateout、Dy_UDF.fn_IsOut
var query2 =
new DyQuery<tb_user>()
.Where(t1 => t1.会员等级 > 100)
//.Where(t1 => t1.会员等级 > 50 && t1.性别 == true && t1.注册日期 == null && t1.上次登录日期 !=null)
.Select(t1 => new
{
状态 = Dy_UDF.fn_IsDateout(t1.上次登录日期),
t1.账号,
t1.用户名,
IsOut = Dy_UDF.fn_IsOut(t1.用户名.Dy_Right(1).Dy_Cast<string, int>("int")),
上次登录日期 = Dy_UDF.fn_IsDateout(t1.上次登录日期.Dy_IsNull(DateTime.Now)),
日期Cast = t1.上次登录日期.Dy_IsNull("20170601").Dy_Cast<string, string>("varchar"),
日期Convert = t1.上次登录日期.Dy_IsNull("20170601").Dy_Convert<string, string>(111, "varchar")
}).AsQueryTopN(10);
var result2 = new Dy().Done(query2);
Console.WriteLine(result2.AsJson());
//表值函数=>Dy_UDF.fn_test1()
var query = new DyQuery<DyXTable>().Select<Dy_UDF.FModel_fn_test1>(t1 => new { t1.用户名 })
.MapXTable<DyXTable, DyXTable>(t1 => t1, t1 => Dy_UDF.fn_test1())
.AsQueryTopN(10);
Console.WriteLine(new Dy().Done(query).AsJson());
//根据中间表查询
var xtable0 = new DyQuery<tb_order>(t2 => t2)
Join<tb_order_detail>(JoinWay.InnerJoin, t3 => t3).On<tb_order, tb_order_detail>((t2, t3) => t2.订单ID == t3.订单ID)
.Group(t2 => t2.订单ID).Group(t2 => t2.账号)
.Select<tb_order, tb_order_detail>((t2, t3) => new { t2.订单ID, t2.账号, 明细数量 = t3.订单ID.Dy_Count() })
.AsXTable();
var query0 = new DyQuery<tb_user>()
.Join<DyXTable>(JoinWay.InnerJoin, (t1, xt1) => t1.账号 == xt1.Dy_X_Column<tb_order, string>(m => m.账号))
.Select(t1=> new { t1.账号,t1.用户名})
.Select<DyXTable>(xt1 =>
new
{
订单ID = xt1.Dy_X_Column<tb_order, Guid>(x1 => x1.订单ID),//可以借助tb_order类型推导，推荐使用方式
明细数量 = xt1.Dy_X_Column<int>("明细数量"),//中间表的返回结果、无法推导
}).MapXTable<DyXTable>(xt1 => xt1, xtable0);
Console.WriteLine(new Dy().Done(query0).AsJson());
//根据中间表更新>>>>>>更新订单总金额
//定义中间表
var xTable1 = new DyQuery<tb_order_detail>(t2 => t2)
.Group(t2 => t2.订单ID)
.Select(t2 => new { t2.订单ID, 总金额 = t2.支付价.Dy_Sum(), })
.AsXTable();
//update from 方式更新 需要JOIN表
var query1 = new DyQuery<tb_order>().Update()
.Set<DyXTable>((t1, xt1) => t1.总金额 == xt1.Dy_X_Column<decimal>("总金额"))
.Join<DyXTable>( JoinWay.InnerJoin, (t1, xt1) => t1.订单ID == xt1.Dy_X_Column<tb_order, Guid>(m => m.订单ID))
.MapXTable<DyXTable>(xt1 => xt1, xTable1)
.AsQuery();
Console.WriteLine(new Dy().Done(query1).AsJson());
//delete from
var xTable2 = new DyQuery<tb_order_detail>(t2 => t2)
.Group(t2 => t2.订单ID)
.Where(t2=>t2.支付价>10)
.Select(t2 => new { t2.订单ID, 总数量 = DyExtFn.Dy_CountN(1), })
.AsXTable();
var query2 = new DyQuery<tb_order>().Delete()
.Where(t1 => t1.总金额 > 300).Exists(WhereWay.And,
new DyQuery<DyXTable>(t2 => t2)
.Where<tb_order, DyXTable>((t1, t2) => t1.订单ID == t2.Dy_X_Column<tb_order, Guid>(m => m.订单ID) && t2.Dy_X_Column<int>("总数量") > 2)
.MapXTable<DyXTable>(t2 => t2, xTable2)
.Select(t2 => 1)
).AsQuery();
Console.WriteLine(new Dy().Done(query2).AsJson());
public static class DyExtFn：所有扩展函数都定义在该类中
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_Ascii | ascii | |
| Dy_Char | char | |
| Dy_NChar | nchar | |
| Dy_Unicode | unicode | |
| Dy_Quotename | quotename | |
| Dy_Soundex | soundex | |
| Dy_PatIndex | patindex | |
| Dy_CharIndex | charindex | |
| Dy_Difference | difference | |
| Dy_Left | left | |
| Dy_Right | right | |
| Dy_Len | len | |
| Dy_Lower | lower | |
| Dy_Upper | upper | |
| Dy_LTrim | ltrim | |
| Dy_RTrim | rtrim | |
| Dy_Reverse | reverse | |
| Dy_Space | space | 静态方法， DyExtFn.Dy_Space(N) |
| Dy_Str | str | |
| Dy_Stuff | stuff | |
| Dy_Substring | substring | |
| Dy_Replace | replace | |
| Dy_Replicate | replicate |
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_DateAdd | dateadd | |
| Dy_DateDiff | datediff | |
| Dy_DateName | datename | |
| Dy_DatePart | datepart | |
| Dy_GetDate | getdate | 静态方法，DyExtFn.Dy_GetDate() |
| Dy_Day | day | |
| Dy_Month | month | |
| Dy_Year | year | |
| Dy_GetUtcDate | getutcdate | 静态方法，DyExtFn.Dy_GetUtcDate() |
| Dy_TimeFrt | 无 | 上下文中DateTime对象的扩展方法 |
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_M_Abs | abs | |
| Dy_M_PI | pi | 静态方法，DyExtFn.Dy_M_PI() |
| Dy_M_Cos | cos | |
| Dy_M_Sin | sin | |
| Dy_M_Cot | cot | |
| Dy_M_Tan | tan | |
| Dy_M_ACos | acos | |
| Dy_M_ASin | asin | |
| Dy_M_ATan | atan | |
| Dy_M_Degrees | degrees | |
| Dy_M_Radians | radians | |
| Dy_M_Exp | exp | |
| Dy_M_Log | log | |
| Dy_M_Log10 | log10 | |
| Dy_M_Ceiling | ceiling | |
| Dy_M_Floor | floor | |
| Dy_M_Power | power | |
| Dy_M_Sqrt | sqrt | |
| Dy_M_Sign | sign | |
| Dy_M_Rand | rand | 静态方法，DyExtFn.Dy_M_Rand() |
| Dy_M_Round | round |
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_Avg | avg | |
| Dy_Count | count | |
| Dy_CountN | count | 静态方法，DyExtFn.Dy_CountN(1) |
| Dy_Max | max | |
| Dy_Min | min | |
| Dy_Sum | sum |
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_Convert | convert | |
| Dy_Cast | cast |
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_NewId | newid | |
| Dy_IsNumeric | isnumeric | |
| Dy_IsNull | isnull | |
| Dy_IsDate | isdate |
| 扩展函数名 | DB函数名 | 说明 |
|---|---|---|
| Dy_X_Column | 取中间表字段，或推导中间表字段 | 通常与DyXTable中间表合用 |
| Dy_N | 数字常量 | where 1 = 0 可以 Where(t1=> DyExtFn.Dy_N(1) == 0 ) |
| Dy_StartsWith | like '[参数]%' | |
| Dy_EndsWith | like '%[参数]' | |
| Dy_Contains | like '%[参数]%' | |
| Dy_StartsWithNot | not like '[参数]%' | |
| Dy_EndsWithNot | not like '%[参数]' | |
| Dy_ContainsNot | not like '%[参数]%' | |
| Dy_StrGT | [字段名] > '[参数]' | |
| Dy_StrGE | [字段名] >= '[参数]' | |
| Dy_StrLT | [字段名] < '[参数]' | |
| Dy_StrLE | [字段名] <= '[参数]' | |
| Dy_In | in ([参数1],[参数2],[参数3],...) | 支持子查询 |
| Dy_InNot | not in ([参数1],[参数2],[参数3],...) | 支持子查询 |