从 AS400 存储过程返回结果集

本文关键字：结果 返回 存储过程 AS400 | 更新日期: 2023-09-27 18:35:58

我正在努力使用 C# 控制台应用程序从 AS400 数据库返回结果集...我可以连接到数据库，并且我已经通过AS400日志验证了连接，但是我似乎遇到了以下错误：

System.InvalidCastException 未处理 消息=提供程序当前不支持返回的数据类型。 源=IBM。Data.DB2.iSeries 堆栈跟踪： 在 IBM。Data.DB2.iSeries.iDB2DbTypeUtility.MapSQLTypeToDCPCType（DcSqlTypes sqlType， Int32 colccsid， UInt32 length） 在 IBM。Data.DB2.iSeries.iDB2Command.setRowOfParameterData（MpDcData[]& dcDataRow） 在 IBM。Data.DB2.iSeries.iDB2Command.execute（） 在 IBM。Data.DB2.iSeries.iDB2Command.ExecuteNonQuery（） at GeacFutureDelivery.Program.Main（String[] args） in C：''Users''harlim''documents''visual studio 2010''Projects''GeacFutureDelivery''GeacFutureDelivery''Program.cs：line 40 at System.AppDomain._nExecuteAssembly（RuntimeAssembly assembly， String[] args） at System.AppDomain.ExecuteAssembly（String assemblyFile， Evidence assemblySecurity， String[] args） at Microsoft.VisualStudio.HostingProcess.HostProc.RunUsersAssembly（） 在System.Threading.ThreadHelper.ThreadStart_Context（对象状态） at System.Threading.ExecutionContext.Run（ExecutionContext executionContext， ContextCallback callback， Object state， Boolean ignoreSyncCtx） at System.Threading.ExecutionContext.Run（ExecutionContext executionContext， ContextCallback callback， Object state） at System.Threading.ThreadHelper.ThreadStart（） 内部异常：

我的消息来源是：

var connectionString = "<Connection String>";
        int startDate = 1120530;
        int endDate = 1120602;
        try
        {
            using (var connection = new iDB2Connection(connectionString))
            {
                connection.Open();
                iDB2Transaction trans = connection.BeginTransaction();
                iDB2Command command = connection.CreateCommand();

                string query = "DRLOBJ01.GETORDPCD";
                command.Transaction = trans;
                command.CommandType = CommandType.StoredProcedure; 
                command.CommandText = query;
                command.CommandTimeout = 0;
                command.Parameters.Add("DTSTR", iDB2DbType.iDB2Integer).Value = startDate;
                command.Parameters.Add("DTEND", iDB2DbType.iDB2Integer).Value = endDate;
                command.Prepare();

                using (iDB2DataReader reader = command.ExecuteReader())
                 {
                    int iCUSO51 = reader.GetOrdinal("CUSO51");
                    int iORDN51 = reader.GetOrdinal("ORDN51");
                    int iDTDR51 = reader.GetOrdinal("DTDR51");
                    int iOPST45 = reader.GetOrdinal("OPST45");
                    while (reader.Read())
                    {
                        if (!string.IsNullOrEmpty(reader.GetString(iCUSO51)))
                        {
                            Console.WriteLine((string)reader[iCUSO51]);
                            Console.WriteLine((string)reader[iORDN51]);
                            Console.WriteLine((string)reader[iDTDR51]);
                            Console.WriteLine((string)reader[iOPST45]);
                        }
                    }
                }
            }
        }
        catch (iDB2CommErrorException ex)
        {
            Console.WriteLine(ex.Message);
        }
    }

有什么想法吗？

从 AS400 存储过程返回结果集

如果你的值是一个字节[]，我想你在CCSID65535时遇到了一些麻烦。

如果是这样，这里有一个代码来解决它：-）

 private DataTable parseCCSID65535(DataTable p_dt)
 {
     DataTable dt = new DataTable();
     // Build a new DataTable
     for (int i = 0; i < p_dt.Columns.Count; i++)
     {
         dt.Columns.Add(p_dt.Columns[i].Caption);
     }
     //loop through the rows
     for (int r = 0; r < p_dt.Rows.Count; r++)
     {
         //create a new row
         string[] row = new string[p_dt.Columns.Count];
         //loop through all columns
         for (int c = 0; c < p_dt.Columns.Count; c++)
         {
             if (p_dt.Rows[r][c].GetType() == typeof(System.Byte[]))
             {
                 // if this value is CCSID65535, change it ;-)
                 iDB2CharBitData cbd = new iDB2CharBitData((Byte[])p_dt.Rows[r][c]);
                 row[c] = cbd.ToString(65535);
             }
             else
             {
                 // else: go on.
                 row[c] = p_dt.Rows[r][c].ToString();
             }
         }
         // passing to the new DataTable.
         dt.Rows.Add(row);
     }
     return dt;
 }
相关文章：