Dapper扩展SQL跟踪及全局缓存通知

壮心未与年俱老，死去犹能作鬼雄。这篇文章主要讲述Dapper扩展SQL跟踪及全局缓存通知相关的知识，希望能为你提供帮助。
具体原因就不说了，目前项目的构成有两部分，一部分是是基于框架开发的，另一部是由于早期业务是采用自定义开发模式，虽然数据访问层都是基于Dapper,
但要做全局sql跟踪及缓存通知，调整代码还是有些麻烦，最后还是动手简单扩展一个Dapper的源码，从底层来进行处理。
调整Dapper源码中有一个很重要的类：CommandDefinition.cs
1、执行SQL前拦截事件

文章图片

2、执行SQL后拦截事件（后失败会不触发)

文章图片

3、SQLMapper.cs增加一行代码（此处应该是作者漏掉了，没有细读）

文章图片

4、附上SqlMapperTrace.cs源码

1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 5 using System.Threading.Tasks; 6 7 namespace Dapper 8 { 9/// < summary> 10/// Sql执行拦截事件 11/// < /summary> 12/// < param name="traceInfo"> < /param> 13public delegate void BeforeCommandExecute(TraceInfo traceInfo); 14/// < summary> 15/// SQL运行成功后拦截事件 16/// < /summary> 17/// < param name="traceInfo"> < /param> 18public delegate void AfterCommandExecute(TraceInfo traceInfo); 19/// < summary> 20/// DapperSQL执行跟踪 21/// < /summary> 22public class SqlMapperTrace 23{ 24static BeforeCommandExecute BeforeSqlCommand = null; 25static AfterCommandExecute AfterSqlCommand = null; 26/// < summary> 27/// 设置DapperSql执行拦截事件 28/// < /summary> 29/// < param name="beforeExecuteTrace"> 执行前事件< /param> 30/// < param name="afterExecuteTrace"> 执行后事件< /param> 31public static void SetMapperTrace(BeforeCommandExecute beforeExecuteTrace, AfterCommandExecute afterExecuteTrace) 32{ 33if (null != BeforeSqlCommand) 34return; 35BeforeSqlCommand = beforeExecuteTrace; 36AfterSqlCommand = afterExecuteTrace; 37 38} 39 40/// < summary> 41/// 执行SQL运行前拦截事件 42/// < /summary> 43/// < param name="traceInfo"> < /param> 44internal static void ShellBeforeCommandExecute(TraceInfo traceInfo) 45{ 46if (null != BeforeSqlCommand) 47BeforeSqlCommand( traceInfo); 48} 49 50/// < summary> 51/// 执行SQL运行成功后拦截事件，若SQL执行失败，则此方法不会触发 52/// < /summary> 53/// < param name="traceInfo"> < /param> 54public static void ShellAfterCommandExecute(TraceInfo traceInfo) 55{ 56if (null != AfterSqlCommand) 57AfterSqlCommand(traceInfo); 58} 59} 60 61/// < summary> 62/// Sql执行状态 63/// < /summary> 64public enum SqlState 65{ 66/// < summary> 67/// 执行中 68/// < /summary> 69Start, 70/// < summary> 71/// 完成 72/// < /summary> 73End, 74/// < summary> 75/// 失败 76/// < /summary> 77Error 78} 79 80/// < summary> 81/// 跟踪信息 82/// < /summary> 83public class TraceInfo 84{ 85/// < summary> 86/// 操作识别Key，用用跟踪同一SQL是否执行成功 87/// < /summary> 88public string Token { get; set; } 89/// < summary> 90/// SQL语句 91/// < /summary> 92public String CommandText { get; set; } 93/// < summary> 94/// sql参数 95/// < /summary> 96public object SqlParams { get; set; } 97 98/// < summary> 99/// 是否正在启动 100/// < /summary> 101public SqlState IsStart { get; set; } 102/// < summary> 103/// 执行时间，性能统计，自己可根据两次时间差去实现 104/// < /summary> 105public DateTime ExecuteTime { get; set; } 106 107/// < summary> 108/// 提示信息 109/// < /summary> 110public string Message { get; set; } 111} 112 113 }

5、调用拦截注入
【Dapper扩展SQL跟踪及全局缓存通知】