[开源]无sql之旅-Chloe.ORM之增删查改

扯淡

这是一款轻量、高效的.NET C#数据库访问框架(ORM)。查询接口借鉴 Linq(但不支持 Linq)。借助 lambda 表达式，可以完全用面向对象的方式就能轻松执行多表连接查询、分组查询、聚合函数查询、插入数据、删除和更新满足条件的数据等操作。

在上篇文章中， Chloe.ORM 初次对外抛头露面，虽然是在重复造轮子，但还是得到部分园友的支持与认可，LZ非常感谢！上文主要展示 Chloe 的查询方式以及支持的 lambda 写法，本文主题是多表连接查询、插入数据、更新数据、删除数据以及事务支持。

导航

  • 事前准备
  • 多表连接查询
  • 插入数据
  • 更新数据
  • 删除数据
  • 事务支持

Chloe.ORM

事前准备

实体：

public enum Gender
{
    Man = 1,
    Woman
}

[Table("Users")]
public class User
{
    [Column(IsPrimaryKey = true)]
    [AutoIncrement]
    public int Id { get; set; }
    public string Name { get; set; }
    public Gender? Gender { get; set; }
    public int? Age { get; set; }
    public int? CityId { get; set; }
    public DateTime? OpTime { get; set; }
}

首先，创建一个 DbContext：

IDbContext context = new MsSqlContext(DbHelper.ConnectionString);

再创建一个 IQuery<T>：

IQuery<User> q = context.Query<User>();

多表连接查询

在上篇文章中，介绍了 Chloe 的查询功能。Chloe 执行连接查询时，建立连接(IQuery<T>接口调用 InnerJoin、LeftJoin、RightJoin 和 FullJoin)返回的是 IJoiningQuery 的泛型对象，如果看过框架源码的同学可能会知道，IJoiningQuery 的泛型参数最多有5个，而且有5个泛型参数的那个类(IJoiningQuery<T1,T2,T3,T4,T5>)就只有一个 Select 方法，也就是说不能继续连接其它表，最多有5个表建立连接，真的是这样吗？如果你这样认为你就错了！我们来看看怎么建立超过5个表的连接。

伪代码：

//假设已经有5个表建立了连接的对象为 jq_q1_q5
IJoiningQuery<T1, T2, T3, T4, T5> jq_q1_q5 = null;

//jq_q1_q5 调用 Select 方法，返回一个包含 T1-T5 的 IQuery<T> 对象 view_q1_q5
var view_q1_q5 = jq_q1_q5.Select((t1, t2, t3, t4, t5) => new { T1 = t1, T2 = t2, T3 = t3, T4 = t4, T5 = t5 });

//假设第6个表的 IQuery<T6> 对象为 q6
IQuery<T6> q6 = null;

//这时，view_q1_q5 与 q6 建立连接，返回 IJoiningQuery 对象 jq
var jq = view_q1_q5.InnerJoin(q6, (t1_t5, t6) => t1_t5.T5.XX == t6.XXX);

//然后我们调用 jq 的 Select 方法，返回一个包含 T1-T6 的 IQuery<T> 对象 view。
//view 又是一个 IQuery<T> 对象，泛型参数为包含 T1-T6 所有信息的匿名对象(这时候还没有发起 sql 查询哦)，拿到它，我们就可以为所欲为了。
var view = jq.Select((t1_t5, t6) => new { T1 = t1_t5.T1, T2 = t1_t5.T2, T3 = t1_t5.T3, T4 = t1_t5.T4, T5 = t1_t5.T5, T6 = t6 });

//可以直接查出数据库中 T1-T6 的所有信息
view.ToList();

//也可以选取 T1-T6 中我们想要的字段
view.Select(a => new { a.T1.xx, a.T2.xx, a.T3.xx /*...*/}).ToList();

这样，周而复始，就可以实现无限表连接了，相对没有 Linq 那么直观，但这是我能想到最好的方式了。如果哪位同学有更好的设计，望分享，不胜感激！

Chloe 的另外亮点是聚合函数查询和分组查询，这两个查询有别于 Linq，更趋于标准 sql 思想，配合连接查询使用，可以应对一些稍微复杂的查询，可以翻看上篇文章使用进阶部分，有简单介绍，连接地址：http://www.cnblogs.com/so9527/p/5636216.html#more_usage。

目前市面上很多 ORM 都只是支持单表查询，能灵活操作连接查询和聚合函数查询的，除 EF 和 linq to sql 外，为数不多，这也是我造轮子的原因之一。

插入数据

方式1

以 lambda 的形式插入：

IDbContext context = new MsSqlContext(DbHelper.ConnectionString);

//返回主键 Id
int id = (int)context.Insert<User>(() => new User() { Name = "lu", Age = 18, Gender = Gender.Man, CityId = 1, OpTime = DateTime.Now });
/*
 * INSERT INTO [Users]([Name],[Age],[Gender],[CityId],[OpTime]) VALUES(N‘lu‘,18,1,1,GETDATE());SELECT @@IDENTITY
 */

方式2

IDbContext context = new MsSqlContext(DbHelper.ConnectionString);

User user = new User();
user.Name = "lu";
user.Age = 18;
user.Gender = Gender.Man;
user.CityId = 1;
user.OpTime = new DateTime(1992, 1, 16);

//会自动将自增 Id 设置到 user 的 Id 属性上
user = context.Insert(user);
/*
 * String @P_0 = "lu";
   Gender @P_1 = Man;
   Int32 @P_2 = 18;
   Int32 @P_3 = 1;
   DateTime @P_4 = "1992/1/16 0:00:00";
   INSERT INTO [Users]([Name],[Gender],[Age],[CityId],[OpTime]) VALUES(@P_0,@P_1,@P_2,@P_3,@P_4);SELECT @@IDENTITY
 */

第一种方式比较接近 sql 的写法，可以有选择的插入。第二种方式则会将所有映射的字段都插入。对于插入数据需求，这两种方式我想应该可以满足了。

更新数据

方式1

以 lambda 的形式更新：

MsSqlContext context = new MsSqlContext(DbHelper.ConnectionString);

context.Update<User>(a => new User() { Name = a.Name, Age = a.Age + 100, Gender = Gender.Man, OpTime = DateTime.Now }, a => a.Id == 1);
/*
 * UPDATE [Users] SET [Name]=[Users].[Name],[Age]=([Users].[Age] + 100),[Gender]=1,[OpTime]=GETDATE() WHERE [Users].[Id] = 1
 */

//批量更新
//给所有女性朋友年轻 10 岁
context.Update<User>(a => new User() { Age = a.Age - 10, OpTime = DateTime.Now }, a => a.Gender == Gender.Woman);
/*
 * UPDATE [Users] SET [Age]=([Users].[Age] - 10),[OpTime]=GETDATE() WHERE [Users].[Gender] = 2
 */

方式2

MsSqlContext context = new MsSqlContext(DbHelper.ConnectionString);

User user = new User();
user.Id = 1;
user.Name = "lu";
user.Age = 28;
user.Gender = Gender.Man;
user.OpTime = DateTime.Now;

context.Update(user); //会更新所有映射的字段
/*
 * String @P_0 = "lu";
   Gender @P_1 = Man;
   Int32 @P_2 = 28;
   Nullable<Int32> @P_3 = NULL;
   DateTime @P_4 = "2016/7/8 11:28:27";
   Int32 @P_5 = 1;
   UPDATE [Users] SET [Name][email protected]_0,[Gender][email protected]_1,[Age][email protected]_2,[CityId][email protected]_3,[OpTime][email protected]_4 WHERE [Users].[Id] = @P_5
 */

/*
 * 支持只更新属性值已变的属性
 */

context.TrackEntity(user);//在上下文中跟踪实体
user.Name = user.Name + "1";
context.Update(user);//这时只会更新被修改的字段
/*
 * String @P_0 = "lu1";
   Int32 @P_1 = 1;
   UPDATE [Users] SET [Name][email protected]_0 WHERE [Users].[Id] = @P_1
 */

像第一种方式可以批量更新数据方法，我觉得在实际开发中很有必要，且不可或缺。

之前，同事用 EF 开发一个功能，需要批量更新，他的做法是将所有满足条件的数据给查出来，然后挨个赋值，最后统一 SaveChanges()，开发时由于数据量少，没发现问题。部署上线了以后，用户随便点击一下保存，这个方法执行都要好久，瞬间懵了，不多说为什么，你懂的！虽然有人基于 EF 做了一个支持批量更新的 EF 扩展类库，经过各方面考虑，最终不敢轻易冒风险引入项目中。那就拼接一句批量 Update 的sql呗，原生态执行。Oh！想到拼 sql，心中一万个草泥马路过！！！都 .net4.5+ 时代，.net Core 都出了，还执着手写sql？这费时费力的活咱90后程序员可不干！虽然我 sql 写得很溜，但不到没辙的时候我是不会去拼 sql。项目开发阶段，我是秉着怎么快怎么做原则，有能10分钟解决问题的方式，我是不会选择10分钟+1秒的其他方法！多一秒也不行！至于优化，那是后事。
自己动手，能根据需求定制理想的功能，这也是我造轮子的原因之一。

删除数据

方式1

以 lambda 的形式删除：

MsSqlContext context = new MsSqlContext(DbHelper.ConnectionString);

context.Delete<User>(a => a.Id == 1);
/*
 * DELETE [Users] WHERE [Users].[Id] = 1
 */

//批量删除
//删除所有不男不女的用户
context.Delete<User>(a => a.Gender == null);
/*
 * DELETE [Users] WHERE [Users].[Gender] IS NULL
 */

方式2

MsSqlContext context = new MsSqlContext(DbHelper.ConnectionString);

User user = new User();
user.Id = 1;
context.Delete(user);
/*
 * Int32 @P_0 = 1;
   DELETE [Users] WHERE [Users].[Id] = @P_0
 */

删除数据就这么简单。

事务支持

Chloe 的事务操作方法在 DbContext.CurrentSession 属性里：

MsSqlContext context = new MsSqlContext(DbHelper.ConnectionString);

IDbSession dbSession = context.CurrentSession;
try
{
    dbSession.BeginTransaction();

    //to do somethings here...

    dbSession.CommitTransaction();
}
catch
{
    dbSession.RollbackTransaction();
}

事务是每个 ORM 必备的功能。太简单，本来不想写进来的，想想，写吧，凑个字数也好。

结语

Chloe.ORM 主打便捷、高效，无论是 IDbContext 还是 IQuery<T> 接口，设计极其简单，基本一看就懂，一用就会。并且不依赖任何配置，上手简单，传个数据库连接字符串就能跑，我就喜欢这样傻瓜式开发。话说有一点我很纳闷，C# 是一门高度简化的语言，很多人说微软把程序员培养得越来越傻，试问，傻瓜式开发不好吗？这是开发语言的进步啊，我们为什么要拒绝！那些人是不是都喜欢折腾？说句不好听的，如果一门语言真把一个程序员变“傻”，我想，那位程序员肯定不是好程序员！扯远了，嘿嘿。

秉着开源共享精神，促进国内开源事业发展，Chloe.ORM 完全开源，遵循 Apache2.0 协议。

GitHub：https://github.com/shuxinqin/Chloe

开源中国：http://www.oschina.net/p/chloe-orm

ps：小弟不才，文化、技术功底有限，必有不足之处，望各路大神多多指点，非常感谢。也请有异议的同学，点反对的同时，麻烦也留个建议再离开，行吗？谢谢。

时间： 2024-10-12 16:43:06

[开源]无sql之旅-Chloe.ORM之增删查改的相关文章

SQL Server 中BIT类型字段增删查改那点事

话说BIT类型字段之前,先看“诡异”的一幕,执行Update成功,但是查询出来的结果依然是1,而不是Update的2 当别人问起我来的时候,本人当时也是处于懵逼状态的,后面联想具体的业务突然想起来这个字段是bit类型的 如果把这个现象跟BIT类型字段连续起来就不觉得奇怪了. 废话不多,直接上代码看结果就好了. 先建一个测试表 CREATE TABLE TestBIT ( Id INT IDENTITY(1,1), BitColumn BIT ) 按照常规来说,bit类型字段只能存0或者1,所以直

[开源].NET数据库访问框架Chloe.ORM

前言 13年毕业之际,进入第一家公司实习,接触了 EntityFramework,当时就觉得这东西太牛了,访问数据库都可以做得这么轻松.优雅!毕竟那时还年轻,没见过世面.工作之前为了拿个实习机会混个工作证明,匆匆忙忙学了两个月的 C#,就这样,稀里糊涂的做了程序员,从此走上了一条不归路.那会也只知道 SqlHelper,DataTable.ORM?太高档上,没听说过.虽然在第一家公司只呆了两个月,但让我认识了 EntityFramework,从此也走上了 ORM 的不归路...纯纯的实体,增改删

SQL Server之 (四) ADO增删查改 登录demo 带参数的sql语句 插入自动返回行号

SQL Server之 (四) ADO增删查改  登录demo  带参数的sql语句  插入自动返回行号 自己学习笔记,转载请注明出处,谢谢!---酸菜 1.什么是ADO.NET ADO.NET是一组类库,这组类库可以让我们通过程序的方式访问数据库,并以各种方式操作存储在其中的数据; ADO.NET是基于.NET FrameWork,与.NET FrameWork类库的其余部分是高度集成的 2.连接数据库的步骤 ①创建连接字符串 Data Source=XXX-PC; Initial Catal

EF增删查改加执行存储过程和sql语句，多种方法汇总

1 ActionUrl c = new ActionUrl() { ActionName="test", RequestUrl="/123/123", SubTime=DateTime.Now }; 2 //增 3 using (EntityContext db = new EntityContext()) 4 { 5 6 /*方法1*/ 7 db.ActionUrls.Add(c); 8 db.SaveChanges(); 9 /*方法2*/ 10 db.Set&

SQL Server 表的管理_关于表的操作增删查改的操作的详解（案例代码）

SQL Server 表的管理_关于表的操作增删查改的操作的详解(案例代码) 概述: 表由行和列组成,每个表都必须有个表名. SQL CREATE TABLE 语法 CREATE TABLE table_name ( column_name1 data_type(size), column_name2 data_type(size), column_name3 data_type(size), .... ); 1.查看表 exec sp_help table1; 2.创建表 create tab

JDBC终章- 使用 DBUtils实现增删查改- C3P0Utils数据源/QueryRunner runner连接数据源并执行sql

JDBC终章- 使用 DBUtils实现增删查改 1.数据库结构 Create Table CREATE TABLE `user` ( `id` int(3) NOT NULL AUTO_INCREMENT, `name` varchar(20) NOT NULL, `password` varchar(20) NOT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 2.工程结构    

sql语法复习：增删查改,各种数据库对象创建和函数使用

推荐工具:机子配置较低的话,可以装Gsql这个工具获得sql执行环境(可作为手册查看内置数据类型 函数和存储过程等) --之前数据库的东西接触不多,虽然基本的语法是了解,但不是很熟悉--最近项目一直在折腾存储过程(一些数据逻辑都通过存储过程在数据库端实现),--复习了一遍sql的东东,在此记录一下. /*--创建数据库create database testuse test;--创建表 字段定义列表 主键 外键create table score (id int primary key, stu

SQL基础教程--实现增删查改功能(W3School)

1.SQL DML 和 DDL 可以把 SQL 分为两个部分:数据操作语言 (DML) 和 数据定义语言 (DDL). SQL (结构化查询语言)是用于执行查询的语法.但是 SQL 语言也包含用于更新.插入和删除记录的语法. 查询和更新指令构成了 SQL 的 DML 部分: SELECT - 从数据库表中获取数据 UPDATE - 更新数据库表中的数据 DELETE - 从数据库表中删除数据 INSERT INTO - 向数据库表中插入数据 SQL 的数据定义语言 (DDL) 部分使我们有能力创

SQL增删查改语句

一.增:有4种方法 1.使用insert插入单行数据: 语法:insert [into] <表名> [列名] values <列值> insert into sheet1 values ('000000','000000','0','张三','000000','000000','000000','000000','0','0','000000', '1900-1-1 0:00:00','派出所','0','泉山分局') (如果没有写表的属性的话,则需依次添加列植) 例:insert