开源Dapper的Lambda扩展-Sikiro.Dapper.Extension V2.0

简介: 开源Dapper的Lambda扩展-Sikiro.Dapper.Extension V2.0

前言

  

去年我在业余时间,自己整了一套dapper的lambda表达式的封装,原本是作为了一个个人的娱乐项目,当时也只支持了Sql Server数据库。随之开源后,有不少朋友也对此做了试用,也对我这个项目提出了不少的建议。因此我在最近公司业务不怎么繁忙的情况下,对朋友们的建议和我的想法做了一个总结,然后花了一个星期的时间对项目进行了重构与升级,希望该项目能帮助到有需要的人。

  

如果您对它有兴趣,欢迎大家提交Pull Request代码变更,如果有任何问题可提交issue进行讨论。当然也可以在下方评论和QQ私聊给我。为该文章点个推荐或者给项目点star

都是给我最大的动力与支持,谢谢。


源码


https://github.com/SkyChenSky/Sikiro.Dapper.Extension


文档


具体使用可以查看文档:


https://github.com/SkyChenSky/Sikiro.Dapper.Extension/wiki


设计理念


该项目主要目的是通过使用lambda表达式达到以下效果:


  • 提高开发效率
  • 强类型。
  • 智能提示
  • 编译错误提示

 

该扩展主要解决重复性较大的简单查询,因此并不提供链表(JOIN)操作,如果是简单的链表可以通过编写视图,再使用该扩展组件。如果是复杂查询,建议手写SQL+原生Dapper方法。


版本改动


数据库支持

  

原本项目名为Sikiro.DapperLambdaExtension.MsSql,


现更名为Sikiro.Dapper.Extension,


同时支持三种数据库 MsSQL、MySQL、PostgreSQL。


MsSql


PM> Install-Package Sikiro.Dapper.Extension.MsSql


MySql


PM> Install-Package Sikiro.Dapper.Extension.MySql


PostgreSql


PM> Install-Package Sikiro.Dapper.Extension.PostgreSql


异步方法支持

  

对于数据库访问这种强I/O操作的,可以在合理的场景下使用异步方法提高应用处理并发能力。支持方法有:


  1. ToListAsync
  2. GetAsync
  3. InsertAsync
  4. DeleteAsync
  5. UpdateSelectAsync
  6. UpdateAsync


框架重构


image.png


框架主要分为两部分:


Sikiro.Dapper.Extension 为公共抽象库,主要是接口、抽象类与公共方法


Sikiro.Dapper.Extension.XXX 为具体实现库,主要是重写不同数据库的特性与语句组合。


Sikiro.Dapper.Extension 类图


image.png


Sikiro.Dapper.Extension.MsSql类图


image.png


其他特性


链式风格


Query


con.QuerySet<SysUser>().Where(a => a.Email == "287245177@qq.com")
                       .OrderBy(a => a.CreateDatetime)
                       .Select(a => new SysUser { Email = a.Email, CreateDatetime = a.CreateDatetime, SysUserid = a.SysUserid })
                       .PageList(1, 10);


Command


con.CommandSet<SysUser>().Where(a => a.Email == "287245177@qq.com").Update(a => new SysUser { Email = "123456789@qq.com" });


忠于原生的特性标签


不标新立异,方便替换组件


[Table("SYS_USER")]
[Key]
[Required]
[StringLength(32)]
[Display(Name = "主键")]
[Column("SYS_USERID")]
[DatabaseGenerated]


高并发处理的UpdateSelect

  

该方法主要用于把符合条件的数据更新后并查询出来,并通过READPAST过滤了已被锁的数据。具体所生成的SQL语句如下:


UPDATE TOP ( 100 )
        SYS_USER WITH ( UPDLOCK, READPAST )
SET     USER_STATUS = 1
OUTPUT  INSERTED.[USER_NAME] ,
        INSERTED.SYS_USERID ,
        INSERTED.EMAIL
FROM    SYS_USER
WHERE   CREATE_DATETIME < '2018-09-13'
        AND USER_STATUS = 2;


那么该方法有他的使用场景,在我们公司现有业务,资金定时服务就是通过使用UpdateSelect方法轮询数据源,把需要处理的数据库先UpdateSelect成一个中间状态,然后再与第三方接口做交互处理,假如此时有多个资金定时服务并行去跑,A-Job会跑取前100条数据,B-Job会因为READPAST的原因过滤了A-JOB所锁的前1-100条而读取了第101-200条数据进行处理。因此当业务量增多,只需要把资金定时服务再部署多一台服务器即可。


附带工具


2年前也是在业余时间,自己基于Visual Studio SDK写了一个实体成的VS 插件。本工具也是开源的,并很好与Sikiro.Dapper.Extension配合使用,当然也是非必要的可独立使用。


github地址:https://github.com/SkyChenSky/AutoBuildEntity


488722-20190326162836718-1899628585.gif



其他

  

如果也想开发类似项目的朋友,也可以参考我以前写过的三篇文章:

目录
相关文章
|
4月前
|
Scala 缓存 API
Play Framework与Scala:揭秘高性能Web应用的构建之道!
【8月更文挑战第31天】张浩是一位热爱新技术的软件工程师,最近在公司项目中使用Play Framework和Scala构建Web应用,并在个人技术博客上记录分享这一过程。他介绍了选择这两项技术的原因:Play Framework具有高性能、热重载及可扩展API等优点,而Scala则结合了面向对象与函数式编程特性,提供了更好的并发模型和简洁代码。张浩详细描述了开发环境搭建、异步编程模型、非阻塞I/O处理、Action Composition、缓存使用及并行集合和`Future`的运用,展示了如何构建高性能Web应用。他鼓励读者尝试这些技术,提升开发效率。
45 0
|
SQL 缓存 开发框架
推荐一个EntityFramework扩展的开源项目
通过必备功能扩展了DbContext:包括过滤器,缓存,提前查询,批量操作等EF扩展功能。
130 0
推荐一个EntityFramework扩展的开源项目
|
前端开发 JavaScript 数据库
如何使用 Restful ABAP Programming 编程模型开发一个支持增删改查的 Fiori 应用(二)
Restful ABAP Programming 编程模式是 ABAP 这门编程语言在不断向前进化的过程中,诞生的一门新的编程模型,简称为RAP模型。
161 0
如何使用 Restful ABAP Programming 编程模型开发一个支持增删改查的 Fiori 应用(二)
|
uml
封装自己的dapper lambda扩展-设计篇(一)
封装自己的dapper lambda扩展-设计篇(一)
233 0
封装自己的dapper lambda扩展-设计篇(一)
封装自己的dapper lambda扩展-设计篇(二)
封装自己的dapper lambda扩展-设计篇(二)
232 0
封装自己的dapper lambda扩展-设计篇(二)
|
开发者
编写自己的dapper lambda扩展-使用篇
编写自己的dapper lambda扩展-使用篇
276 0
|
SQL 存储 C#
C#中如何使用Dapper
C#中如何使用Dapper
272 0
|
SQL 前端开发 .NET
Asp.net 面向接口可扩展框架之数据处理模块及EntityFramework扩展和Dapper扩展(含干货)
原文:Asp.net 面向接口可扩展框架之数据处理模块及EntityFramework扩展和Dapper扩展(含干货) 接口数据处理模块是什么意思呢?实际上很简单,就是使用面向接口的思想和方式来做数据处理。
1205 0
|
关系型数据库 数据库
|
机器学习/深度学习 关系型数据库 C#