Effizient einfügen mehrerer Datensätze in oracle-db mittels Oracle-client

Habe ich C#-WCF/Winforms-Anwendung.Es fügt plus von 450.000 Datensätze in eine staging-Tabelle in der Oracle-Datenbank mit Oracle-Client-API und eine gespeicherte Prozedur mit einem einfachen insert-Abfrage.
Das dauert etwa 15 Minuten, zum einfügen von Datensätzen in die db und manchmal werden die Datensätze nicht eingefügt zu..geben alle Arten von timeout-Fehler bei der wcf-Seite.
Gibt es eine effiziente Art, das zu tun diese Einsätze?

Vielen Dank für das Lesen.

Hier ist mein code, funktioniert die Batchdatei einfügen:

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; 
}

}

in C# verwenden zu werfen und nicht werfen ex oder Ihre StackTrace wird versaut: stackoverflow.com/questions/178456/...
ja, einverstanden, Davide.Ich werfen; statt.Danke.

InformationsquelleAutor user74042 | 2011-10-03

  1. 1

    Die Schnellste Möglichkeit zum laden von Daten in eine Tabelle ist datapump (impdp-Dienstprogramm).
    Ein weiterer schneller Weg ist SQL*Loader.

    Wenn Sie wollen stick mit C#, Blick in bulk-Operationen.
    Meine google-karma gefunden die folgenden Beispiele

    InformationsquelleAutor Klas Lindbäck

  2. 0

    Habe ich verwendet SQL*Loader Häufig von C# zu bulk-load records auf die Bühne.

    Dem Fleisch der code geht so:

    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;
}

    Das liefert die Ausgabe der Befehlszeile, aber Sie werden auch prüfen wollen, die erzeugte log-Datei für die Datensätze geladen und die Fehler-zählt etc..

    InformationsquelleAutor manadart

  3. 0

    Ich bin das einfügen einer Menge von Daten in einer Oracle-Datenbank gespeichert ist, die in Australien, weit entfernt von wo ich bin läuft die client-Anwendung in C#.

    Hier ist die Zusammenfassung, wie ich bin, es zu tun. Es erstaunt mich, wie schnell ich stecken Hunderte oder Tausende von Datensätzen schnell mittels array-binding.

    Dies ist nicht der exakte code, aber Sie bekommen die Idee:

    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

    Carlos Merighe.

    InformationsquelleAutor Carlos A Merighe

Schreibe einen Kommentar