标签：数据库 key 配置 net 查询 orm框架 操作 删除 最大值
本项目是一个使用.NET Standard 2.0开发的，基于 Dapper 的轻量级 ORM 框架，包含基本的CRUD以及根据表达式进行一些操作的方法，目前只针对单表，不包含多表连接操作。
github：https://github.com/iamoldli/NetSql
Install-Package NetSql创建Article实体类，继承EntityBase
public class Article : EntityBase
{
[Column("Title")]
public string Title1 { get; set; }
public string Summary { get; set; }
public string Body { get; set; }
public Category Category { get; set; }
public int ReadCount { get; set; }
public bool IsDeleted { get; set; }
public DateTime CreatedTime { get; set; }
}
public enum Category
{
Blog,
Movie
}EntityBase是一个定义好的实体基类，包含一个泛型主键标识，默认是 Int 类型的，也可以指定 long 或者 string 类型
public class Article : EntityBase<string>数据库上下文我是模仿的 EF，IDbContextOptions是数据库上下文配置项接口，默认包含了 SqlServer 的实现DbContextOptions，如果使用的是 MySql 或者 SQLite，需要额外安装对应的扩展包
Install-Package NetSql.MySql //MySqlInstall-Package NetSql.SQLite //SQLite这里我定义了一个BlogDbContext上下文，其中包含一个Articles数据集
public class BlogDbContext : DbContext
{
public BlogDbContext(IDbContextOptions options) : base(options)
{
}
public IDbSet<Article> Articles { get; set; }
}private readonly BlogDbContext _dbContext;
private readonly IDbSet<Article> _dbSet;
public DbSetTests()
{
_dbContext = new BlogDbContext(new SQLiteDbContextOptions("Filename=./Database/Test.db"));
_dbSet = _dbContext.Set<Article>();
//预热
_dbSet.Find().First();
}[Fact]
public async void InsertTest()
{
var article = new Article
{
Title1 = "test",
Category = Category.Blog,
Summary = "这是一篇测试文章",
Body = "这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章",
ReadCount = 10,
IsDeleted = true,
CreatedTime = DateTime.Now
};
await _dbSet.InsertAsync(article);
Assert.True(article.Id > 0);
}[Fact]
public void BatchInsertTest()
{
var sw = new Stopwatch();
sw.Start();
var tran = _dbContext.BeginTransaction();
for (var i = 0; i < 10000; i++)
{
var article = new Article
{
Title1 = "test" + i,
Category = i % 3 == 1 ? Category.Blog : Category.Movie,
Summary = "这是一篇测试文章",
Body = "这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章",
ReadCount = 10,
IsDeleted = i % 2 == 0,
CreatedTime = DateTime.Now
};
_dbSet.InsertAsync(article, tran);
}
tran.Commit();
sw.Stop();
var s = sw.ElapsedMilliseconds;
Assert.True(s > 0);
}[Fact]
public void DeleteTest()
{
var b = _dbSet.DeleteAsync(3).Result;
Assert.True(b);
}[Fact]
public async void DeleteWhereTest()
{
var b = await _dbSet.Find(m => m.Id > 10).Delete();
Assert.True(b);
}
[Fact]
public async void DeleteWhereTest()
{
var b = await _dbSet.Find(m => m.Id > 10)
.Where(m => m.CreatedTime > DateTime.Now).Delete();
Assert.True(b);
}[Fact]
public async void UpdateTest()
{
var article = await _dbSet.Find().First();
article.Title1 = "修改测试";
var b = await _dbSet.UpdateAsync(article);
Assert.True(b);
}[Fact]
public async void UpdateWhereTest()
{
var b = await _dbSet.Find(m => m.Id == 1000).Update(m => new Article
{
Title1 = "hahahaah",
ReadCount = 1000
});
Assert.True(b);
}[Fact]
public void GetTest()
{
var article = _dbSet.GetAsync(100).Result;
Assert.NotNull(article);
}该方法返回结果集中的第一条数据
[Fact]
public async void GetWehreTest()
{
var article = await _dbSet.Find(m => m.Id > 100).First();
Assert.NotNull(article);
}IDbSet的Find方法会返回一个INetSqlQueryable对象，这个对象是模仿的 EF 里面的IQueryable，虽然有些不伦不类，但是是按照适合自己的方式设计的。
INetSqlQueryable目前包含以下方法：
Where：用于添加过滤条件var query = _dbSet.Find().Where(m => m.Id > 1);WhereIf：根据指定条件来添加过滤条件var query = _dbSet.Find().WhereIf(id > 1, m => m.Id > 200);OrderBy：用于添加排序规则var query = _dbSet.Find(m => m.Id > 200 && m.Id < 1000).OrderBy(m => m.Id, SortType.Desc);Limit：该方法包含两个参数skip和take，标识跳过 skip 条数据，取 take 条数据var query = _dbSet.Find(m => m.Id > 100 && m.Id < 120).Limit(5, 10);Select：选择要返回的列var query = _dbSet.Find().Select(m => new { m.Id, m.Title1 }).Limit(0, 10);以上方法都是用于构造INetSqlQueryable的，下面的方法则是执行：
Max：查询最大值var maxReadCount = _dbSet.Find().Max(m => m.ReadCount).Result;Min：查询最小值var maxReadCount = _dbSet.Find().Min(m => m.ReadCount).Result;Count：查询数量var count = _dbSet.Find(m => m.Id > 1000).Count().Result;Exists：判断是否存在var b = _dbSet.Find(m => m.Id > 1000).Exists().Result;First：获取第一条数据var article = _dbSet.Find(m => m.Id > 100 && m.Id < 120).First().Result;Delete：删除数据var b = _dbSet.Find(m => m.Id > 1000).Delete().Result;Update：更新数据var b = await _dbSet.Find(m => m.Id == 1000).Update(m => new Article
{
Title1 = "hahahaah",
ReadCount = 1000
});ToList：获取结果集var list = await _dbSet.Find(m => m.Id > 100 && m.Id < 120).ToList();[Table("blog_article")]
public class Article : EntityBase
{
[Column("Title")]
public string Title1 { get; set; }
public string Summary { get; set; }
public string Body { get; set; }
public Category Category { get; set; }
public int ReadCount { get; set; }
public bool IsDeleted { get; set; }
public DateTime CreatedTime { get; set; }
}可以通过KeyAttribute来指定某个字段为主键
平时开发时用到伪 DDD 比较多，所以框架提供了一个泛型仓储接口IRepository以及一个抽象实现RepositoryAbstract
/// <summary>
/// 判断是否存在
/// </summary>
/// <param name="where"></param>
/// <param name="transaction"></param>
/// <returns></returns>
Task<bool> ExistsAsync(Expression<Func<TEntity, bool>> where, IDbTransaction transaction = null);
/// <summary>
/// 新增
/// </summary>
/// <param name="entity">实体</param>
/// <param name="transaction">事务</param>
/// <returns></returns>
Task<bool> AddAsync(TEntity entity, IDbTransaction transaction = null);
/// <summary>
/// 批量新增
/// </summary>
/// <param name="list"></param>
/// <param name="transaction"></param>
/// <returns></returns>
Task<bool> AddAsync(List<TEntity> list, IDbTransaction transaction = null);
/// <summary>
/// 删除
/// </summary>
/// <param name="id"></param>
/// <param name="transaction"></param>
/// <returns></returns>
Task<bool> DeleteAsync(dynamic id, IDbTransaction transaction = null);
/// <summary>
/// 更新
/// </summary>
/// <param name="entity">实体</param>
/// <param name="transaction">事务</param>
/// <returns></returns>
Task<bool> UpdateAsync(TEntity entity, IDbTransaction transaction = null);
/// <summary>
/// 根据主键查询
/// </summary>
/// <param name="id"></param>
/// <param name="transaction"></param>
/// <returns></returns>
Task<TEntity> GetAsync(dynamic id, IDbTransaction transaction = null);
/// <summary>
/// 根据表达式查询单条记录
/// </summary>
/// <param name="where"></param>
/// <param name="transaction"></param>
/// <returns></returns>
Task<TEntity> GetAsync(Expression<Func<TEntity,bool>> where, IDbTransaction transaction = null);
/// <summary>
/// 分页查询
/// </summary>
/// <param name="paging">分页</param>
/// <param name="where">过滤条件</param>
/// <param name="transaction">事务</param>
/// <returns></returns>
Task<List<TEntity>> PaginationAsync(Paging paging = null, Expression<Func<TEntity, bool>> where = null, IDbTransaction transaction = null);RepositoryAbstract中包含实体对应的数据集IDbSet以及数据上限为IDbContext
protected readonly IDbSet<TEntity> Db;
protected readonly IDbContext DbContext;
protected RepositoryAbstract(IDbContext dbContext)
{
DbContext = dbContext;
Db = dbContext.Set<TEntity>();
}对于事务，建议使用工作单元IUnitOfWork
public interface IUnitOfWork
{
/// <summary>
/// 打开一个事务
/// </summary>
/// <returns></returns>
IDbTransaction BeginTransaction();
/// <summary>
/// 提交
/// </summary>
/// <returns></returns>
void Commit();
/// <summary>
/// 回滚
/// </summary>
void Rollback();
}项目已经包含了一个实现UnitOfWork
public interface IArticleRepository : IRepository<Article>
{
}private readonly IArticleRepository _repository;
public RepositoryTest()
{
var dbContext = new BlogDbContext(new SQLiteDbContextOptions("Filename=./Database/Test.db"));
_repository = new ArticleRepository(dbContext);
}[Fact]
public async void AddTest()
{
var article = new Article
{
Title1 = "test",
Category = Category.Blog,
Summary = "这是一篇测试文章",
Body = "这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章",
ReadCount = 10,
IsDeleted = true,
CreatedTime = DateTime.Now
};
await _repository.AddAsync(article);
Assert.True(article.Id > 0);
}[Fact]
public void BatchInsertTest()
{
var list = new List<Article>();
for (var i = 0; i < 10000; i++)
{
var article = new Article
{
Title1 = "test" + i,
Category = i % 3 == 1 ? Category.Blog : Category.Movie,
Summary = "这是一篇测试文章",
Body = "这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章这是一篇测试文章",
ReadCount = 10,
IsDeleted = i % 2 == 0,
CreatedTime = DateTime.Now
};
list.Add(article);
}
var sw = new Stopwatch();
sw.Start();
_repository.AddAsync(list);
sw.Stop();
var s = sw.ElapsedMilliseconds;
Assert.True(s > 0);
}[Fact]
public async void DeleteTest()
{
var b = await _repository.DeleteAsync(2);
Assert.True(b);
}[Fact]
public async void UpdateTest()
{
var article = await _repository.GetAsync(2);
article.Title1 = "修改测试";
var b = await _repository.UpdateAsync(article);
Assert.True(b);
}[Fact]
public async void PaginationTest()
{
var paging = new Paging(1, 20);
var list = await _repository.PaginationAsync(paging, m => m.Id > 1000);
Assert.True(paging.TotalCount > 0);
}标签：数据库 key 配置 net 查询 orm框架 操作 删除 最大值
原文地址：https://www.cnblogs.com/oldli/p/9551606.html
