Как получить последний выполненный SQL-запрос по SqlConnection?

Question

На самом деле, мой сценарий немного отличается от упомянутого здесь. Я задал другой вопрос. Но так как я не могу найти там решения, я решил изменить подход.

у меня есть SqlConnection объект доступен для моего кода. Все остальные объекты ADO.NET, такие как SqlCommand, SqlParameter и т.д. не доступны для меня. Эти другие объекты потребляются Dapper Extensions ORM.

Мое приложение выполняет запросы SQL, используя SqlConnection объект и метод Dapper Extensions. SQL-запрос автоматически генерируется Dapper Extensions; сгенерированный запрос не доступен для меня. Я хочу войти в этот запрос SQL.

У меня уже есть свой модуль логов, и единственное, что мне нужно, это последний SQL-запрос, выполненный объектом соединения.

Как получить последний выполненный SQL-запрос SqlConnection?

Следующее не работает, потому что SqlCommand не доступен

Если я пойму SqlCommandЯ могу построить запрос из него с помощью кода ниже; к сожалению, это не доступно для меня.

public string GetCommandLogString(IDbCommand command)
{
    string outputText;
    if(command.Parameters.Count == 0)
    {
        outputText = command.CommandText;
    }
    else
    {
        StringBuilder output = new StringBuilder();
        output.Append(command.CommandText);
        output.Append("; ");

        IDataParameter objIDataParameter;
        int parameterCount = command.Parameters.Count;
        for(int i = 0; i < parameterCount; i++)
        {
            objIDataParameter = (IDataParameter)command.Parameters[i];
            output.Append(string.Format("{0} = '{1}'", objIDataParameter.ParameterName, objIDataParameter.Value));

            if(i + 1 < parameterCount)
            {
                output.Append(", ");
            }
        }
        outputText = output.ToString();
    }
    return outputText;
}

Answer 1

Подход, который я использовал в прошлом, когда я не хотел полагаться на какие-либо внешние инструменты (или когда инструментов не хватало, как, например, при работе с Access), - это использовать соединение с базой данных и командовать классы-оболочки, чтобы Я могу добавить протоколирование к любому из их методов или свойств.

Чтобы использовать его, вы передаете любое соединение, которое хотите использовать, в конструктор WrappedDbConnection -

using (var conn = new WrappedDbConnection(GetMyConnection()))
{
    // Do work using Dapper here against "conn"
}

(Примечание. Когда вызывается метод Dispose экземпляра WrappedDbConnection, он передается в базовое соединение, поэтому вам не нужно "использование" для WrappedDbConnection и отдельное "использование" для вашего соединения - вам нужен только один "использование" ", как показано выше).

Два класса, которые вам нужны, определены ниже.

Обратите внимание, что есть вызовы Console.WriteLine в методах "ExecuteNonQuery", "ExecuteReader", "ExecuteReader" и "ExecuteScalar", которые выписывают, какой запрос будет выполняться. Вы можете изменить это в соответствии с вашими требованиями, чтобы выписать запрос после его завершения, или вы можете использовать другой вывод, отличный от Console.Writeline, но эти изменения должны быть достаточно простыми для внесения.

public class WrappedDbConnection : IDbConnection
{
    private readonly IDbConnection _conn;
    public WrappedDbConnection(IDbConnection connection)
    {
        if (connection == null)
            throw new ArgumentNullException(nameof(connection));

        _conn = connection;
    }

    public string ConnectionString
    {
        get { return _conn.ConnectionString; }
        set { _conn.ConnectionString = value; }
    }

    public int ConnectionTimeout
    {
        get { return _conn.ConnectionTimeout; }
    }

    public string Database
    {
        get { return _conn.Database; }
    }

    public ConnectionState State
    {
        get { return _conn.State; }
    }

    public IDbTransaction BeginTransaction()
    {
        return _conn.BeginTransaction();
    }

    public IDbTransaction BeginTransaction(IsolationLevel il)
    {
        return _conn.BeginTransaction(il);
    }

    public void ChangeDatabase(string databaseName)
    {
        _conn.ChangeDatabase(databaseName);
    }

    public void Close()
    {
        _conn.Close();
    }

    public IDbCommand CreateCommand()
    {
        return new WrappedDbCommand(_conn.CreateCommand());
    }

    public void Dispose()
    {
        _conn.Dispose();
    }

    public void Open()
    {
        _conn.Open();
    }
}

public class WrappedDbCommand : IDbCommand
{
    private readonly IDbCommand _cmd;
    public WrappedDbCommand(IDbCommand command)
    {
        if (command == null)
            throw new ArgumentNullException(nameof(command));

        _cmd = command;
    }

    public string CommandText
    {
        get { return _cmd.CommandText; }
        set { _cmd.CommandText = value; }
    }

    public int CommandTimeout
    {
        get { return _cmd.CommandTimeout; }
        set { _cmd.CommandTimeout = value; }
    }

    public CommandType CommandType
    {
        get { return _cmd.CommandType; }
        set { _cmd.CommandType = value; }
    }

    public IDbConnection Connection
    {
        get { return _cmd.Connection; }
        set { _cmd.Connection = value; }
    }

    public IDataParameterCollection Parameters
    {
        get { return _cmd.Parameters; }
    }

    public IDbTransaction Transaction
    {
        get { return _cmd.Transaction; }
        set { _cmd.Transaction = value; }
    }

    public UpdateRowSource UpdatedRowSource
    {
        get { return _cmd.UpdatedRowSource; }
        set { _cmd.UpdatedRowSource = value; }
    }

    public void Cancel()
    {
        _cmd.Cancel();
    }

    public IDbDataParameter CreateParameter()
    {
        return _cmd.CreateParameter();
    }

    public void Dispose()
    {
        _cmd.Dispose();
    }

    public int ExecuteNonQuery()
    {
        Console.WriteLine($"[ExecuteNonQuery] {_cmd.CommandText}");
        return _cmd.ExecuteNonQuery();
    }

    public IDataReader ExecuteReader()
    {
        Console.WriteLine($"[ExecuteReader] {_cmd.CommandText}");
        return _cmd.ExecuteReader();
    }

    public IDataReader ExecuteReader(CommandBehavior behavior)
    {
        Console.WriteLine($"[ExecuteReader({behavior})] {_cmd.CommandText}");
        return _cmd.ExecuteReader();
    }

    public object ExecuteScalar()
    {
        Console.WriteLine($"[ExecuteScalar] {_cmd.CommandText}");
        return _cmd.ExecuteScalar();
    }

    public void Prepare()
    {
        _cmd.Prepare();
    }
}