JDBC und Threading

Question

Ich habe ein Programm, das eine Datenbank in einem bestimmten Intervall abfragen muss und mit den Datensätzen, die es ruft, eine Aktion ausführen und dann die Tabelle erneut aktualisieren.

Ich benutze den ExecutorService, um die Threads auszuführen, aber wundere mich, sollte jeder Thread eine eigene Verbindung erhalten (weil es Datenbank aktualisieren muss) oder kann ich die gleiche Verbindung verwenden, die ich verwendet, um die ersten Ergebnisse abzufragen?

Kann Verbindung Pooling arbeiten, bin auf Oracle 9i.

Answer 1

Sie sollten immer eine separate Verbindung für separate Threads verwenden, da die Treiber auf diese Weise nicht Thread-sicher sind. Ein Verbindungspool könnte Ihnen helfen, da er die Wiederverwendung von Verbindungen auf sichere Weise ermöglicht.

Sie könnten auch ein Abfrage-Dispatch-Muster erstellen - wenn ich Ihr Problem richtig verstehe -, wo ein Thread für die Abfrage und Starts von N Threads verantwortlich ist, die die Datenbank aktualisieren können - die alle separate Verbindungsobjekte haben.

Sie können auch ein Batch-Update über das PreparedStatement betrachten zu tun, so Fäden auf sich in Bezug auf den Zeilen- und Tabellensperren stolpern nicht, die folgende Struktur verwendet:

• 1 Abfrage Thread
• NCPU Verarbeitungsthreads
• 1 Batch-Update-Thread

wie ein Mini-db gabel verbinden.

bearbeiten

Beispiele, wie man mit Pstmt Batch-Update zu tun:

PreparedStatement pstmt = connection.prepareStatement(
    "UPDATE table SET field=? WHERE id=?"); 
for (int i = 0; i < 100; i++) { 
    pstmt.setInt(1, i * i); 
    pstmt.setInt(2, i); 
    pstmt.addBatch(); 
} 
pstmt.executeBatch(); 
pstmt.close(); 

Oder Sie eine Warteschlange in der Schleife nicht abfragen, wo die Update-Anfragen von den Verarbeitungsthreads ankommen:

class WhatToUpdate { 
    public int id; 
    public int value; 
} 
Queue<WhatToUpdate> queue = new LinkedBlockingQueue<WhatToUpdate>(); 

PreparedStatement pstmt = connection.prepareStatement(
    "UPDATE table SET field=? WHERE id=?"); 

int poisons = THE_NUMBER_OF_PROCESSING_THREADS; 
while (true) { 
    WhatToUpdate record == queue.take(); 
    if (record == null) { // poison pill 
     if (--poisons <= 0) { 
      break; 
     } 
    } 
    pstmt.setInt(1, record.value); 
    pstmt.setInt(2, record.id); 
    pstmt.addBatch(); 
} 
pstmt.executeBatch(); 
pstmt.close(); 

Answer 2

Wenn Sie den Code für die Oracle JDBC OracleConnection und OraclePreparedStatement betrachten, m Die wichtigsten Methoden sind synchronisiert, so dass sie "threadsicher" sind. Die Verwendung einer einzelnen Connection über mehrere Threads hinweg bietet Ihnen nicht die größte Effizienz, da jeder Thread auf die Operationen der Connection und PreparedStatement (insbesondere execute) warten muss, bevor er seine eigenen Aktionen ausführt.