73 lines
2.7 KiB
C#
73 lines
2.7 KiB
C#
using Infrastructure;
|
||
using SqlSugar;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
|
||
namespace ZR.Repository.DbProvider
|
||
{
|
||
/// <summary>
|
||
/// SqlSugar ORM
|
||
/// </summary>
|
||
public class SugarDbContext
|
||
{
|
||
public SqlSugarClient Db; //用来处理事务多表查询和复杂的操作
|
||
|
||
/// <summary>
|
||
/// 使用SugarSql获取连接对象
|
||
/// 构造方法有问题
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public SugarDbContext()
|
||
{
|
||
string connStr = ConfigUtils.Instance.GetConnectionStrings(OptionsSetting.ConnAdmin);
|
||
string dbKey = ConfigUtils.Instance.GetAppConfig<string>(OptionsSetting.DbKey);
|
||
int dbType = ConfigUtils.Instance.GetAppConfig(OptionsSetting.DbType, 0);
|
||
if (!string.IsNullOrEmpty(dbKey))
|
||
{
|
||
connStr = NETCore.Encrypt.EncryptProvider.DESDecrypt(connStr, dbKey);
|
||
}
|
||
|
||
Db = new SqlSugarClient(new List<ConnectionConfig>()
|
||
{
|
||
new ConnectionConfig(){
|
||
ConnectionString = connStr,
|
||
DbType = (DbType)dbType,
|
||
IsAutoCloseConnection = true,//开启自动释放模式和EF原理一样
|
||
InitKeyType = InitKeyType.Attribute,//从特性读取主键和自增列信息
|
||
ConfigId = 0
|
||
},
|
||
});
|
||
|
||
//调式代码 用来打印SQL
|
||
Db.Aop.OnLogExecuting = (sql, pars) =>
|
||
{
|
||
Console.BackgroundColor = ConsoleColor.Yellow;
|
||
Console.WriteLine("【SQL语句】" + sql.ToLower() + "\r\n" + Db.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
|
||
};
|
||
//出错打印日志
|
||
Db.Aop.OnError = (e) =>
|
||
{
|
||
Console.WriteLine($"[执行Sql出错]{e.Message}，SQL={e.Sql}");
|
||
Console.WriteLine();
|
||
};
|
||
}
|
||
|
||
public SqlSugarClient GetSugarDbContext(string dbName)
|
||
{
|
||
string connStr = ConfigUtils.Instance.GetConnectionStrings(OptionsSetting.Conn).Replace("{DbName}", dbName);
|
||
int dbType = ConfigUtils.Instance.GetAppConfig(OptionsSetting.DbType, 0);
|
||
|
||
return new SqlSugarClient(new List<ConnectionConfig>()
|
||
{
|
||
new ConnectionConfig(){
|
||
ConnectionString = connStr,
|
||
DbType = (DbType)dbType,
|
||
IsAutoCloseConnection = true,//开启自动释放模式和EF原理一样
|
||
InitKeyType = InitKeyType.Attribute,//从特性读取主键和自增列信息
|
||
},
|
||
});
|
||
}
|
||
}
|
||
}
|