读取已提交隔离级别不起作用

Question

我正在尝试了解 ACID 隔离原则。我已经编写了这部分代码：

ExecutorService executorService = Executors.newSingleThreadExecutor();

        Runnable t2 = () -> {
            System.out.println("Thread: " + Thread.currentThread().getName());
            Connection connection;

            try {
                connection = this.iDatabaseConnector.getConnection();

                PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM mssmbank.mssmbank.bankaccounts WHERE id = ?");
                preparedStatement.setInt(1, 490);

                ResultSet resultSet = preparedStatement.executeQuery();
                resultSet.next();

                System.out.println("Result: " + resultSet.getDouble("BALANCE"));

                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        };

        Runnable t1 = () -> {
            System.out.println("Thread: " + Thread.currentThread().getName());
            Connection connection;

            try {
                connection = this.iDatabaseConnector.getConnection();
                connection.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
                connection.setAutoCommit(false);

                PreparedStatement preparedStatement = connection.prepareStatement("UPDATE mssmbank.mssmbank.bankaccounts " + "SET balance = ? WHERE id = ?");
                preparedStatement.setDouble(1, (new Random()).nextInt(1000));
                preparedStatement.setInt(2, 490);
                preparedStatement.executeUpdate();

                ExecutorService executorService1 = Executors.newSingleThreadExecutor();
                executorService1.execute(t2);

                Thread.sleep(3_000);

                connection.commit();
                connection.close();

                executorService1.shutdown();
                executorService1.awaitTermination(20, TimeUnit.SECONDS);
            } catch (SQLException | InterruptedException e) {
                e.printStackTrace();
            }
        };

        executorService.execute(t1);
        executorService.shutdown();
        executorService.awaitTermination(20, TimeUnit.SECONDS);

有 2 个线程，t1 和 t2。 t1 应该更新数据库中的银行帐户行，t2 应该读取其余额。

以下是场景：t1 启动、打开连接、进行更新并且不提交。它会触发 t2 和 sleeps 3 秒。

t2 启动，打开连接，读取余额并打印（基本上是旧的，因为 t1 尚未提交）然后关闭连接。

然后t1通过提交更新结束，程序结束。

我期望发生的是，t2 被阻止，直到 t1 完成提交，因为 t2 正在访问同一个银行帐户行（t1 应该已锁定该行以进行更新）。因此，t2 应该打印了 #490 银行账户的更新余额，而不是之前的余额。

为什么t1 不锁定行？为什么 t2 没有被阻止？ 请注意，隔离级别设置为TRANSACTION_READ_COMMITTED。

Answer 1

t2 中的 select 语句没有被阻塞，因为它只是尝试读取而不是写入。如果您要尝试执行更新（或选择...进行更新），那么如果您的超时设置为在放弃之前等待一段时间，它可能会阻塞。你没有提到你正在使用哪个数据库，但这里有一些关于 Postgres 如何处理锁定的好文档： https://www.postgresql.org/docs/current/explicit-locking.html