基于Dapper封装
参考DapperExtensions做了业务精简
public async Task<T> GetByIdAsync<T>(long id) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.GetByIdAsync<T>(id); });
}
public async Task<IEnumerable<T>> GetListAsync<T>(List<FieldPredicate> predicates = null) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.GetListAsync<T>(predicates); });
}
public async Task<IEnumerable<T>> GetPageListAsync<T>(int page, int pageSize, List<FieldPredicate> predicates = null, ISort sort = null) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.GetPageListAsync<T>(predicates, page, pageSize, sort: sort); });
}
public async Task<int> InsertAsync<T>(T entity) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.InsertAsync(entity); });
}
public async Task<int> UpdateAsync<T>(T entity) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.UpdateAsync(entity); });
}
public async Task<int> DeleteAsync<T>(long id) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.DeleteAsync<T>(id); });
}
public async Task<int> GetCountAsync<T>(List<FieldPredicate> predicates = null) where T : class, new()
{
return await WithConnectionAsync(async c => { return await c.GetCountAsync<T>(predicates); });
}
github地址：https://github.com/SDaiPeng/Core.SapORM
