IDatabaseToExecuteableQueryAdaptor for MySql

MySqlCommandAdapter.cs

// Note: Connection string must include the following option: Allow User Variables=True

using System;
using System.Data.Common;
using System.Linq;

using ApprovalUtilities.Persistence.Database;

using MySql.Data.MySqlClient;
public class MySqlCommandAdapter : IDatabaseToExecuteableQueryAdaptor
{
    private readonly MySqlCommand mySqlCommand;

    public MySqlCommandAdapter(MySqlCommand mySqlCommand)
    {
        this.mySqlCommand = mySqlCommand;
    }

    public string GetQuery()
    {
        return
            mySqlCommand.Parameters.Cast<MySqlParameter>()
                .Select(p => "SET " + p.ParameterName + " = '" + p.Value + "';" + Environment.NewLine)
                .Aggregate(mySqlCommand.CommandText, (s, s1) => s1 + s);
    }

    public DbConnection GetConnection()
    {
        return mySqlCommand.Connection;
    }
}