4

我必须在 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
}

谢谢你的时间。

问候，蒂博。

4

1 回答 1

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 命令和参数支持之上创建一个抽象层，但我认为这里没有必要。这不像您没有编写完整的数据提供程序。

于 2012-06-20T17:30:43.567 回答