交流群：863563315
常規的中小型項目搭建方式一般是三層架構加上mvc與webapi作為一個主要框架，再加上一些第三方庫，例如orm框架（EF、SqlSugar、Dapper等），API文檔工具（Swagger）這些的應用。
接下來我們以一個數據管理平台做為實戰項目來演示三層架構與倉儲模式。
項目Github連接：
https://github.com/FaithGuo/DataManager
一、項目創建
首先搭建以下目錄結構
1. 數據持久接口：IDAL
2.數據持久實現：DAL
3.業務邏輯接口：IBLL
4.業務邏輯實現：BLL
5.業務規則接口：IBussness
6.業務規則實現：Bussness
7.數據實體：Entity
8.模型：Model
9.公共工具：Common
10.頁面UI：Web
其中我將常規三層的業務邏輯層分為了業務邏輯與業務規則兩部分，這樣分層的優點是，便於后期維護；缺點是工作量的增加。
二、第三方庫的加入
項目搭建完了自然就是加入一些第三方框架。
這里我選擇的ORM框架為SqlSugar：
分別在Common、Entity、IDAL與DAL項目依賴項中右鍵-管理NuGet程序包-搜索sqlSugarCore-安裝(此處為5.0.0.9版本)
這個項目中我將sqlSugar數據庫鏈接類放入到Common中，以便未來其他項目中可以直接復用Common項目，所以才在Common中引入sqlSugarCore。
首先在Common中新建BaseDbContext類：
using System; using System.Collections.Generic; using System.Configuration; using System.Text; using Microsoft.Extensions.Configuration; using SqlSugar; namespace DataManager.Common.Db { /// <summary> /// 數據庫操作基類 /// </summary> public class BaseDbContext { public SqlSugarClient Db; /// <summary> /// 構造函數 /// </summary> public BaseDbContext(IConfiguration configuration) { try { //主庫 var connMain = ConfigurationManager.AppSettings["ConnMain"]; //從庫 var connFrom = ConfigurationManager.AppSettings["ConnFrom"]; InitDataBase(connFrom == null ? new List<string> {connMain.ToString()} : new List<string> {connMain.ToString(), connFrom.ToString()}); } catch (Exception ex) { throw new Exception("未配置數據庫連接字符串"); } } /// <summary> /// 構造函數 /// </summary> /// <param name="listConnSettings"> /// 連接字符串配置Key集合,配置多個連接則是讀寫分離 /// </param> public BaseDbContext(List<string> listConnSettings) { try { var listConn = new List<string>(); foreach (var t in listConnSettings) { listConn.Add(ConfigurationManager.ConnectionStrings[t].ToString()); } InitDataBase(listConn); } catch { throw new Exception("未配置數據庫連接字符串"); } } /// <summary> /// 構造函數 /// </summary> /// <param name="serverIp">服務器IP</param> /// <param name="user">用戶名</param> /// <param name="pass">密碼</param> /// <param name="dataBase">數據庫</param> public BaseDbContext(string serverIp, string user, string pass, string dataBase) { InitDataBase(new List<string> {$"server={serverIp};user id={user};password={pass};persistsecurityinfo=True;database={dataBase}"}); } /// <summary> /// 初始化數據庫連接 /// </summary> /// <param name="listConn">連接字符串</param> private void InitDataBase(List<string> listConn) { var connStr = ""; //主庫 var slaveConnectionConfigs = new List<SlaveConnectionConfig>(); //從庫集合 for (var i = 0; i < listConn.Count; i++) { if (i == 0) { connStr = listConn[i]; //主數據庫連接 } else { slaveConnectionConfigs.Add(new SlaveConnectionConfig() { HitRate = i * 2, ConnectionString = listConn[i] }); } } //如果配置了 SlaveConnectionConfigs那就是主從模式,所有的寫入刪除更新都走主庫，查詢走從庫， //事務內都走主庫，HitRate表示權重 值越大執行的次數越高，如果想停掉哪個連接可以把HitRate設為0 var ctx = new ConfigureExternalServices(); Db = new SqlSugarClient(new ConnectionConfig() { ConnectionString = connStr, DbType = DbType.SqlServer, IsAutoCloseConnection = true, SlaveConnectionConfigs = slaveConnectionConfigs }); Db.Ado.CommandTimeOut = 30000; //設置超時時間 Db.Aop.OnLogExecuted = (sql, pars) => //SQL執行完事件 { }; Db.Aop.OnLogExecuting = (sql, pars) => //SQL執行前事件 { }; Db.Aop.OnError = (exp) => //執行SQL 錯誤事件 { throw new Exception("出錯SQL：" + exp.Sql + "\r\n" + exp.Message); }; Db.Aop.OnExecutingChangeSql = (sql, pars) => //SQL執行前 可以修改SQL { return new KeyValuePair<string, SugarParameter[]>(sql, pars); }; } public SqlSugarClient GetClient() => Db; } }
查詢排序條件類：
using System; using System.Collections.Generic; using System.Text; using SqlSugar; namespace DataManager.Common { /// <summary> /// 排序類型 /// </summary> public enum OrderSequence { Asc, Desc } /// <summary> /// 排序枚舉 /// </summary> public class OrderByClause { public string Sort { get; set; } public OrderSequence Order { get; set; } } /// <summary> /// 查詢條件 /// </summary> public class QueryDescriptor { /// <summary> /// 行數 /// </summary> public int PageSize { get; set; } /// <summary> /// 頁碼 /// </summary> public int PageIndex { get; set; } /// <summary> /// 排序 /// </summary> public List<OrderByClause> OrderBys { get; set; } /// <summary> /// 條件 /// </summary> public List<ConditionalModel> Conditions { get; set; } } }
在IDAL中新建倉儲基類接口IBaseRepository：
using System; using System.Collections.Generic; using System.Data; using System.Linq.Expressions; using DataManager.Common; using SqlSugar; namespace DataManager.IDAL { public interface IBaseRepository<T> : IDisposable where T : class, new() { #region 事務 /// <summary> /// 初始化事務 /// </summary> /// <param name="level"></param> void BeginTran(IsolationLevel level = IsolationLevel.ReadCommitted); /// <summary> /// 完成事務 /// </summary> void CommitTran(); /// <summary> /// 完成事務 /// </summary> void RollbackTran(); #endregion #region 新增 /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock">是否加鎖</param> /// <returns>操作影響的行數</returns> int Add<T>(T entity, bool isLock = false) where T : class, new(); /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entitys">泛型集合</param> /// <param name="isLock">是否加鎖</param> /// <returns>操作影響的行數</returns> int Add<T>(List<T> entitys, bool isLock = false) where T : class, new(); /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock">是否加鎖</param> /// <returns>返回實體</returns> T AddReturnEntity<T>(T entity, bool isLock = false) where T : class, new(); /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock">是否加鎖</param> /// <returns>返回bool, 並將identity賦值到實體</returns> bool AddReturnBool<T>(T entity, bool isLock = false) where T : class, new(); /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entitys">泛型集合</param> /// <param name="isLock">是否加鎖</param> /// <returns>返回bool, 並將identity賦值到實體</returns> bool AddReturnBool<T>(List<T> entitys, bool isLock = false) where T : class, new(); #endregion #region 修改 /// <summary> /// 修改數據源 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <returns>數據源</returns> IUpdateable<T> Updateable<T>() where T : class, new(); /// <summary> /// 修改（主鍵是更新條件） /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> int Update<T>(T entity, bool isLock = false) where T : class, new(); /// <summary> /// 修改 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="update"> 字段集合 </param> /// <param name="where"> 條件 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> int Update<T>(Expression<Func<T, T>> update, Expression<Func<T, bool>> where, bool isLock = false) where T : class, new(); /// <summary> /// 修改（主鍵是更新條件） /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entitys">泛型集合</param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> int Update<T>(List<T> entitys, bool isLock = false) where T : class, new(); #endregion #region 刪除 /// <summary> /// 刪除（主鍵是條件） /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> int Delete<T>(T entity, bool isLock = false) where T : class, new(); /// <summary> /// 刪除（主鍵是條件） /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="where"> 條件 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> int Delete<T>(Expression<Func<T, bool>> where, bool isLock = false) where T : class, new(); #endregion #region 查詢 /// <summary> /// 查詢數據源 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <returns>數據源</returns> ISugarQueryable<T> Queryable<T>() where T : class, new(); /// <summary> /// 查詢 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns></returns> T Query<T>(Expression<Func<T, bool>> whereLambda) where T : class, new(); /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns>實體</returns> List<T> QueryList<T>(Expression<Func<T, bool>> whereLambda) where T : class, new(); /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="sql">sql</param> /// <returns>實體</returns> List<T> QueryList<T>(string sql) where T : class, new(); /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns>實體</returns> DataTable QueryDataTable<T>(Expression<Func<T, bool>> whereLambda) where T : class, new(); /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="sql">sql</param> /// <returns>實體</returns> DataTable QueryDataTable<T>(string sql) where T : class, new(); /// <summary> /// 分頁查詢 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="query">查詢條件</param> /// <param name="totalCount">總行數</param> /// <returns>實體</returns> List<T> QueryPageList<T>(QueryDescriptor query, out int totalCount) where T : class, new(); /// <summary> /// 分頁查詢 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="query">查詢條件</param> /// <param name="totalCount">總行數</param> /// <returns>實體</returns> DataTable QueryDataTablePageList<T>(QueryDescriptor query, out int totalCount) where T : class, new(); /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns>Json</returns> string QueryJson<T>(Expression<Func<T, bool>> whereLambda) where T : class, new(); /// <summary> /// 查詢存儲過程 /// </summary> /// <param name="procedureName">存儲過程名稱</param> /// <param name="parameters">參數</param> DataTable QueryProcedure(string procedureName, List<SugarParameter> parameters); /// <summary> /// 查詢前多少條數據 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <param name="num">數量</param> /// <returns></returns> List<T> Take<T>(Expression<Func<T, bool>> whereLambda, int num) where T : class, new(); /// <summary> /// 查詢單條數據 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns></returns> T First<T>(Expression<Func<T, bool>> whereLambda) where T : class, new(); /// <summary> /// 是否存在 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns></returns> bool IsExist<T>(Expression<Func<T, bool>> whereLambda) where T : class, new(); /// <summary> /// 合計 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> int Sum<T>(string field) where T : class, new(); /// <summary> /// 最大值 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> object Max<T>(string field) where T : class, new(); /// <summary> /// 最小值 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> object Min<T>(string field) where T : class, new(); /// <summary> /// 平均值 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> int Avg<T>(string field) where T : class, new(); #endregion } }
在DAL中新建倉儲基類的實現，在sqlSugar框架中，作者直接將SqlSugarClient默認單例，所以此處不用再做處理可以直接在倉儲基類中繼承BaseDbContext方便直接操作數據庫：
using System; using System.Collections.Generic; using System.Data; using System.Linq.Expressions; using System.Text; using DataManager.Common; using DataManager.Common.Db; using DataManager.IDAL; using Microsoft.Extensions.Configuration; using SqlSugar; namespace DataManager.DAL { public class BaseService<T> : BaseDbContext, IBaseRepository<T> where T : class, new() { public SqlSugarClient DbContext; public BaseService(IConfiguration configuration) : base(configuration) { DbContext = GetClient(); } #region 事務 /// <summary> /// 初始化事務 /// </summary> /// <param name="level"></param> public void BeginTran(IsolationLevel level = IsolationLevel.ReadCommitted) { DbContext.Ado.BeginTran(IsolationLevel.Unspecified); } /// <summary> /// 完成事務 /// </summary> public void CommitTran() { DbContext.Ado.CommitTran(); } /// <summary> /// 完成事務 /// </summary> public void RollbackTran() { DbContext.Ado.RollbackTran(); } #endregion #region 新增 /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock">是否加鎖</param> /// <returns>操作影響的行數</returns> public int Add<T>(T entity, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Insertable(entity).With(SqlWith.UpdLock).ExecuteCommand() : DbContext.Insertable(entity).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entitys">泛型集合</param> /// <param name="isLock">是否加鎖</param> /// <returns>操作影響的行數</returns> public int Add<T>(List<T> entitys, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Insertable(entitys).With(SqlWith.UpdLock).ExecuteCommand() : DbContext.Insertable(entitys).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock">是否加鎖</param> /// <returns>返回實體</returns> public T AddReturnEntity<T>(T entity, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Insertable(entity).With(SqlWith.UpdLock).ExecuteReturnEntity() : DbContext.Insertable(entity).ExecuteReturnEntity(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock">是否加鎖</param> /// <returns>返回bool, 並將identity賦值到實體</returns> public bool AddReturnBool<T>(T entity, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Insertable(entity).With(SqlWith.UpdLock).ExecuteCommandIdentityIntoEntity() : DbContext.Insertable(entity).ExecuteCommandIdentityIntoEntity(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 新增 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entitys">泛型集合</param> /// <param name="isLock">是否加鎖</param> /// <returns>返回bool, 並將identity賦值到實體</returns> public bool AddReturnBool<T>(List<T> entitys, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Insertable(entitys).With(SqlWith.UpdLock).ExecuteCommandIdentityIntoEntity() : DbContext.Insertable(entitys).ExecuteCommandIdentityIntoEntity(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } #endregion #region 修改 /// <summary> /// 修改數據源 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <returns>數據源</returns> public IUpdateable<T> Updateable<T>() where T : class, new() { return DbContext.Updateable<T>(); } /// <summary> /// 修改（主鍵是更新條件） /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> public int Update<T>(T entity, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Updateable(entity).With(SqlWith.UpdLock).ExecuteCommand() : DbContext.Updateable(entity).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 修改 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="update"> 實體對象 </param> /// <param name="where"> 條件 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> public int Update<T>(Expression<Func<T, T>> update, Expression<Func<T, bool>> where, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Updateable<T>().SetColumns(update).Where(where).With(SqlWith.UpdLock) .ExecuteCommand() : DbContext.Updateable<T>().SetColumns(update).Where(where).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 修改（主鍵是更新條件） /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entitys"> 實體對象集合 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> public int Update<T>(List<T> entitys, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Updateable(entitys).With(SqlWith.UpdLock).ExecuteCommand() : DbContext.Updateable(entitys).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } #endregion #region 刪除 /// <summary> /// 刪除 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="entity"> 實體對象 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> public int Delete<T>(T entity, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Deleteable(entity).With(SqlWith.UpdLock).ExecuteCommand() : DbContext.Deleteable(entity).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } /// <summary> /// 刪除 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="where"> 條件 </param> /// <param name="isLock"> 是否加鎖 </param> /// <returns>操作影響的行數</returns> public int Delete<T>(Expression<Func<T, bool>> where, bool isLock = false) where T : class, new() { try { var result = isLock ? DbContext.Deleteable<T>().Where(where).With(SqlWith.UpdLock).ExecuteCommand() : DbContext.Deleteable<T>().Where(where).ExecuteCommand(); return result; } catch (Exception ex) { RollbackTran(); throw new Exception(ex.Message); } } #endregion #region 查詢 /// <summary> /// 查詢數據源 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <returns>數據源</returns> public ISugarQueryable<T> Queryable<T>() where T : class, new() { return DbContext.Queryable<T>(); } /// <summary> /// 查詢 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns></returns> public T Query<T>(Expression<Func<T, bool>> whereLambda) where T : class, new() { return DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).First(); var str = DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).ToSql(); Console.WriteLine(str); return null; } /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns>實體</returns> public List<T> QueryList<T>(Expression<Func<T, bool>> whereLambda) where T : class, new() { return DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).ToList(); } /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="sql">sql</param> /// <returns>實體</returns> public List<T> QueryList<T>(string sql) where T : class, new() { return DbContext.SqlQueryable<T>(sql).With(SqlWith.NoLock).ToList(); } /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns>實體</returns> public DataTable QueryDataTable<T>(Expression<Func<T, bool>> whereLambda) where T : class, new() { return DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).ToDataTable(); } /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="sql">sql</param> /// <returns>實體</returns> public DataTable QueryDataTable<T>(string sql) where T : class, new() { return DbContext.SqlQueryable<T>(sql).With(SqlWith.NoLock).ToDataTable(); } /// <summary> /// 分頁查詢 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="query">查詢條件</param> /// <param name="totalCount">總行數</param> /// <returns>實體</returns> public List<T> QueryPageList<T>(QueryDescriptor query, out int totalCount) where T : class, new() { if (query == null) { throw new ArgumentNullException(nameof(query)); } var listDatas = DbContext.Queryable<T>(); if (query.Conditions != null) { var conds = ParseCondition(query.Conditions); listDatas = listDatas.Where(conds); } if (query.OrderBys != null) { var orderBys = ParseOrderBy(query.OrderBys); listDatas = listDatas.OrderBy(orderBys); } totalCount = 0; var datas = listDatas.ToPageList(query.PageIndex, query.PageSize, ref totalCount); return datas; } /// <summary> /// 分頁查詢 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="query">查詢條件</param> /// <param name="totalCount">總行數</param> /// <returns>DataTable</returns> public DataTable QueryDataTablePageList<T>(QueryDescriptor query, out int totalCount) where T : class, new() { if (query == null) { throw new ArgumentNullException(nameof(query)); } var listDatas = DbContext.Queryable<T>(); if (query.Conditions != null) { var conds = ParseCondition(query.Conditions); listDatas = listDatas.Where(conds); } if (query.OrderBys != null) { var orderBys = ParseOrderBy(query.OrderBys); listDatas = listDatas.OrderBy(orderBys); } totalCount = 0; var datas = listDatas.ToDataTablePage(query.PageIndex, query.PageSize, ref totalCount); return datas; } /// <summary> /// 查詢集合 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型)</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns>Json</returns> public string QueryJson<T>(Expression<Func<T, bool>> whereLambda) where T : class, new() { return DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).ToJson(); } /// <summary> /// 查詢存儲過程 /// </summary> /// <param name="procedureName">存儲過程名稱</param> /// <param name="parameters">參數</param>re public DataTable QueryProcedure(string procedureName, List<SugarParameter> parameters) { var datas = DbContext.Ado.UseStoredProcedure().GetDataTable(procedureName, parameters); return datas; } /// <summary> /// 查詢前多少條數據 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <param name="num">數量</param> /// <returns></returns> public List<T> Take<T>(Expression<Func<T, bool>> whereLambda, int num) where T : class, new() { var datas = DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).Take(num).ToList(); return datas; } /// <summary> /// 查詢單條數據 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns></returns> public T First<T>(Expression<Func<T, bool>> whereLambda) where T : class, new() { var datas = DbContext.Queryable<T>().With(SqlWith.NoLock).Where(whereLambda).First(); return datas; } /// <summary> /// 是否存在 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="whereLambda">查詢表達式</param> /// <returns></returns> public bool IsExist<T>(Expression<Func<T, bool>> whereLambda) where T : class, new() { var datas = DbContext.Queryable<T>().Any(whereLambda); return datas; } /// <summary> /// 合計 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> public int Sum<T>(string field) where T : class, new() { var datas = DbContext.Queryable<T>().Sum<int>(field); return datas; } /// <summary> /// 最大值 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> public object Max<T>(string field) where T : class, new() { var datas = DbContext.Queryable<T>().Max<object>(field); return datas; } /// <summary> /// 最小值 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> public object Min<T>(string field) where T : class, new() { var datas = DbContext.Queryable<T>().Min<object>(field); return datas; } /// <summary> /// 平均值 /// </summary> /// <typeparam name="T">泛型參數(集合成員的類型</typeparam> /// <param name="field">字段</param> /// <returns></returns> public int Avg<T>(string field) where T : class, new() { var datas = DbContext.Queryable<T>().Avg<int>(field); return datas; } #endregion #region 私有方法 /// <summary> /// 查詢條件轉換 /// </summary> /// <param name="contitons">查詢條件</param> /// <returns></returns> private List<IConditionalModel> ParseCondition(List<ConditionalModel> contitons) { var conds = new List<IConditionalModel>(); foreach (var con in contitons) { if (con.FieldName.Contains(",")) { conds.Add(ParseKeyOr(con)); } else { conds.Add(new ConditionalModel() { FieldName = con.FieldName, ConditionalType = con.ConditionalType, FieldValue = con.FieldValue }); } } return conds; } /// <summary> /// 轉換Or條件 /// </summary> /// <param name="condition"></param> /// <returns></returns> private ConditionalCollections ParseKeyOr(ConditionalModel condition) { var objectKeys = condition.FieldName.Split(','); var conditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>(); foreach (var objKey in objectKeys) { var cond = new KeyValuePair<WhereType, ConditionalModel> (WhereType.Or, new ConditionalModel() { FieldName = objKey, ConditionalType = condition.ConditionalType, FieldValue = condition.FieldValue }); conditionalList.Add(cond); } return new ConditionalCollections { ConditionalList = conditionalList }; } /// <summary> /// 排序轉換 /// </summary> /// <param name="orderBys">排序</param> /// <returns></returns> private string ParseOrderBy(List<OrderByClause> orderBys) { var conds = ""; foreach (var con in orderBys) { if (con.Order == OrderSequence.Asc) { conds += $"{con.Sort} asc,"; } else if (con.Order == OrderSequence.Desc) { conds += $"{con.Sort} desc,"; } } return conds.TrimEnd(','); } #endregion /// <summary> /// 處理 /// </summary> public void Dispose() { RollbackTran(); DbContext.Close(); } } }
至此sqlSugar前期工作完成，后期新增的實體新建對應的倉庫，直接繼承BaseRepository。下一篇我會將Swagger加入到項目中。