229 lines
8.6 KiB
C#
229 lines
8.6 KiB
C#
using SqlSugar;
|
||
using System.Data;
|
||
using System.Linq.Expressions;
|
||
using Yi.Framework.Common.Attribute;
|
||
using Yi.Framework.Common.Models;
|
||
using Yi.Framework.Model.Models;
|
||
using Yi.Framework.Model.Query;
|
||
|
||
/***这里面写的代码不会给覆盖,如果要重新生成请删除 Repository.cs ***/
|
||
namespace Yi.Framework.Repository
|
||
{
|
||
/// <summary>
|
||
/// 仓储模式
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
[AppService]
|
||
public class Repository<T> : SimpleClient<T>, IRepository<T> where T : class, new()
|
||
{
|
||
|
||
public ISugarQueryable<T> _DbQueryable { get { return base.Context.Queryable<T>(); } set { } }
|
||
|
||
public ISqlSugarClient _Db { get { return base.Context; } set { } }
|
||
/// <summary>
|
||
/// 构造函数
|
||
/// </summary>
|
||
/// <param name="context"></param>
|
||
public Repository(ISqlSugarClient context) : base(context)//注意这里要有默认值等于null
|
||
{
|
||
////开始Saas分库！
|
||
////单个公共基础库+多个租户业务库
|
||
|
||
////1:先判断操作对应实体上是否存在租户特性，如果存在说明是公共库
|
||
//var anyTenant = typeof(T).GetCustomAttributes(false).Any(a => a.GetType().Equals(typeof(TenantAttribute)));
|
||
|
||
////如果是公共库，直接使用默认库即可
|
||
//if (anyTenant)
|
||
//{
|
||
// base.Context = _Db.AsTenant().GetConnectionScope("0");
|
||
//}
|
||
////如果不是公共库
|
||
//else
|
||
//{
|
||
// //2:根据上下文对象获取用户的租户id、数据库连接串及用户信息
|
||
// string tenantId = "获取用户的租户id";
|
||
// string connection = "获取用户信息中的数据库连接字符串";
|
||
|
||
// //如果该租户未添加到db对象中
|
||
// if (!_Db.AsTenant().IsAnyConnection(tenantId))
|
||
// {
|
||
// //添加业务库只在当前上下文有效
|
||
// _Db.AsTenant().AddConnection(new ConnectionConfig()
|
||
// {
|
||
// ConfigId = tenantId,
|
||
// ConnectionString = connection,
|
||
// //数据库类型同样可以动态配置
|
||
// DbType = SqlSugar.DbType.MySql,
|
||
// IsAutoCloseConnection = true
|
||
// });
|
||
// }
|
||
// //3:根据租户id获取到对应db对象,替换仓储中的db对象即可
|
||
// base.Context = _Db.AsTenant().GetConnectionScope(tenantId);
|
||
//}
|
||
//这里有个问题，如果想通过上下文请求获取用户信息，就依赖到web相关。需要进行协调好
|
||
//同时还要考虑动态的业务库初始化问题，这个判断不应该写到仓储中，会很吃性能，可以添加租户、程序启动，两个地方同时进行业务库的数据库初始化判断
|
||
}
|
||
|
||
/// <summary>
|
||
/// 异步事务
|
||
/// </summary>
|
||
/// <param name="func"></param>
|
||
/// <returns></returns>
|
||
public async Task<bool> UseTranAsync(Func<Task> func)
|
||
{
|
||
var con = Context;
|
||
var res = await _Db.AsTenant().UseTranAsync(func);
|
||
return res.IsSuccess;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 执行查询sql返回dto列表
|
||
/// </summary>
|
||
/// <typeparam name="S"></typeparam>
|
||
/// <param name="sql"></param>
|
||
/// <returns></returns>
|
||
public async Task<List<S>> UseSqlAsync<S>(string sql, object parameters = null)
|
||
{
|
||
return await _Db.Ado.SqlQueryAsync<S>(sql, parameters);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 执行增删改sql返回状态
|
||
/// </summary>
|
||
/// <param name="sql"></param>
|
||
/// <returns></returns>
|
||
public async Task<bool> UseSqlAsync(string sql, object parameters)
|
||
{
|
||
return await _Db.Ado.ExecuteCommandAsync(sql, parameters) > 0;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新忽略空值
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
public async Task<bool> UpdateIgnoreNullAsync(T entity)
|
||
{
|
||
return await _Db.Updateable(entity).IgnoreColumns(true).ExecuteCommandAsync() > 0;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 调用存储过程
|
||
/// </summary>
|
||
/// <typeparam name="S"></typeparam>
|
||
/// <param name="storeName"></param>
|
||
/// <param name="para"></param>
|
||
/// <returns></returns>
|
||
public async Task<List<S>> StoreAsync<S>(string storeName, object para)
|
||
{
|
||
return await _Db.Ado.UseStoredProcedure().SqlQueryAsync<S>(storeName, para);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 多条件查询
|
||
/// </summary>
|
||
/// <param name="pars"></param>
|
||
/// <returns></returns>
|
||
public async Task<List<T>> GetListAsync(QueryCondition pars)
|
||
{
|
||
return await QueryConditionHandler(pars).ToListAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 仓储扩展方法:单表查询通用分页
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<PageModel<List<T>>> CommonPageAsync(QueryPageCondition pars)
|
||
{
|
||
RefAsync<int> tolCount = 0;
|
||
var result = await QueryConditionHandler(new QueryCondition() { OrderBys = pars.OrderBys, Parameters = pars.Parameters }).ToPageListAsync(pars.Index, pars.Size, tolCount);
|
||
return new PageModel<List<T>>
|
||
{
|
||
Total = tolCount.Value,
|
||
Data = result
|
||
};
|
||
}
|
||
|
||
|
||
public ISugarQueryable<T> QueryConditionHandler(QueryCondition pars)
|
||
{
|
||
var sugarParamters = pars.Parameters.Select(it => (IConditionalModel)new ConditionalModel()
|
||
{
|
||
ConditionalType = it.Type,
|
||
FieldName = it.Key,
|
||
FieldValue = it.Value
|
||
}).ToList();
|
||
var query = _Db.Queryable<T>();
|
||
if (pars.OrderBys != null)
|
||
{
|
||
foreach (var item in pars.OrderBys)
|
||
{
|
||
if (pars.IsAsc)
|
||
{
|
||
query.OrderBy(item.ToSqlFilter() + " asc");
|
||
}
|
||
else
|
||
{
|
||
query.OrderBy(item.ToSqlFilter() + " desc");
|
||
}
|
||
}
|
||
}
|
||
return query.Where(sugarParamters);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 更新高级保存，验证重复
|
||
/// </summary>
|
||
/// <param name="list"></param>
|
||
/// <param name="columns"></param>
|
||
/// <returns></returns>
|
||
public async Task<bool> UpdateSuperSaveAsync(T data, Expression<Func<T, object>> columns)
|
||
{
|
||
var x = _Db.Storageable(data)
|
||
.SplitError(it => it.Any())
|
||
.SplitUpdate(it => true)
|
||
.WhereColumns(columns)//这里用name作为数据库查找条件
|
||
.ToStorage();
|
||
return await x.AsInsertable.ExecuteCommandAsync() > 0;//插入可插入部分
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加高级保存，验证重复
|
||
/// </summary>
|
||
/// <param name="list"></param>
|
||
/// <param name="columns"></param>
|
||
/// <returns></returns>
|
||
public async Task<bool> InsertSuperSaveAsync(T data, Expression<Func<T, object>> columns)
|
||
{
|
||
var x = _Db.Storageable(data)
|
||
.SplitError(it => it.Any())
|
||
.SplitInsert(it => true)
|
||
.WhereColumns(columns)//这里用name作为数据库查找条件
|
||
.ToStorage();
|
||
return await x.AsInsertable.ExecuteCommandAsync() > 0;//插入可插入部分
|
||
}
|
||
/// <summary>
|
||
/// 方法重载，多条件获取第一个值
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<T> GetFirstAsync(Expression<Func<T, bool>> where, Expression<Func<T, object>> order, OrderByType orderByType = OrderByType.Desc)
|
||
{
|
||
return await _Db.Queryable<T>().Where(where).OrderBy(order, orderByType).FirstAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 方法重载，多条件获取范围
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<List<T>> GetListAsync(Expression<Func<T, bool>> where, Expression<Func<T, object>> order, OrderByType orderByType = OrderByType.Desc)
|
||
{
|
||
return await _Db.Queryable<T>().Where(where).OrderBy(order, orderByType).ToListAsync();
|
||
}
|
||
}
|
||
|
||
|
||
} |