Sábados do Clube do Livro

A Biblioteca Pública Metropolitana promove os "Sábados do Clube do Livro", um evento superpopular em que 30–40 membros chegam às 10h para pegar suas leituras do mês. O sistema atual processa cada empréstimo individualmente com auto-commit ativado, criando dois problemas críticos:

Inconsistência de dados: No mês passado, o sistema travou enquanto processava o empréstimo de quatro livros de um membro. Dois livros foram registrados como emprestados, mas os outros dois não, causando discrepâncias no acervo e frustração entre os usuários.
Gargalo de desempenho: Processar cada empréstimo como uma transação separada no banco de dados leva de 15 a 20 minutos, gerando filas longas e deixando a equipe da biblioteca sobrecarregada.

Sua missão é implementar processamento em lote com controle de transações.

Este exercício faz parte do curso

Consultando um banco de dados PostgreSQL em Java

Ver curso

Instruções do exercício

Defina autoCommit como false para habilitar o controle manual da transação na linha 32.
Adicione vários empréstimos ao lote na linha 43.
Faça o commit da transação se todas as operações forem bem-sucedidas na linha 49.

Exercício interativo prático

Experimente este exercício completando este código de exemplo.

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

Editar e executar o código