基于Dapper的开源Lambda扩展,且支持分库分表自动生成实体

LnskyDB

LnskyDB是基于Dapper的Lambda扩展,支持按时间分库分表,也可以自定义分库分表方法.而且可以T4生成实体类免去手写实体类的烦恼.

文档地址: https://liningit.github.io/LnskyDB/

开源地址: https://github.com/liningit/LnskyDB

nuget地址: https://www.nuget.org/packages/LnskyDB/

在此非常感谢SkyChenSky其中lambda表达式的解析参考了他的开源项目

下面是用ProductSaleByDayEntity作为示例,其中StatisticalDate为分库分表字段,如果是对分库分表对象进行数据库操作则必须传入StatisticalDate或者设置DBModel_ShuffledTempDate指定是那个库和表

---

1. 使用配置

在Startup.cs的ConfigureServices中添加services.AddLnskyDB();在Configure中添加app.UseLnskyDB();

2. 仓储的创建

仓储的创建有两种方式一种是通过RepositoryFactory.Create<ProductSaleByDayEntity>()创建IRepository<ProductSaleByDayEntity>
还有一种是创建一个仓储类继承Repository<ProductSaleByDayEntity>

public interface IProductSaleByDayRepository : IRepository<ProductSaleByDayEntity>{}public class ProductSaleByDayRepository : Repository<ProductSaleByDayEntity>{}//调用的地方可以IProductSaleByDayRepository repository=new ProductSaleByDayRepository();

3. 查询

3.1 根据主键查询

var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var entity = repository.Get(new ProductSaleByDayEntity{ DBModel_ShuffledTempDate = new DateTime(2019, 01, 01),//这儿表示差19年1月的库和表 SysNo = sysNo});

3.2 根据where条件查询

var stTime = new DateTime(2019, 1, 15);var endTime = new DateTime(2019, 2, 11);var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var query = QueryFactory.Create<ProductSaleByDayEntity>(m => m.ShopName.Contains("测试"));query.And(m => m.StatisticalDate >= stTime);query.And(m => m.StatisticalDate < endTime.Date.AddDays(1));query.OrderByDescing(m => m.StatisticalDate);//如果是查多个库表必须按分库分表的字段降序排列query.StarSize = 20; //可以设置查询行数及开始行数query.Rows = 10;//分库的传入stTime,endTime会自动根据时间查询符合条件的库和表var lst = repository.GetList(query, stTime, endTime);

如果可以确定统计时间也可以查指定的库表进行单表查询

var stTime = new DateTime(2019, 1, 15);var endTime = new DateTime(2019, 1, 18);var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var query = QueryFactory.Create<ProductSaleByDayEntity>(m => m.ShopName.Contains("测试"));query.And(m => m.StatisticalDate >= stTime);query.And(m => m.StatisticalDate < endTime.Date.AddDays(1));query.DBModel.DBModel_ShuffledTempDate = new DateTime(2019, 01, 01);//这儿表示查19年1月的库和表query.OrderByDescing(m => m.StatisticalDate);//单表查询可以随意排序query.StarSize = 20;query.Rows = 10;var lst= repository.GetList(query);

3.3 分页查询

var stTime = new DateTime(2019, 1, 15);var endTime = new DateTime(2019, 2, 11);var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var query = QueryFactory.Create<ProductSaleByDayEntity>(m => m.ShopName.Contains("测试"));query.And(m => m.StatisticalDate >= stTime);query.And(m => m.StatisticalDate < endTime.Date.AddDays(1));query.OrderByDescing(m => m.StatisticalDate);//如果是查多个库表必须按分库分表的字段降序排列query.StarSize = 20;query.Rows = 10;//分库的传入stTime,endTime会自动根据时间查询符合条件的库和表var paging = repository.GetPaging(query, stTime, endTime);var count = paging.TotalCount;var lst = paging.ToList();//或者paging.Items

如果可以确定统计时间也可以查指定的库表

var stTime = new DateTime(2019, 1, 15);var endTime = new DateTime(2019, 1, 18);var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var query = QueryFactory.Create<ProductSaleByDayEntity>(m => m.ShopName.Contains("测试"));query.And(m => m.StatisticalDate >= stTime);query.And(m => m.StatisticalDate < endTime.Date.AddDays(1));query.DBModel.DBModel_ShuffledTempDate = new DateTime(2019, 01, 01);//这儿表示查19年1月的库和表query.OrderByDescing(m => m.StatisticalDate);//单表查询可以随意排序query.StarSize = 20;query.Rows = 10;var paging= repository.GetPaging(query);var count = paging.TotalCount;var lst = paging.ToList();//或者paging.Items

4. 添加

var addEntity = new ProductSaleByDayEntity(){ SysNo = Guid.NewGuid(), DataSource = "测试来源", ProductID = Guid.NewGuid(),     ShopID = Guid.NewGuid(), ShopName = "测试店铺", ProductName = "测试商品", OutProductID = Guid.NewGuid().ToString(), ImportGroupId = Guid.NewGuid(), StatisticalDate = DateTime.Now//分库分表字段是必须的};var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();//如果新增主键是自增列会自动赋值自增列值到主键repository.Add(addEntity);

5. 更新

5.1 根据主键更新

var updateEntity = new ProductSaleByDayEntity(){ SysNo = Guid.Parse("650BC09C-2B9C-467B-A457-8B4853CC1F0F"), DataSource = "测试来源修改", ShopName = "店铺修改", StatisticalDate = new DateTime(2019,01,05),//如果StatisticalDate赋值了则根据StatisticalDate找库表,然后根据主键更新,StatisticalDate也会被更新成所赋的值 //如果不想更新StatisticalDate可以用下面这句话 // DBModel_ShuffledTempDate=new DateTime(2019,01,05),//如果不想更新StatisticalDate字段则用这句话来确定是那个库及表};var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();//根据主键更新其他字段return repository.Update(updateEntity);

5.2 根据where条件更新

var updateEntity = new ProductSaleByDayEntity(){ DataSource = "测试来源修改", ShopName = "店铺修改Where", DBModel_ShuffledTempDate = new DateTime(2019, 01, 05),//如果用这句话来确定是那个库表 // StatisticalDate = statisticalDate,//如果要更新StatisticalDate则可以用这句话替代上面那句话};var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var where = QueryFactory.Create<ProductSaleByDayEntity>(m => m.ShopName == "测试店铺1" && m.StatisticalDate > new DateTime(2019, 01, 03));//where是更新条件//注意如果是更新用的是实体类的DBModel_ShuffledTempDate Query中的无效return repository.Update(updateEntity, where);

6. 删除

6.1 根据主键删除

var deleteEntity = new ProductSaleByDayEntity(){ SysNo = Guid.Parse("650BC09C-2B9C-467B-A457-8B4853CC1F0F"), DBModel_ShuffledTempDate = new DateTime(2019, 01, 05),//对于分库分表来说DBModel_ShuffledTempDate是必须的用来确认是那个库表};var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();return repository.Delete(deleteEntity);

6.2 根据where条件删除

var repository = RepositoryFactory.Create<ProductSaleByDayEntity>();var where = QueryFactory.Create<ProductSaleByDayEntity>();where.DBModel.DBModel_ShuffledTempDate = new DateTime(2019, 01, 01);//QueryiSearch方法表示搜索里面空格表示或+表示且//如 导入+手工 自动+生成 表示字段必须同时拥有导入和手工或者自动和生成//生成sql是 and ((DataSource like '%导入%' and DataSource like '%手工%') or DataSource like '%自动%' and DataSource like '%生成%')   where.QueryiSearch(m => m.DataSource, "新+更");where.QueryiSearch(m => m.ShopName, "批量修改");//注意如果是更新用的是实体类的DBModel_ShuffledTempDate Query中的无效return repository.Delete(where);

7. 多线程处理

对于mvc每次请求都会在请求结束时将数据库连接关闭,如果是新建线程则需要在线程开始调用DBTool.BeginThread();
并且在线程结束为止调用DBTool.CloseConnections();关闭连接

public class ThreadTool{ public static void QueueUserWorkItem(Action action) {  ThreadPool.QueueUserWorkItem(delegate  {   DBTool.BeginThread();   try   {    action();   }   finally   {    DBTool.CloseConnections();   }  }); }}ThreadTool.QueueUserWorkItem(ThreadDo);//调用

8. 实体类T4自动生成

在LnskyDB.Demo\T4中有可以自动生成实体类的T4模版.
其中DbHelper.ttinclude中的Config是配置数据库的
Entity.tt是生成实体的T4模版.大家可以根据自己的情况修改
我们项目是表的命名规则是 :非分库分表的:模块_表名 分库分表:模块_表名_月份 所以T4也是根据这个规则生成的.大家如果不一样的话可以根据自己的情况修改DbHelper.ttinclude文件

原文转载：http://www.shaoqun.com/a/755791.html

跨境电商：https://www.ikjzd.com/

sgshop：https://www.ikjzd.com/w/1982

折扣网：https://www.ikjzd.com/w/74

LnskyDBLnskyDB是基于Dapper的Lambda扩展,支持按时间分库分表,也可以自定义分库分表方法.而且可以T4生成实体类免去手写实体类的烦恼.文档地址:https://liningit.github.io/LnskyDB/开源地址:https://github.com/liningit/LnskyDBnuget地址:https://www.nuget.org/packages/Lns
环球易购：https://www.ikjzd.com/w/1034
走秀网：https://www.ikjzd.com/w/2427
兰亭集势：https://www.ikjzd.com/w/820
Amazon Business从未公布的"品类赚钱利器"丨欧洲工具品类深度解析：https://www.ikjzd.com/articles/10308
第一次爱爱老公就流鼻血：http://lady.shaoqun.com/a/271245.html
分享新店运营思路，lazada新店怎样快速提升流量转化？：https://www.ikjzd.com/articles/128547