每周六读书会

Metropolitan 公共图书馆每周都会举办"Book Club Saturdays"活动。该活动非常受欢迎，通常在上午 10 点有 30–40 位会员到馆借阅他们本月的选书。现有系统在启用自动提交的情况下逐条处理每一笔借阅，这带来了两个关键问题：

数据不一致：上个月，系统在处理一位会员一次借 4 本书时崩溃。其中 2 本被记录为已借出，另外 2 本未记录，导致库存不符，读者也非常不满。
性能瓶颈：将每条借阅作为独立的数据库事务处理需要 15–20 分钟，造成长队等待，工作人员也难以应对。

您的任务是实现带有事务控制的批量处理。

本练习是课程的一部分

在 Java 中查询 PostgreSQL 数据库

查看课程

练习说明

在第 32 行将 autoCommit 设置为 false，以启用手动事务控制。
在第 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;
            }
        }
    }
}

编辑并运行代码