C# ADO.NET IBM DB2 命名参数具有相同的名称抛出没有足够的参数指定异常

Question

我有一个相当不可知的 ADO.NET 应用程序，它连接到许多数据库并且能够提取必要的信息来运行。我遇到了 DB2 及其处理命名参数的问题，尤其是当我在同一个查询中重用命名参数时。我知道有几种方法可以通过简单地添加更多参数来解决这个问题，但理论上它应该像在我连接的其他数据库上一样工作，因为参数名称相同。

我正在做的事情有点复杂，涉及子查询等，但为了演示，采用以下查询:

从 test.table 中选择值，其中 cola=@key1 和 colb=@key1；

命名参数@key1被使用了两次。

我的代码如下:

       try
        {
            DbProviderFactory dbfFactory = DbProviderFactories.GetFactory("IBM.Data.DB2.iSeries");
            using (DbConnection dbConnection = dbfFactory.CreateConnection())
            {
                dbConnection.ConnectionString = "DataSource=xxx.xxx.xxx.xxx;UserID=xxxxxxxx;password=xxxxxxxxx";

                using (DbCommand dbCommand = dbConnection.CreateCommand())
                {
                    IDbDataParameter iddpParameter1 = dbCommand.CreateParameter();
                    iddpParameter1.ParameterName = "@key1";
                    iddpParameter1.DbType = DbType.String;
                    iddpParameter1.Value = "1";

                    dbCommand.Parameters.Add(iddpParameter1);
                    dbCommand.CommandType = CommandType.Text;
                    dbCommand.CommandText = "select value from test.table where cola=@key1 and colb=@key1";
                    dbConnection.Open();

                    using (IDataReader idrReader = dbCommand.ExecuteReader())
                    {
                        while (idrReader.Read())
                        {
                                   ...
                        }
                    }
                }

            } // end dbConnection
        } // end try

        catch (Exception ex)
        {
            Console.Write(ex.Message);
        }

当我运行它时，我得到一个异常告诉我:

System.InvalidOperationException: Not enough parameters specified.  The command requires 2 parameter(s), but only 1 parameter(s) exist in the parameter collection.

我明白它告诉我的内容，但我正在寻求帮助，以弄清楚如何让提供者对两个参数使用命名参数，因为它们是相同的。似乎它正在对命名参数进行盲目计数，而没有意识到它们是相同的命名参数。 SQL Server 似乎允许我使用上面的相同代码来执行此操作。我猜这只是提供程序中的差异之一，但希望有人遇到过这个问题并有一个不涉及特定 DB2 代码的 DB2 解决方案。

谢谢，感谢您的帮助。

Answer 1

好吧，我做了更多的挖掘，我想知道它是否可能是您正在使用的连接器。所以我正在做以下事情(这与你正在做的事情非常相似)

在我的应用配置文件中有

<connectionStrings>
    <add name="AWOLNATION" providerName="Ibm.Data.DB2" connectionString="Server=sail:50000;Database=Remix;" />
</connectionStrings>

在我的 Databasemanager 类中，我会像这样初始化它

    public static DatabaseManager Instance(string connectionStringName)
    {
        var connectionStringSettings = ConfigurationManager.ConnectionStrings[connectionStringName];
        if (connectionStringSettings == null) throw new MissingMemberException("[app.config]", string.Format("ConnectionStrings[{0}]", connectionStringName));
        return new DatabaseManager(connectionStringSettings);
    }

    private DatabaseManager(ConnectionStringSettings connectionInformation)
    {
        _connectionInformation = connectionInformation;
        _parameters = new Dictionary<string, object>();
    }
    private void Initialize()
    {
        _connection = DbProviderFactories.GetFactory(_connectionInformation.ProviderName).CreateConnection();
        _connection.ConnectionString = _connectionInformation.ConnectionString;

        _command = _connection.CreateCommand();
    }

不过我添加的参数有点不同。我有一个 Dictionary<string,object>我在设置查询时也添加了。要使用你的例子，我会有这个

    public IEnumerable<object> GetSomething(string key)
    {
        var sql = "select value from test.table where cola = @key1 and colb = @key1";
        _manager.AddParameter("@key1", key);

        return _manager.ExecuteReader<object>(sql, ToSomethignUseful);
    }

    private object ToSomethignUseful(DatabaseManager arg)
    {
        return new { Value = arg.GetArgument<object>("value") };
    }

然后阅读是 OP 和我有相似代码的地方

    public IEnumerable<T> ExecuteReader<T>(string sql, Func<DatabaseManager, T> conversionBlock)
    {
        Initialize();
        using (_connection)
        {
            _connection.Open();
            _command.CommandText = sql;
            _command.CommandType = CommandType.Text;

            if (_parameters.Count > 0)
                AddParameters(_command, _parameters);

            _parameters.Clear();

            using (_reader = _command.ExecuteReader())
            {
                while (_reader.Read())
                {
                    yield return conversionBlock(this);
                }
            }
        }
    }
    private static void AddParameters(DbCommand command, Dictionary<string, object> parameters)
    {
        foreach (var param in parameters)
        {
            command.Parameters.Add(CreateParameter(command, param.Key, param.Value));
        }
    }

    private static DbParameter CreateParameter(DbCommand command, string key, object value)
    {
        var parameter = command.CreateParameter();
        parameter.ParameterName = key;
        parameter.Value = value;

        return parameter;
    }

运行上述代码对我有用，所以我想知道区别是否在于我们使用的提供程序。我在生产中使用命名参数，现在至少使用了一年，可能接近 2 年。

我要说的是，我确实在两次运行相同的代码时遇到了同样的错误，如这段代码所示

    public static void IndendedPrintForEach<T>(this IEnumerable<T> array, string header, Func<T, string> consoleStringConverterMethod)
    {
        var list = array.ToList();
        var color = Console.ForegroundColor;
        Console.ForegroundColor = ConsoleColor.Magenta;
        Console.WriteLine($"<<<{header}>>>");
        Console.ForegroundColor = color;

        if (!list.Any())
        {
            Console.ForegroundColor = ConsoleColor.DarkRed;
            Console.WriteLine("    ************NoItemsFound************");
            Console.ForegroundColor = color;
        }
        else
        {
            foreach (var item in list)
                Console.WriteLine($"    {consoleStringConverterMethod(item)}");
        }
    }

第 3 行 var list = array.ToList()是您为我看到的问题的解决方案。在我有if (!array.Any())之前这将运行查询并使用参数(我在执行查询之前清除了这些参数)然后当我去枚举并打印数组中的每个项目时我得到了错误。对我来说，问题是它正在重新运行我没有更多参数的查询。解决方法是使用 ToList() 枚举查询，然后在列表上进行检查和打印。