c# - 如何在 C# 中使用通用数据库连接调用存储过程？

Question

我必须在 C# (.Net 2.0) 中调用存储过程，有时使用 ODBC 连接，有时使用 SQLClient。 future 我们也可能需要与 Oracle 进行交流。

我的存储过程有输入/输出参数和返回值。

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

我的问题是我无法找到存储命令的方法，无论客户端如何，该命令都可能是通用的。我正在使用 IDbCommand 对象。

对于 ODBC 连接，我必须定义:

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

在 SQL 客户端上下文中:

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
}

感谢您的宝贵时间。

问候，蒂博。

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 实例(如果不为空)。这非常重要，否则你会泄漏内存。

如果建议不明确，请告诉我，我会尝试用更多细节来补充。我会说，解决方案很简单。您可以更进一步，在整个 ADO.NET 命令和参数支持之上创建一个抽象层，但我认为这里没有必要。这并不是说您没有编写完整的数据提供程序。