Oracle Entity Framework Core将表参数传递给存储过程

Question

我正在尝试使用Oracle.EntityFrameworkCore包将参数传递给存储过程，如下所示：

DataTable table = new DataTable();
table.Columns.Add("keyColumn", typeof(string));
table.Columns.Add("valueColumn", typeof(string));

var row = table.NewRow();
row.ItemArray = new object[]
{
    entry.KeyColumn,
    entry.ValueColumn
};

table.Rows.Add(row);

var parameter = new OracleParameter("entries",table);
parameter.UdtTypeName = "entry_type_list";


return context.Database.ExecuteSqlCommandAsync(
    new RawSqlString( @"EXEC set_entry_list (:entries)" ),
    parameter);

存储过程和类型的定义如下：

CREATE OR REPLACE TYPE entry_type AS OBJECT
(
"keyColumn" NVARCHAR2(3), 
"valueColumn" NVARCHAR2(3)
);

CREATE OR REPLACE TYPE entry_type_list AS TABLE OF entry_type;

CREATE OR REPLACE PROCEDURE set_entry_list (entries entry_type_list) AS
BEGIN
REM Doing stuff
END;

但出现错误：

System.ArgumentException：值不在预期范围内。在Oracle.ManagedDataAccess.Client.OracleParameter..ctor（String parameterName，Object obj）

唯一的来源是an answer如何使用SQL Server进行此操作，但对于使用EFCore的Oracle则没有答案。这里的问题似乎是Oracle仅接受OracleParameter，而其他人则使用SqlParameter。

如果我使用这样的SqlParameter类型：

var parameter = new SqlParameter("entries", SqlDbType.Structured);
parameter.TypeName = "entry_type_list";
parameter.Value = table;

我收到此错误：

System.InvalidCastException：无法将类型为'System.Data.SqlClient.SqlParameter'的对象转换为类型为'Oracle.ManagedDataAccess.Client.OracleParameter'。

[我也曾尝试将parameter.OracleDbType设置为不同的值，例如Blob，RefCursor，Clob或XmlType，将parameter.DbType设置为Object或将CollectionType设置为PLSQLAssociativeArray，但均未成功。同样，传递列表或对象数组而不是表也没有成功。

我目前不知道我还能尝试什么。

任何以高性能方式将大量实体传递给存储过程的方法都将有所帮助。我将它们与merge-command一起使用，因此我需要能够将这些参数转换为表。

Answer 1

我现在找到了使用临时表并将此表用作输入参数的解决方案。

由于我无法传递完整的表，但是我必须通过为每一列传递一个数组来填充此简单对象数组：

var keyColumn = new OracleParameter( "keyColumn", OracleDbType.Decimal );
keyColumn.Value = values.Select( c => c.KeyColumn).ToArray();
var valueColumn = new OracleParameter( "valueColumn", OracleDbType.Decimal );
valueColumn = values.Select( c => c.ValueColumn).ToArray();

using ( var transaction = this.dbContext.Database.BeginTransaction( IsolationLevel.ReadCommitted) )
{
    var connection = this.dbContext.Database.GetDbConnection() as OracleConnection;
    OracleCommand cmd = connection.CreateCommand();

    cmd.CommandText = @"
        INSERT INTO TMP_TABLE 
        (
        ""keyColumn"",
        ""valueColumn""
        )
        VALUES (
        :keyColumn,
        :valueColumn)";
    cmd.Parameters.Add( keyColumn ); 
    cmd.Parameters.Add( valueColumn );
    cmd.ArrayBindCount = values.Length;
    var insertCount = await cmd.ExecuteNonQueryAsync();


    cmd = connection.CreateCommand();
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.CommandText = "dbo.stored_procedure";

    var result = await cmd.ExecuteNonQueryAsync();
    transaction.Commit();
}

我创建了这样的临时表：

CREATE
GLOBAL TEMPORARY TABLE "dbo"."TMP_TABLE"
ON COMMIT DELETE ROWS
 AS SELECT * FROM "dbo"."REAL_TABLE" WHERE 0=1;

并更改了存储过程以使用它：

CREATE OR REPLACE PROCEDURE stored_procedure AS 
BEGIN
    REM use the "dbo"."TMP_TABLE"
END;

This answer帮助我实现了每列一个数组的批量插入方法。该线程还包含有关该主题的进一步讨论和更通用的方法。

我将继续公开这个问题-如果有人有更好（不太复杂）的方式，我将接受他的回答。