Oracle ODP.NET SQL Logging

OracleLogging.cs

public class OracleConnectionProvider
{
  private readonly ProxyGenerator proxyGenerator = new ProxyGenerator();
  
  private readonly IInterceptor interceptor = new SqlLoggingInterceptor(SqlLogger);

  public IDbConnection CreateConnection()
  {
      var con = new OracleConnection(connectionString);
      con.Open();
      if (!EnableLogging) return con;
      return proxyGenerator.CreateInterfaceProxyWithTarget<IDbConnection>(con, interceptor);
  }
}

public class SqlLoggingInterceptor : IInterceptor
{
    private readonly ISqlLogger sqlLogger;
    private readonly ProxyGenerator proxyGenerator = new ProxyGenerator();

    public SqlLoggingInterceptor(ISqlLogger sqlLogger)
    {
        this.sqlLogger = sqlLogger;
    }

    private static readonly MethodInfo[] executeMethods =
        typeof (IDbCommand).GetMethods(BindingFlags.Instance | BindingFlags.Public)
            .Where(m => new[] {"ExecuteScalar", "ExecuteNonQuery", "ExecuteReader"}.Contains(m.Name))
            .ToArray();

    public void Intercept(IInvocation invocation)
    {
        if (invocation.Method == createCommandMethod)
        {
            invocation.Proceed();
            var command = (IDbCommand)invocation.ReturnValue;
            var proxy = proxyGenerator.CreateInterfaceProxyWithTarget(command, this);
            invocation.ReturnValue = proxy;
            return;
        }

        if (executeMethods.Contains(invocation.Method))
        {
            var cmd = (IDbCommand)invocation.InvocationTarget;
            var sw = new Stopwatch();
            sw.Start();
            try
            {
                invocation.Proceed();
            }
            catch (Exception exc)
            {
                sqlLogger.Log(exc, cmd.CommandText, cmd.Parameters, sw.Elapsed);
                throw;
            }
            sqlLogger.Log(cmd.CommandText, cmd.Parameters, sw.Elapsed);
            return;
        }

        invocation.Proceed();
    }
}