使用 Oracle 客户端在 oracle db 中高效插入多条记录

Question

我有 C#-WCF/Winforms 应用程序。它使用 Oracle 客户端 API 和具有简单插入查询的存储过程在 Oracle 数据库的临时表中插入 450,000 多条记录。 在数据库中插入记录大约需要 15 分钟，有时记录也不会被插入。在 wcf 端出现各种超时错误。 有没有什么有效的方法来做这些插入？

感谢阅读。

这是我的批量插入代码：

OracleTransaction tran = null; 
UpdateRowSource oldURS = this.cmd.UpdatedRowSource; 
OracleCommand oldCmd = this.dbAdapter.InsertCommand; 
int oldUBS = this.dbAdapter.UpdateBatchSize; 
try 
{ 
    SetOutputParams(); 
    this.OpenDBConnection(); 
    tran = this.dbConn.BeginTransaction(); 
    this.cmd.Transaction = tran; 
    this.cmd.UpdatedRowSource = UpdateRowSource.OutputParameters; 
    this.dbAdapter.InsertCommand = this.cmd; 
    this.dbAdapter.UpdateBatchSize = size; 
    this.dbAdapter.Update(data); 
    tran.Commit(); 
    SetOutputParamValues(); 
} 
catch (OracleException ex) 
{ 
    if (tran != null) { 
        tran.Rollback(); 
    } 
    throw; 
} 
finally 
{ 
    this.CloseDBConnection(); 
    this.cmd.Parameters.Clear(); 
    this.cmd.UpdatedRowSource = oldURS; 
    this.dbAdapter.InsertCommand = oldCmd; 
    this.dbAdapter.UpdateBatchSize = oldUBS; 
} 

}

Answer 1

将数据加载到表中的最快方法是 datapump（impdp 实用程序）。 另一种快速方法是 SQL*Loader。

如果您想坚持使用 C#，请查看批量操作。 我的 google 业力找到了the following examples

Answer 2

我经常从 C# 使用 SQL*Loader 将记录批量加载到阶段。

代码的内容是这样的：

public string RunSqlLdr(string user, string password, string dsn, string fileNameCtl, string fileNameLog)
{
    // Redirect both streams so we can write/read them.
    var cmdProcessInfo = new System.Diagnostics.ProcessStartInfo("cmd.exe")
    {
        RedirectStandardInput = true,
        RedirectStandardOutput = true,
        UseShellExecute = false
    };

    // Start the process. 
    var process = System.Diagnostics.Process.Start(cmdProcessInfo);

    // Issue the sqlldr command and exit.
    process.StandardInput.WriteLine("cd " + _directoryPath);
    process.StandardInput.WriteLine("sqlldr " + user + "/" + password + "@" + dsn + " control=" + fileNameCtl + " log=" + fileNameLog);
    process.StandardInput.WriteLine("exit");

    // Read all the output generated from it.
    var output = process.StandardOutput.ReadToEnd();
    process.Dispose();

    return output;
}

这将返回命令行的输出，但您还需要检查生成的日志文件中的加载记录和错误计数等。

Answer 3

我将大量数据插入到位于澳大利亚的 Oracle 数据库中，远离我在 C# 中运行客户端应用程序的地方。

这是我如何做的总结。使用数组绑定插入数十万条记录的速度之快让我感到惊讶。

这不是确切的代码，但你明白了：

using System.Data.OleDb;

int numRecords = 2;
int[] DISTRIBNO = new int[numRecords];
DISTRIBNO[0] = 100;
DISTRIBNO[1] = 101;

string sql = "INSERT INTO Distributors (distribno) VALUES (:DISTRIBNO)";
cnn = new Oracle.DataAccess.Client.OracleConnection(conString);
cnn.Open();

using (Oracle.DataAccess.Client.OracleCommand cmd = cnn.CreateCommand())
{
    cmd.CommandText = sql;
    cmd.CommandType = CommandType.Text;
    cmd.BindByName = true;
    // To use ArrayBinding, we need to set ArrayBindCount                
    cmd.ArrayBindCount = numRecords;
    cmd.CommandTimeout = 0;

    cmd.Parameters.Add(
              ":DISTRIBNO", 
              Oracle.DataAccess.Client.OracleDbType.Int32, 
              BR_VOLMONTH,
              ParameterDirection.Input);

    cmd.ExecuteNonQuery();
}//using

卡洛斯·梅里赫。

Answer 4

您可能必须放弃“DataAdapter”代码才能获得真正的性能。

这是似乎是目标的 dotnet 类。

Oracle.DataAccess.Client.OracleBulkCopy

OracleBulkCopy 类

OracleBulkCopy 对象有效地将数据从另一个数据源批量加载或复制到 Oracle 表中。

https://docs.oracle.com/cd/E11882_01/win.112/e23174/OracleBulkCopyClass.htm#ODPNT7446

https://docs.oracle.com/cd/E85694_01/ODPNT/BulkCopyCtor3.htm

…………

这是来自（oracle 拥有的）ODP.NET。

见

https://www.nuget.org/packages/Oracle.ManagedDataAccess/