如何在不使用存储函数或过程的情况下使用 C# ODP.NET 中的 Oracle Ref Cursor 作为 ReturnValue 参数？

Question

我需要帮助了解我是否尝试将 Ref 游标用作多个记录/值的 ReturnValue 参数，PL/SQL 只是 OracleCommand 对象的 CommandText 而不是存储过程或函数, 甚至是可能的。

如果这不可能，我想做的是找到一种方法来发出一个 PL/SQL 语句，该语句将更新未知数量的记录（取决于有多少匹配 WHERE 子句），并返回 Id在 OracleDataReader 中更新的所有记录，使用单次往返数据库，不使用存储过程或函数。

我正在使用 ODP.NET 使用 Oracle 11g 与现有的 C# .NET 4.0 代码库进行通信，该代码库使用 SQL 连接来检索/修改数据。我使用的简化测试表定义如下所示：

CREATE TABLE WorkerStatus
(
    Id                  NUMERIC(38)         NOT NULL
    ,StateId            NUMERIC(38)         NOT NULL
    ,StateReasonId      NUMERIC(38)         NOT NULL
    ,CONSTRAINT PK_WorkerStatus PRIMARY KEY ( Id )
)

我用三个测试值预先填充表格，如下所示：

BEGIN
    EXECUTE IMMEDIATE 'INSERT INTO WorkerStatus (Id, StateId, StateReasonId)
                        VALUES (1, 0, 0)';
    EXECUTE IMMEDIATE 'INSERT INTO WorkerStatus (Id, StateId, StateReasonId)
                        VALUES (2, 0, 0)';
    EXECUTE IMMEDIATE 'INSERT INTO WorkerStatus (Id, StateId, StateReasonId)
                        VALUES (3, 0, 0)';
END;

从名为 Oracle_UpdateWorkerStatus2 的脚本文件加载并包含在 OracleCommand.CommandText 中的现有 SQL 语句如下所示：

DECLARE
    TYPE id_array IS TABLE OF WorkerStatus.Id%TYPE INDEX BY PLS_INTEGER;    

    t_ids   id_array;
BEGIN
    UPDATE WorkerStatus
    SET
         StateId = :StateId
        ,StateReasonId = :StateReasonId
    WHERE
        StateId = :CurrentStateId
    RETURNING Id BULK COLLECT INTO t_Ids;
    SELECT Id FROM t_Ids;
END;

我创建了一个小型 C# 测试程序，以尝试隔离我在哪里得到 ORA-01036“非法变量名称/编号”错误，该错误的主体如下所示：

using System;
using System.Configuration;
using System.Data;
using System.Text;
using Oracle.DataAccess.Client;
using Oracle.DataAccess.Types;
namespace OracleDbTest
{
  class Program
  {
    static void Main(string[] args)
    {
        // Load the SQL command from the script file.
        StringBuilder sql = new StringBuilder();
        sql.Append(Properties.Resources.Oracle_UpdateWorkerStatus2);

        // Build and excute the command.
        OracleConnection cn = new OracleConnection(ConfigurationManager.ConnectionStrings["OracleSystemConnection"].ConnectionString);
        using (OracleCommand cmd = new OracleCommand(sql.ToString(), cn))
        {
            cmd.BindByName = true;
            cn.Open();

            OracleParameter UpdatedRecords  = new OracleParameter();
            UpdatedRecords.OracleDbType     = OracleDbType.RefCursor;
            UpdatedRecords.Direction        = ParameterDirection.ReturnValue;
            UpdatedRecords.ParameterName    = "rcursor";

            OracleParameter StateId         = new OracleParameter();
            StateId.OracleDbType            = OracleDbType.Int32;
            StateId.Value                   = 1;
            StateId.ParameterName           = "StateId";

            OracleParameter StateReasonId   = new OracleParameter();
            StateReasonId.OracleDbType      = OracleDbType.Int32;
            StateReasonId.Value             = 1;
            StateReasonId.ParameterName     = "StateReasonId";

            OracleParameter CurrentStateId  = new OracleParameter();
            CurrentStateId.OracleDbType     = OracleDbType.Int32;
            CurrentStateId.Value            = 0;
            CurrentStateId.ParameterName    = "CurrentStateId";

            cmd.Parameters.Add(UpdatedRecords);
            cmd.Parameters.Add(StateId);
            cmd.Parameters.Add(StateReasonId);
            cmd.Parameters.Add(CurrentStateId);

            try
            {
                cmd.ExecuteNonQuery();
                OracleDataReader dr = ((OracleRefCursor)UpdatedRecords.Value).GetDataReader();
                while (dr.Read())
                {
                    Console.WriteLine("{0} affected.", dr.GetValue(0));
                }
                dr.Close();
            }
            catch (OracleException e)
            {
                foreach (OracleError err in e.Errors)
                {
                    Console.WriteLine("Message:\n{0}\nSource:\n{1}\n", err.Message, err.Source);
                    System.Diagnostics.Debug.WriteLine("Message:\n{0}\nSource:\n{1}\n", err.Message, err.Source);
                }
            }
            cn.Close();
        }
        Console.WriteLine("Press Any Key To Exit.\n");
        Console.ReadKey(false);
    }
  }
}

我尝试更改参数名称、命名和不命名 UpdatedRecords 参数、更改顺序以使 UpdatedRecords 位于第一个或最后一个。到目前为止我发现的最接近的是以下 StackOverflow 问题 (How to call an Oracle function with a Ref Cursor as Out-parameter from C#?)，但据我所知，它仍然使用存储函数。

从 SQL Developer 运行 Oracle_UpdateWorkerStatus2 PL/SQL 脚本，它会打开“Enter Binds”对话框，我在上面的代码中输入 CurentStateId、StateId 和 StateReasonId 的值，但它会给出以下错误报告：

Error report:
ORA-06550: line 13, column 17:
PL/SQL: ORA-00942: table or view does not exist
ORA-06550: line 13, column 2:
PL/SQL: SQL Statement ignored
06550. 00000 -  "line %s, column %s:\n%s"
*Cause:    Usually a PL/SQL compilation error.
*Action:

我真的不明白为什么它告诉我该表不存在，当我定义了 WorkerStatus 表并将类型为 id_array 的 t_Ids 变量也声明为表时。非常感谢这里的任何帮助。

Answer 1

我会尝试一个答案而不是另一个评论。

正如我在一条评论中所说，纯/简单的选择语句在 PL/SQL 中不起作用。但是我说错了，你需要一个存储函数来返回一个引用光标。

但首先要做的是：您在 PL/SQL 块中声明的类型“id_array”是 PL/SQL 类型。它不能在引用游标选择语句中使用。相反，您需要一个 SQL 类型：

create type id_array as table of number;

这只需执行一次，就像“创建表”一样。

您的 PL/SQL 块可能如下所示：

DECLARE
    t_ids   id_array;
BEGIN
    UPDATE WorkerStatus
    SET
         StateId = :StateId
        ,StateReasonId = :StateReasonId
    WHERE
        StateId = :CurrentStateId
    RETURNING Id BULK COLLECT INTO t_Ids;

    OPEN :rcursor FOR SELECT * FROM TABLE(cast(t_Ids as id_array));    
END;

PS：
在整理这篇文章时，我意识到 ORA-00942 可能来自哪里。数组 t_ids 基于 PL/SQL 类型，在 SQL 端未知/可用。