Суботи книжкового клубу

Міська публічна бібліотека проводить «Суботи книжкового клубу» — надзвичайно популярну подію, коли 30–40 учасників приходять о 10:00, щоб узяти свої щомісячні книжки. Поточна система опрацьовує кожну позику окремо з увімкненим автофіксуванням (auto-commit), що створює дві критичні проблеми:

Непослідовність даних: минулого місяця система зависла під час оформлення чотирьох книжок одного учасника. Дві книжки були зафіксовані як видані, а дві — ні, що спричинило розбіжності в обліку та невдоволення відвідувачів.
Вузьке місце в продуктивності: опрацювання кожної позики як окремої транзакції бази даних займає 15–20 хвилин, утворюючи довгі черги та виснажуючи персонал бібліотеки.

Ваше завдання — реалізувати пакетну обробку з контролем транзакцій.

Ця вправа є частиною курсу

Запити до бази даних PostgreSQL у Java

Переглянути курс

Інструкції до вправи

Встановіть autoCommit у значення false, щоб увімкнути ручний контроль транзакцій у рядку 32.
Додайте кілька позик до пакета в рядку 43.
Зафіксуйте транзакцію, якщо всі операції виконалися успішно, у рядку 49.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

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

Редагувати та запускати код