有没有大哥实现过 监控所有数据库成功执行的sql 不包括事务回滚的sql

[929496959]

我写了个例子 但是不能涵盖所有类型的事务

        //全部sql日志
	private static ConcurrentDictionary<Guid, ConcurrentBag<string>> _sqlLogs = new();
        private static readonly AsyncLocal<Guid?> _currentTransactionId = new();
				db.Aop.TraceBefore += (s, e) =>
				{
                    if (e.Operation.Contains("Transaction"))
                    {
						_sqlLogs.GetOrAdd(e.Identifier, new ConcurrentBag<string>());
						_currentTransactionId.Value = e.Identifier;
						Console.WriteLine($"跟踪开始:{e.Operation}");
					}
				};
				db.Aop.TraceAfter += (s, e) =>
				{
                    if (e.Operation.Contains("Transaction"))
                    {
						Console.WriteLine($"跟踪结束:{e.Operation},是否异常:{e.Exception != null}");
						if (e.Exception == null)
						{
							foreach (var item in _sqlLogs[e.Identifier])
							{
								_Logger?.Log(NLog.LogLevel.Info, $"TraceID:{e.Identifier} sql:{item}");
							}
						}
						_sqlLogs.TryRemove(e.Identifier, out _);
						_currentTransactionId.Value = null;
					}
				};
				db.Aop.CurdAfter += (s, e) =>
				{
                    if (_currentTransactionId.Value.HasValue)
                    {
                        if (_sqlLogs.TryGetValue(_currentTransactionId.Value.Value, out var sqllogsList))
                        {
                            sqllogsList.Add(e.Sql);
                        }
                    }
                    else
                    { 
                        _Logger?.Log(NLog.LogLevel.Info, e.Sql);
					}

				};

[929496959]

只有在同一个线程里面执行 这个代码才有效果 一旦异步就不行