分享一个 .NET 通过监听器拦截 EF 消息写日志的详细例子

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: 分享一个 .NET 通过监听器拦截 EF 消息写日志的详细例子

EF 开发效率确实很高也很便捷,但当它发生错误时,也挺让人头疼的,为什么?因为 EF 就像是一个黑盒子,一切全被封装起来,出错的时候很难定位原因,如果能够知道并打印 EF 生成的 SQL 语句,对于定位 EF 错误,就很有帮助。

程序员的才智是无限的,虽然 EF 有这个那个的问题,但程序员却总比这些问题多一个办法。

下面分享一个 .NET 通过监听器拦截 EF 消息写日志的详细例子。

  1. 创建自定义监听器类,拦截 EF 的命令执行事件(留意注释
/// <summary>
/// 监听并写 EF 生成的 SQL 到日志
/// </summary>
public class EFIntercepterLogging : IDbCommandInterceptor
{
    /// <summary>
    /// 实现接口的 NonQueryExecuting 方法
    /// </summary>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    public void NonQueryExecuting(
        DbCommand command, 
        DbCommandInterceptionContext<int> interceptionContext)
    {
        LogWhenExecuting(command, interceptionContext);
    }
    /// <summary>
    /// 实现接口的 NonQueryExecuted 方法
    /// </summary>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    public void NonQueryExecuted(
        DbCommand command, 
        DbCommandInterceptionContext<int> interceptionContext)
    {
        LogIfError(command, interceptionContext);
    }
    /// <summary>
    /// 实现接口的 ReaderExecuting 方法
    /// </summary>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    public void ReaderExecuting(
        DbCommand command, 
        DbCommandInterceptionContext<DbDataReader> interceptionContext)
    {
        LogWhenExecuting(command, interceptionContext);
    }
    /// <summary>
    /// 实现接口的 ReaderExecuted 方法
    /// </summary>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    public void ReaderExecuted(
        DbCommand command, 
        DbCommandInterceptionContext<DbDataReader> interceptionContext)
    {
        LogIfError(command, interceptionContext);
    }
    /// <summary>
    /// 实现接口的 ScalarExecuting 方法
    /// </summary>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    public void ScalarExecuting(
        DbCommand command, 
        DbCommandInterceptionContext<object> interceptionContext)
    {
        LogWhenExecuting(command, interceptionContext);
    }
    /// <summary>
    /// 实现接口的 ScalarExecuted 方法
    /// </summary>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    public void ScalarExecuted(
        DbCommand command, 
        DbCommandInterceptionContext<object> interceptionContext)
    {
        LogIfError(command, interceptionContext);
    }
    /// <summary>
    /// 写 EF 执行中的 SQL 日志,Debug 级别,用在 Executing 方法
    /// </summary>
    /// <typeparam name="TResult"></typeparam>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    private void LogWhenExecuting<TResult>(
        DbCommand command, 
        DbCommandInterceptionContext<TResult> interceptionContext)
    {
        Logger.DebugFormat("Executing the following SQL: [{0}]", command.CommandText);
    }
    /// <summary>
    /// 出现异常时写日志到 Log4net
    /// </summary>
    /// <typeparam name="TResult"></typeparam>
    /// <param name="command"></param>
    /// <param name="interceptionContext"></param>
    private void LogIfError<TResult>(
        DbCommand command, 
        DbCommandInterceptionContext<TResult> interceptionContext)
    {
        if (interceptionContext.Exception != null)
        {
            var errMsg = new StringBuilder(16);
            errMsg.AppendLine("Error occurred when executing the following SQL: ");
            errMsg.AppendLine(command.CommandText);
            foreach (DbParameter param in command.Parameters)
            {
                errMsg.AppendLine($"ParameterName:[{param.ParameterName}] -- DbType:[{param.DbType}] -- Value:[{param.Value}]");
            }
            Logger.Error(errMsg, interceptionContext.Exception);
        }
    }
}

2.在 Global.asax 中的 Application_Start 方法注册监听器

protected void Application_Start()
{
    AreaRegistration.RegisterAllAreas();
    FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
    RouteConfig.RegisterRoutes(RouteTable.Routes);
    BundleConfig.RegisterBundles(BundleTable.Bundles);
    //autofac注册
    AutofacConfig.RegisterConfig();
    //注册 EF log 监听器
    DbInterception.Add(new EFIntercepterLogging());
}

3.这样就实现了监听器拦截 EF 消息写日志的功能,当运行程序执行 EF 语句时,就会自动将 EF 生成的 SQL 写到日志文件中


相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
相关文章
|
2月前
|
JSON 安全 API
.net 自定义日志类
在.NET中,创建自定义日志类有助于更好地管理日志信息。示例展示了如何创建、配置和使用日志记录功能,包括写入日志文件、设置日志级别、格式化消息等。注意事项涵盖时间戳、日志级别、JSON序列化、线程安全、日志格式、文件处理及示例使用。请根据需求调整代码。
53 13
|
4月前
|
SQL 分布式计算 Hadoop
Hadoop-19 Flume Agent批量采集数据到HDFS集群 监听Hive的日志 操作则把记录写入到HDFS 方便后续分析
Hadoop-19 Flume Agent批量采集数据到HDFS集群 监听Hive的日志 操作则把记录写入到HDFS 方便后续分析
79 2
|
6月前
|
存储 监控 网络协议
在Linux中,如何使用 tcpdump 监听主机为 192.168.1.1,tcp 端⼝为 80 的数据,并将将输出结果保存输出到tcpdump.log?
在Linux中,如何使用 tcpdump 监听主机为 192.168.1.1,tcp 端⼝为 80 的数据,并将将输出结果保存输出到tcpdump.log?
|
6月前
|
开发框架 .NET Docker
【Azure 应用服务】App Service .NET Core项目在Program.cs中自定义添加的logger.LogInformation,部署到App Service上后日志不显示Log Stream中的问题
【Azure 应用服务】App Service .NET Core项目在Program.cs中自定义添加的logger.LogInformation,部署到App Service上后日志不显示Log Stream中的问题
|
6月前
|
存储 开发框架 .NET
ASP.NET Web Api 使用 EF 6,DateTime 字段如何取数据库服务器当前时间
ASP.NET Web Api 使用 EF 6,DateTime 字段如何取数据库服务器当前时间
|
6月前
|
程序员 数据库
分享 2 个 .NET EF 6 只更新某些字段的方法
分享 2 个 .NET EF 6 只更新某些字段的方法
146 0
|
6月前
|
数据库
分享一个 .NET EF 6 扩展 Where 的方法
分享一个 .NET EF 6 扩展 Where 的方法
|
6月前
|
SQL 程序员 数据库
总结查看 .NET EF 生成的 SQL 的 3 种方式,亲测可用
总结查看 .NET EF 生成的 SQL 的 3 种方式,亲测可用
172 0
|
3月前
|
XML 安全 Java
【日志框架整合】Slf4j、Log4j、Log4j2、Logback配置模板
本文介绍了Java日志框架的基本概念和使用方法,重点讨论了SLF4J、Log4j、Logback和Log4j2之间的关系及其性能对比。SLF4J作为一个日志抽象层,允许开发者使用统一的日志接口,而Log4j、Logback和Log4j2则是具体的日志实现框架。Log4j2在性能上优于Logback,推荐在新项目中使用。文章还详细说明了如何在Spring Boot项目中配置Log4j2和Logback,以及如何使用Lombok简化日志记录。最后,提供了一些日志配置的最佳实践,包括滚动日志、统一日志格式和提高日志性能的方法。
927 31
【日志框架整合】Slf4j、Log4j、Log4j2、Logback配置模板
|
2月前
|
监控 安全 Apache
什么是Apache日志?为什么Apache日志分析很重要?
Apache是全球广泛使用的Web服务器软件,支持超过30%的活跃网站。它通过接收和处理HTTP请求,与后端服务器通信,返回响应并记录日志,确保网页请求的快速准确处理。Apache日志分为访问日志和错误日志,对提升用户体验、保障安全及优化性能至关重要。EventLog Analyzer等工具可有效管理和分析这些日志,增强Web服务的安全性和可靠性。

热门文章

最新文章