84 lines
3.7 KiB
C#
84 lines
3.7 KiB
C#
|
|
||
|
|
using JinYuan.Helper;
|
||
|
|
using SqlSugar;
|
||
|
|
using System;
|
||
|
|
using System.Collections.Generic;
|
||
|
|
using System.Linq;
|
||
|
|
|
||
|
|
namespace JinYuan.DAL
|
||
|
|
{
|
||
|
|
public class SQLSugarHelper
|
||
|
|
{
|
||
|
|
/// <summary>
|
||
|
|
/// 数据库连接字符串
|
||
|
|
/// </summary>
|
||
|
|
public static string connString = string.Empty;
|
||
|
|
private static LoggerHelp _logger = new LoggerHelp();
|
||
|
|
/// <summary>
|
||
|
|
/// 数据库类型
|
||
|
|
/// </summary>
|
||
|
|
public static SqlSugar.DbType dbType = SqlSugar.DbType.SqlServer;
|
||
|
|
|
||
|
|
public static SqlSugarScope SqlSugarClient
|
||
|
|
{
|
||
|
|
get
|
||
|
|
{
|
||
|
|
//如果配置了 SlaveConnectionConfigs那就是主从模式,所有的写入删除更新都走主库，查询走从库，
|
||
|
|
var db = new SqlSugarScope(new ConnectionConfig()
|
||
|
|
{
|
||
|
|
ConnectionString = connString,
|
||
|
|
DbType = dbType, //数据库类型
|
||
|
|
IsAutoCloseConnection = true, //默认false,自动释放和关闭数据库连接，设置为true无需使用using或者close操作
|
||
|
|
InitKeyType = InitKeyType.Attribute //默认SystemTable,该属性是不是主键，是不是标识列等等信息
|
||
|
|
|
||
|
|
});
|
||
|
|
db.Ado.CommandTimeOut = 3000;//设置执行语法超时时间
|
||
|
|
db.Aop.OnLogExecuted = (sql, pars) => //SQL执行完事件
|
||
|
|
{
|
||
|
|
LoggerHelp.WriteLog($"执行时间：{db.Ado.SqlExecutionTime.TotalMilliseconds}毫秒 \r\nSQL如下：{sql} \r\n参数：{GetParams(pars)} ", "SQL执行");
|
||
|
|
};
|
||
|
|
db.Aop.OnLogExecuting = (sql, pars) => //SQL执行前事件
|
||
|
|
{
|
||
|
|
if (db.TempItems == null) db.TempItems = new Dictionary<string, object>();
|
||
|
|
};
|
||
|
|
db.Aop.OnError = (exp) =>//执行SQL 错误事件
|
||
|
|
{
|
||
|
|
LoggerHelp.WriteLog($"SQL错误:{exp.Message}\r\nSQL如下：{exp.Sql}", "SQL执行");
|
||
|
|
throw new Exception(exp.Message);
|
||
|
|
};
|
||
|
|
db.Aop.OnDiffLogEvent = (it) => //可以方便拿到 数据库操作前和操作后的数据变化。
|
||
|
|
{
|
||
|
|
var editBeforeData = it.BeforeData; //变化前数据
|
||
|
|
var editAfterData = it.AfterData; //变化后数据
|
||
|
|
var sql = it.Sql; //SQL
|
||
|
|
var parameter = it.Parameters; //参数
|
||
|
|
var data = it.BusinessData; //业务数据
|
||
|
|
var time = it.Time ?? new TimeSpan(); //时间
|
||
|
|
var diffType = it.DiffType; //枚举值 insert 、update 和 delete 用来作业务区分
|
||
|
|
|
||
|
|
//你可以在这里面写日志方法
|
||
|
|
var log = $"时间:{time.TotalMilliseconds}\r\n";
|
||
|
|
log += $"类型:{diffType.ToString()}\r\n";
|
||
|
|
log += $"SQL:{sql}\r\n";
|
||
|
|
log += $"参数:{GetParams(parameter)}\r\n";
|
||
|
|
log += $"业务数据:{JsonHelper.EntityToJson(data)}\r\n";
|
||
|
|
log += $"变化前数据:{JsonHelper.EntityToJson(editBeforeData)}\r\n";
|
||
|
|
log += $"变化后数据:{JsonHelper.EntityToJson(editAfterData)}\r\n";
|
||
|
|
//SqlLogHelper.WriteLog(log, "数据变化前后");
|
||
|
|
};
|
||
|
|
return db;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// 获取参数信息
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="pars"></param>
|
||
|
|
/// <returns></returns>
|
||
|
|
private static string GetParams(SugarParameter[] pars)
|
||
|
|
{
|
||
|
|
return pars.Aggregate("", (current, p) => current + $"{p.ParameterName}:{p.Value}, ");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|