csharp 控制台拦截器

Posted 2021-05-12

class ConsoleWriterInterceptor : IDbCommandInterceptor
{
    public void NonQueryExecuted(DbCommand command, DbCommandInterceptionContext<int> interceptionContext)
    {
        WriteInfo(interceptionContext.IsAsync, command.CommandText);
    }

    public void NonQueryExecuting(DbCommand command, DbCommandInterceptionContext<int> interceptionContext)
    {
        WriteInfo(interceptionContext.IsAsync, command.CommandText);
    }

    public void ReaderExecuted(DbCommand command, DbCommandInterceptionContext<DbDataReader> interceptionContext)
    {
        WriteInfo(interceptionContext.IsAsync, command.CommandText);
    }

    public void ReaderExecuting(DbCommand command, DbCommandInterceptionContext<DbDataReader> interceptionContext)
    {
        WriteInfo(interceptionContext.IsAsync, command.CommandText);
    }

    public void ScalarExecuted(DbCommand command, DbCommandInterceptionContext<object> interceptionContext)
    {
        WriteInfo(interceptionContext.IsAsync, command.CommandText);
    }

    public void ScalarExecuting(DbCommand command, DbCommandInterceptionContext<object> interceptionContext)
    {
        WriteInfo(interceptionContext.IsAsync, command.CommandText);
    }

    private void WriteInfo(bool isAsync, string commandText)
    {
        Console.WriteLine($"IsAsync: {isAsync}, Command Text:{ commandText}");
    }
}

DbInterception.Add(new ConsoleWriterInterceptor());