Sobotní čtenářský klub

Metropolitní veřejná knihovna pořádá „Sobotní čtenářský klub" – mimořádně oblíbenou akci, na kterou každou sobotu v 10 hodin přichází 30–40 členů, aby si vybrali své měsíční tituly. Současný systém zpracovává každou půjčku zvlášť s povoleným auto-commitem, což způsobuje dva zásadní problémy:

Nekonzistence dat: Minulý měsíc systém spadl během zpracování výpůjčky čtyř knih jednoho člena. Dvě knihy se zaznamenaly jako půjčené, ale zbývající dvě ne – to vedlo k nesrovnalostem ve skladu a zklamaným čtenářům.
Výkonnostní úzké hrdlo: Zpracování každé půjčky jako samostatné databázové transakce trvá 15–20 minut, tvoří se dlouhé fronty a personál knihovny je nespokojený.

Tvým úkolem je implementovat dávkové zpracování s řízením transakcí.

Toto cvičení je součástí kurzu

Dotazování PostgreSQL databáze v Javě

Zobrazit kurz

Pokyny k cvičení

Na řádku 32 nastav autoCommit na false, čímž povolíš ruční řízení transakcí.
Na řádku 43 přidej několik půjček do dávky.
Na řádku 49 potvrď transakci, pokud všechny operace proběhly úspěšně.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

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

Upravit a spustit kód