一、SqlSugar介紹及分析
SqlSugar是一款 老牌 .NET 開源ORM框架,連接DB特別方便
支持?jǐn)?shù)據(jù)庫:MySql、SqlServer、Sqlite、Oracle 、 postgresql、達(dá)夢、人大金倉
官方文檔:http://www.donet5.com/Home/Doc
SqlSugar的優(yōu)點(diǎn):
1、高性能:不夸張的說,去掉Sql在數(shù)據(jù)庫執(zhí)行的時(shí)間,SqlSugar是EF數(shù)倍性能,另外在批量操作和一對多查詢上也有不錯的SQL優(yōu)化;
2、高擴(kuò)展性 :支持自定義拉姆達(dá)函數(shù)解析、擴(kuò)展數(shù)據(jù)類型、支持自定義實(shí)體特性,外部緩存等;
3、穩(wěn)定性和技術(shù)支持:? 雖然不是官方ORM, 但在穩(wěn)定性上也是有著數(shù)年用戶積累,如果遇到問題可以在GITHUB提出來,會根據(jù)緊急度定期解決;
4、功能全面:雖然SqlSugar小巧可功能并不遜色于EF框架
5、創(chuàng)新、持續(xù)更新 ,向下兼容
二、SqlSugar項(xiàng)目中的使用
1、包的引用:
?2、全局引用:
3、接口中常用方法封裝
1)、ISqlSugarRepository接口封裝
public interface ISqlSugarRepository<TEntity> : IBaseRepository where TEntity : class
{
/// <summary>
///
/// </summary>
ISqlSugarClient Db { get; }
/// <summary>
/// 執(zhí)行查詢SQL語句
/// 只支持查詢操作,并且支持拉姆達(dá)分頁
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
Task<List<TEntity>> ExecuteSql(string sql);
/// <summary>
/// 通過Ado方法執(zhí)行SQL語句
/// 支持任何SQL語句
/// </summary>
/// <param name="sql"></param>
/// <param name="whereObj"></param>
/// <returns></returns>
Task<List<TEntity>> ExecuteAllSql(string sql, object whereObj = null);
/// <summary>
/// 插入實(shí)體
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
Task<int> Add(TEntity model);
/// <summary>
/// 批量插入實(shí)體
/// </summary>
/// <param name="listEntity"></param>
/// <returns></returns>
Task<int> Add(List<TEntity> listEntity);
/// <summary>
/// 根據(jù)實(shí)體刪除數(shù)據(jù)
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
Task<bool> Delete(TEntity model);
/// <summary>
/// 根據(jù)實(shí)體集合批量刪除數(shù)據(jù)
/// </summary>
/// <param name="models"></param>
/// <returns></returns>
Task<bool> Delete(List<TEntity> models);
/// <summary>
/// 根據(jù)ID刪除數(shù)據(jù)
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
Task<bool> DeleteById(object id);
/// <summary>
/// 根據(jù)IDs批量刪除數(shù)據(jù)
/// </summary>
/// <param name="ids"></param>
/// <returns></returns>
Task<bool> DeleteByIds(List<object> ids);
/// <summary>
/// 更新實(shí)體
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
Task<bool> Update(TEntity model);
/// <summary>
/// 批量更新實(shí)體
/// </summary>
/// <param name="listEntity"></param>
/// <returns></returns>
Task<int> Update(List<TEntity> listEntity);
/// <summary>
/// 根據(jù)ID查詢一條數(shù)據(jù)
/// </summary>
/// <param name="objId"></param>
/// <returns></returns>
Task<TEntity> GetById(object objId);
/// <summary>
/// 根據(jù)條件查詢數(shù)據(jù)是否存在
/// </summary>
/// <param name="whereExpression"></param>
/// <returns></returns>
Task<bool> GetAnyByFilter(Expression<Func<TEntity, bool>> whereExpression);
/// <summary>
/// 根據(jù)IDs查詢數(shù)據(jù)
/// </summary>
/// <param name="lstIds"></param>
/// <returns></returns>
Task<List<TEntity>> GetByIds(List<object> lstIds);
/// <summary>
/// 根據(jù)條件查詢一條數(shù)據(jù)
/// </summary>
/// <param name="whereExpression"></param>
/// <returns></returns>
Task<TEntity> GetSingleByFilter(Expression<Func<TEntity, bool>> whereExpression);
/// <summary>
/// 查詢所有數(shù)據(jù)
/// </summary>
/// <returns></returns>
Task<List<TEntity>> Get();
/// <summary>
/// 查詢數(shù)據(jù)列表
/// </summary>
/// <param name="whereExpression">條件表達(dá)式</param>
/// <returns>數(shù)據(jù)列表</returns>
Task<List<TEntity>> Get(Expression<Func<TEntity, bool>> whereExpression);
/// <summary>
/// 查詢數(shù)據(jù)列表
/// </summary>
/// <param name="whereExpression">條件表達(dá)式</param>
/// <param name="orderByExpression">排序表達(dá)式</param>
/// <param name="isAsc">是否升序排序</param>
/// <returns></returns>
Task<List<TEntity>> Get(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, object>> orderByExpression = null, bool isAsc = true);
/// <summary>
/// 分頁查詢
/// </summary>
/// <param name="selector"></param>
/// <param name="whereExpression"></param>
/// <param name="intPageIndex"></param>
/// <param name="intPageSize"></param>
/// <param name="orderDescSelector"></param>
/// <returns></returns>
Task<PaginatedViewModel<TResult>> Get<TResult>(Expression<Func<TEntity, TResult>> selector, Expression<Func<TEntity, bool>> whereExpression, int intPageIndex, int intPageSize, Expression<Func<TEntity, object>> orderDescSelector = null);
/// <summary>
/// 分頁查詢
/// </summary>
/// <param name="selector"></param>
/// <param name="whereExpression"></param>
/// <param name="intPageIndex"></param>
/// <param name="intPageSize"></param>
/// <param name="orderDescSelector"></param>
/// <returns></returns>
Task<PaginatedViewModel<TEntity>> Get(Expression<Func<TEntity, bool>> whereExpression, int intPageIndex, int intPageSize, Expression<Func<TEntity, object>> orderDescSelector = null);
}
public interface IBaseRepository { }
?事務(wù)接口:
public interface IUnitOfWork
{
/// <summary>
///
/// </summary>
/// <returns></returns>
SqlSugarClient GetDbClient();
/// <summary>
///
/// </summary>
void BeginTran();
/// <summary>
///
/// </summary>
void CommitTran();
/// <summary>
///
/// </summary>
void RollbackTran();
}
2)、SqlSugarRepository接口實(shí)現(xiàn)
/// <summary>
///
/// </summary>
/// <typeparam name="TEntity"></typeparam>
public class SqlSugarRepository<TEntity> : ISqlSugarRepository<TEntity> where TEntity : class, new()
{
private readonly SqlSugarClient _dbBase;
public ISqlSugarClient Db
{
get { return _dbBase; }
}
/// <summary>
///
/// </summary>
/// <param name="unitOfWork"></param>
public SqlSugarRepository(IUnitOfWork unitOfWork)
{
_dbBase = unitOfWork.GetDbClient();
}
/// <summary>
/// 執(zhí)行查詢SQL語句
/// 只支持查詢操作,并且支持拉姆達(dá)分頁
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public async Task<List<TEntity>> ExecuteSql(string sql)
{
return await Db.SqlQueryable<TEntity>(sql).ToListAsync();
}
/// <summary>
/// 通過Ado方法執(zhí)行SQL語句
/// 支持任何SQL語句
/// </summary>
/// <param name="sql"></param>
/// <param name="whereObj">參數(shù)</param>
/// <returns></returns>
public async Task<List<TEntity>> ExecuteAllSql(string sql, object whereObj = null)
{
return await Task.Run(() => Db.Ado.SqlQuery<TEntity>(sql, whereObj));
}
/// <summary>
/// 根據(jù)ID查詢一條數(shù)據(jù)
/// </summary>
/// <param name="objId"></param>
/// <returns></returns>
public async Task<TEntity> GetById(object objId)
{
return await Db.Queryable<TEntity>().In(objId).SingleAsync();
}
/// <summary>
/// 根據(jù)IDs查詢數(shù)據(jù)
/// </summary>
/// <param name="lstIds">id列表</param>
/// <returns>數(shù)據(jù)實(shí)體列表</returns>
public async Task<List<TEntity>> GetByIds(List<object> lstIds)
{
return await Db.Queryable<TEntity>().In(lstIds).ToListAsync();
}
/// <summary>
/// 插入實(shí)體
/// </summary>
/// <param name="entity">實(shí)體類</param>
/// <returns></returns>
public async Task<int> Add(TEntity entity)
{
var insert = Db.Insertable(entity);
return await insert.ExecuteCommandAsync();
}
/// <summary>
/// 批量插入實(shí)體
/// </summary>
/// <param name="listEntity">實(shí)體集合</param>
/// <returns>影響行數(shù)</returns>
public async Task<int> Add(List<TEntity> listEntity)
{
return await Db.Insertable(listEntity.ToArray()).ExecuteCommandAsync();
}
/// <summary>
/// 更新實(shí)體
/// </summary>
/// <param name="entity">實(shí)體類</param>
/// <returns></returns>
public async Task<bool> Update(TEntity entity)
{
return await Db.Updateable(entity).ExecuteCommandHasChangeAsync();
}
/// <summary>
/// 批量更新實(shí)體
/// </summary>
/// <param name="listEntity">實(shí)體類</param>
/// <returns></returns>
public async Task<int> Update(List<TEntity> listEntity)
{
return await Db.Updateable(listEntity).ExecuteCommandAsync();
}
/// <summary>
/// 根據(jù)實(shí)體刪除數(shù)據(jù)
/// </summary>
/// <param name="entity">實(shí)體</param>
/// <returns></returns>
public async Task<bool> Delete(TEntity entity)
{
return await Db.Deleteable(entity).ExecuteCommandHasChangeAsync();
}
/// <summary>
/// 根據(jù)實(shí)體集合批量刪除數(shù)據(jù)
/// </summary>
/// <param name="models"></param>
/// <returns></returns>
public async Task<bool> Delete(List<TEntity> models)
{
return await Db.Deleteable(models).ExecuteCommandHasChangeAsync();
}
/// <summary>
/// 根據(jù)ID刪除數(shù)據(jù)
/// </summary>
/// <param name="id">ID</param>
/// <returns></returns>
public async Task<bool> DeleteById(object id)
{
return await Db.Deleteable<TEntity>(id).ExecuteCommandHasChangeAsync();
}
/// <summary>
/// 根據(jù)IDs批量刪除數(shù)據(jù)
/// </summary>
/// <param name="ids">ID集合</param>
/// <returns></returns>
public async Task<bool> DeleteByIds(List<object> ids)
{
return await Db.Deleteable<TEntity>().In(ids).ExecuteCommandHasChangeAsync();
}
/// <summary>
/// 根據(jù)條件查詢數(shù)據(jù)是否存在
/// </summary>
/// <param name="whereExpression"></param>
/// <returns></returns>
public async Task<bool> GetAnyByFilter(Expression<Func<TEntity, bool>> whereExpression)
{
return await Db.Queryable<TEntity>().AnyAsync(whereExpression);
}
/// <summary>
/// 根據(jù)條件查詢一條數(shù)據(jù)
/// </summary>
/// <param name="whereExpression"></param>
/// <returns></returns>
public async Task<TEntity> GetSingleByFilter(Expression<Func<TEntity, bool>> whereExpression)
{
return await Db.Queryable<TEntity>().FirstAsync(whereExpression);
}
/// <summary>
/// 查詢所有數(shù)據(jù)
/// </summary>
/// <returns></returns>
public async Task<List<TEntity>> Get()
{
return await Db.Queryable<TEntity>().ToListAsync();
}
/// <summary>
/// 查詢數(shù)據(jù)列表----按條件表達(dá)式
/// </summary>
/// <param name="whereExpression">條件表達(dá)式</param>
/// <returns>數(shù)據(jù)列表</returns>
public async Task<List<TEntity>> Get(Expression<Func<TEntity, bool>> whereExpression)
{
return await Db.Queryable<TEntity>().WhereIF(whereExpression != null, whereExpression).ToListAsync();
}
/// <summary>
/// 查詢數(shù)據(jù)列表----按條件表達(dá)式、排序表達(dá)式
/// </summary>
/// <param name="whereExpression">條件表達(dá)式</param>
/// <param name="orderByExpression">排序表達(dá)式</param>
/// <param name="isAsc">是否升序排序</param>
/// <returns></returns>
public async Task<List<TEntity>> Get(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, object>> orderByExpression = null, bool isAsc = true)
{
return await Db.Queryable<TEntity>().OrderByIF(orderByExpression != null, orderByExpression, isAsc ? OrderByType.Asc : OrderByType.Desc).WhereIF(whereExpression != null, whereExpression).ToListAsync();
}
/// <summary>
/// 分頁查詢
/// </summary>
/// <param name="selector"></param>
/// <param name="whereExpression">條件表達(dá)式</param>
/// <param name="intPageIndex">頁碼</param>
/// <param name="intPageSize">頁大小</param>
/// <param name="orderDescSelector">排序字段</param>
/// <returns></returns>
public async Task<PaginatedViewModel<TResult>> Get<TResult>(Expression<Func<TEntity, TResult>> selector, Expression<Func<TEntity, bool>> whereExpression, int intPageIndex, int intPageSize, Expression<Func<TEntity, object>> orderDescSelector = null)
{
var query = Db.Queryable<TEntity>().WhereIF(whereExpression != null, whereExpression);
query = query.OrderByIF(orderDescSelector != null, orderDescSelector);
var totalCount = 0;
var results = query.Select(selector).ToPageList(intPageIndex, intPageSize, ref totalCount).ToList();
var basePage = new PaginatedViewModel<TResult>(intPageIndex, intPageSize, totalCount, results);
return await Task.FromResult(basePage);
}
/// <summary>
/// 分頁查詢
/// </summary>
/// <param name="selector"></param>
/// <param name="whereExpression">條件表達(dá)式</param>
/// <param name="intPageIndex">頁碼</param>
/// <param name="intPageSize">頁大小</param>
/// <param name="orderDescSelector">排序字段</param>
/// <returns></returns>
public async Task<PaginatedViewModel<TEntity>> Get(Expression<Func<TEntity, bool>> whereExpression, int intPageIndex, int intPageSize, Expression<Func<TEntity, object>> orderDescSelector = null)
{
var query = Db.Queryable<TEntity>().WhereIF(whereExpression != null, whereExpression);
query = query.OrderByIF(orderDescSelector != null, orderDescSelector);
var totalCount = 0;
var results = query.ToPageList(intPageIndex, intPageSize, ref totalCount).ToList();
var basePage = new PaginatedViewModel<TEntity>(intPageIndex, intPageSize, totalCount, results);
return await Task.FromResult(basePage);
}
}
事務(wù)接口實(shí)現(xiàn):
public class UnitOfWork : IUnitOfWork, IDisposable
{
private readonly ISqlSugarClient _sqlSugarClient;
private bool _disposed = false;
public UnitOfWork(ISqlSugarClient sqlSugarClient)
{
_sqlSugarClient = sqlSugarClient;
}
public SqlSugarClient GetDbClient()
{
return (SqlSugarClient)_sqlSugarClient;
}
public void BeginTran()
{
GetDbClient().BeginTran();
}
public void CommitTran()
{
try
{
GetDbClient().CommitTran();
Dispose();
}
catch
{
GetDbClient().RollbackTran();
Dispose();
}
}
public void RollbackTran()
{
GetDbClient().RollbackTran();
Dispose();
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
public void Dispose(bool disposing)
{
if (_disposed) return;
if (disposing)
{
GetDbClient()?.Dispose();
}
_disposed = true;
}
~UnitOfWork() => Dispose(false);
}
分頁查詢模型:
public class PaginatedViewModel<T>
{
public int PageIndex { get; private set; }
public int PageSize { get; private set; }
public long Count { get; private set; }
public IEnumerable<T> Data { get; private set; }
public PaginatedViewModel(int pageIndex, int pageSize, long count, IEnumerable<T> data)
{
PageIndex = pageIndex;
PageSize = pageSize;
Count = count;
Data = data;
}
}
3、SqlSugar在項(xiàng)目中的使用
1)、定義及初始化
private readonly ISqlSugarRepository<StatEquipmentInfo> _statEquipmentInfoRepository;
public GetStatusInfoHandler(ISqlSugarRepository<StatEquipmentInfo> statEquipmentInfoRepository)
{
_statEquipmentInfoRepository = statEquipmentInfoRepository;
}
2)、使用文章來源:http://www.zghlxwxcb.cn/news/detail-401893.html
var infos = await _statEquipmentInfoRepository.GetSingleByFilter(s => s.EId == requestDtoModel.EId && s.StatDate == requestDtoModel.StatDate && s.ETypeId == requestDtoModel.ETypeId);
其他函數(shù)的使用,按照接口規(guī)范要求使用即可,在這里就不過多贅敘了。文章來源地址http://www.zghlxwxcb.cn/news/detail-401893.html
到了這里,關(guān)于C# ORM模式之 SqlSugar使用的文章就介紹完了。如果您還想了解更多內(nèi)容,請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!