Book Club del sabato

La Metropolitan Public Library organizza i "Book Club del sabato", un evento molto apprezzato in cui 30-40 membri arrivano alle 10 per prendere i loro libri del mese. Il sistema attuale elabora ogni prestito singolarmente con l'auto-commit attivo, creando due problemi critici:

Inconsistenza dei dati: Il mese scorso, il sistema è andato in crash mentre elaborava il prestito di quattro libri di un membro. Due libri sono stati registrati come prestati, ma gli altri due no, causando discrepanze nell'inventario e frustrazione tra gli utenti.
Collo di bottiglia prestazionale: Elaborare ogni prestito come una transazione separata richiede 15-20 minuti, creando lunghe code e personale della biblioteca insoddisfatto.

La tua missione è implementare l'elaborazione in batch con controllo delle transazioni.

Questo esercizio fa parte del corso

Eseguire query su un database PostgreSQL in Java

Visualizza il corso

Istruzioni dell'esercizio

Imposta autoCommit su false per abilitare il controllo manuale delle transazioni alla riga 32.
Aggiungi più prestiti al batch alla riga 43.
Esegui il commit della transazione se tutte le operazioni hanno successo alla riga 49.

Esercizio pratico interattivo

Prova a risolvere questo esercizio completando il codice di esempio.

public class BatchLoanProcessor {
    private static final String DB_URL = "jdbc:postgresql://localhost:5432/library_db";
    private static final String USERNAME = "postgres";
    private static final String PASSWORD = "postgres";
    
    public static void main(String[] args) {
        Object[][] loanData = {
            {1, 1, LocalDate.now(), LocalDate.now().plusDays(14), "borrowed"},
            {2, 2, LocalDate.now(), LocalDate.now().plusDays(14), "borrowed"},
            {3, 3, LocalDate.now(), LocalDate.now().plusDays(7), "borrowed"},
            {4, 1, LocalDate.now(), LocalDate.now().plusDays(14), "borrowed"}
        };
        
        try {
            boolean success = processBatchLoans(loanData);
            if (success) {
                System.out.println("All loans were processed successfully.");
            } else {
                System.out.println("Loan processing failed. Transaction was rolled back.");
            }
        } catch (SQLException e) {
            System.err.println("Database error: " + e.getMessage());
            e.printStackTrace();
        }
    }
    
    public static boolean processBatchLoans(Object[][] loanData) throws SQLException {
        String insertSQL = "INSERT INTO loans (book_id, member_id, loan_date, due_date, status) VALUES (?, ?, ?, ?, ?)";
        
        try (Connection conn = DriverManager.getConnection(DB_URL, USERNAME, PASSWORD)) {
            // Set autoCommit to false
            conn.____(____);
            
            try (PreparedStatement pstmt = conn.prepareStatement(insertSQL)) {
                for (Object[] loan : loanData) {
                    pstmt.setInt(1, (Integer) loan[0]);  
                    pstmt.setInt(2, (Integer) loan[1]);  
                    pstmt.setDate(3, java.sql.Date.valueOf((LocalDate) loan[2]));  
                    pstmt.setDate(4, java.sql.Date.valueOf((LocalDate) loan[3]));  
                    pstmt.setString(5, (String) loan[4]);  
                    
                    // Add to batch
                    pstmt.____();
                }
                
                int[] results = pstmt.executeBatch();
                                
                // Commit the transaction if all operations are successful
                conn.____();
                
                return true;
            } catch (SQLException e) {
                conn.rollback();
                
                System.err.println("Error during batch processing: " + e.getMessage());
                return false;
            }
        }
    }
}

Modifica ed esegui il codice