Как вызвать хранимую процедуру с использованием общего соединения с БД в C#?

Question

Мне нужно вызвать хранимые procs в C# (.Net 2.0), иногда используя ODBC-соединение, иногда с SQLClient. В будущем мы могли бы общаться с Oracle.

Мои хранимые процедуры имеют параметры ввода/вывода и возвращаемое значение.

CREATE PROCEDURE myProc (@MyInputArg varchar(10), @MyOutputArg varchar(20) output) AS (...) return @@ERROR 

Моя проблема заключается в том, что я не могу найти способ хранения команды, которая может быть общей для любого клиента. Я использую объект IDbCommand.

С подключением к ODBC я должен определить:

objCmd.CommandText = "? = CALL myProc (?,?)"; 

В контексте SQLClient:

objCmd.CommandText = "myProc"; 

Я не хочу, чтобы разобрать мою команду, я уверен, что есть лучший способ иметь общий характер!

Чтобы помочь людям воспроизводиться, вы можете найти ниже, как я создал общее соединение с БД. В моем контексте объект поставщика определяется из файла конфигурации.

// My DB connection string, init is done from a configuration file 
string myConnectionStr = ""; 

// Provider which defined the connection type, init from config file 
//object objProvider = new OdbcConnection(); //ODBC 
object objProvider = new SqlConnection(); // SQLClient 

// My query -- must be adapted switch ODBC or SQLClient -- that's my problem! 
//string myQuery = "? = CALL myProc (?,?)"; // ODBC 
string myQuery = "myProc"; // SQLClient 

// Prepare the connection 
using (IDbConnection conn = (IDbConnection)Activator.CreateInstance(typeof(objProvider), myConnectionStr)) 
{ 
    // Command creation 
    IDbCommand objCmd = (IDbCommand)Activator.CreateInstance(typeof(objProvider)); 
    objCmd.Connection = conn; 

    // Define the command 
    objCmd.CommandType = CommandType.StoredProcedure; 
    objCmd.CommandTimeout = 30; 
    objCmd.CommandText = myQuery; 

    IDbDataParameter param; 

    // Return value 
    param = (IDbDataParameter)Activator.CreateInstance(typeof(objProvider)); 
    param.ParameterName = "RETURN_VALUE"; 
    param.DbType = DbType.Int32; 
    param.Direction = ParameterDirection.ReturnValue; 
    objCmd.Parameters.Add(param); 

    // Param 1 (input) 
    param = (IDbDataParameter)Activator.CreateInstance(typeof(objProvider)); 
    param.ParameterName = "@MyInputArg"; 
    param.DbType = DbType.AnsiString; 
    param.Size = 10; 
    param.Direction = ParameterDirection.Input; 
    param.Value = "myInputValue"; 
    objCmd.Parameters.Add(param); 

    // Param 2 (output) 
    param = (IDbDataParameter)Activator.CreateInstance(typeof(objProvider)); 
    param.ParameterName = "@MyOutputArg"; 
    param.DbType = DbType.AnsiString; 
    param.Size = 20; 
    param.Direction = ParameterDirection.Output; 
    objCmd.Parameters.Add(param); 

    // Open and execute the command 
    objCmd.Connection.Open(); 
    objCmd.ExecuteReader(CommandBehavior.SingleResult); 
    (...) // Treatment 
} 

Спасибо за ваше время.

С уважением, Thibaut.

Answer 1

Вы можете создать обертку вокруг IDbCommand и реализаций (но только если вы хотите :)).

//Note the IDisposable interface 
public class MultiSqlCommand : IDisposable 
{ 
    //DbConnectionType is a custom enum 
    public MultiSqlCommand(DbConnectionType connType, DbConnection conn) 
    { 
    //initialize members 
    ... 
    switch(connType) 
    { 
     case ADO: 
     _cmd = new SqlCommand(_connection); 
     break; 
     case ODBC: 
     ... 
    } 
    } 

    //As param name you pass the undecorated parameter name (no @, ?, etc.) 
    public void AddParameter(string strippedName, object value) 
    { 
    //this should be an internal function which gives you an SqlParameter formatted for your specific DbConnectionType 
    object parameter = GetSqlParam(strippedName, value); 
    _cmd.Parameters.Add(object); 
    } 
} 

После добавления параметров команда готова к выполнению. Вы можете либо открыть его через свойство, либо выполнить его за пределами этого класса, либо расширить API и добавить несколько методов для его выполнения и получения результатов. Что бы вы ни находили удобным.

Примечание: В вашей реализации IDisposable вы должны удалить экземпляр IDbCommand (если не null). Это очень важно, иначе вы будете утечки памяти.

Если предложение нечеткое, сообщите мне, и я попытаюсь заполнить его более подробными сведениями. Решение просто, я бы сказал. Вы можете пойти дальше и создать слой абстракции поверх всех команд и параметров поддержки ADO.NET, но я не думаю, что это действительно необходимо здесь. Это не похоже на то, что вы не пишете целый поставщик данных.