前端之家

  1. 首页
  2. 问答

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

• 问答

我正在尝试使用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设置为{{ 1}}或将Object设置为CollectionType都没有成功。同样，传递列表或对象数组而不是表也没有成功。

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

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

liqzone 回答：Oracle Entity Framework Core将表参数传递给存储过程

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

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

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帮助我实现了每列一个数组的批量插入方法。该线程还包含有关该主题的进一步讨论和更通用的方法。

.net-coreef-core-2.2odp.netoraclestored-procedures
本文链接：https://www.f2er.com/3136548.html

大家都在问