3

我正在尝试进行一些测试以了解如何使用事务隔离级别来解决各种并发问题。我从 开始TRANSACTION_READ_COMMITED，但最简单的情况并不符合我的预期。这是代码：

try(Connection connection1 = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD)) {
    connection1.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
    connection1.setAutoCommit(false);

    try(Connection connection2 = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD)) {
        connection2.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
        connection2.setAutoCommit(false);

        assertEquals(0, selectAll(connection1));
        assertEquals(0, selectAll(connection2));

        insertOne(connection1);
        assertEquals(0, selectAll(connection2)); // there is 1 row!
    }
}

在这里，我设置了 2 个并发连接，在这两个连接中启动事务，在第一个连接中进行更改，并希望在第二个连接中看不到它们。这不起作用：在连接 1 中所做的未提交更改对连接 2 可见。

我使用以嵌入式模式运行的 HSQLDB 2.3.2 和内存数据库。以下是我的 selectAll/insert 辅助方法的实现：

private static void initSchema() throws SQLException {
    try(Connection connection = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD)) {
        try (PreparedStatement s = connection.prepareStatement(
                "create table Notes(text varchar(256) not null)")) {
            s.executeUpdate();
        }
    }
}

private static int selectAll(Connection connection) throws SQLException {
    int count = 0;
    try (PreparedStatement s = connection.prepareStatement("select * from Notes")) {
        s.setQueryTimeout(1);
        try (ResultSet resultSet = s.executeQuery()) {
            while (resultSet.next()) {
                ++count;
            }
        }
    }

    return count;
}

private static void insertOne(Connection connection) throws SQLException {
    try(PreparedStatement s = connection.prepareStatement("insert into Notes(text) values(?)")) {
        s.setString(1, "hello");
        s.setQueryTimeout(1);
        s.executeUpdate();
    }
}

完整的测试可以在这里找到：https ://gist.github.com/loki2302/aad49a5a2c26d5fda2b3

这段代码有问题，还是 HSQLDB 的行为不符合预期？

更新：重新阅读wiki后，我相信我的想法是错误的。我在这里看到的是“幻读”。READ_COMMITTED不保证幻读永远不会发生。相反，我应该检查的是，用单行预先填充表，通过更新它connection1并确保此更改不可见，connection2除非更改已提交。此外，通常不能保证此更改在提交后立即可见：它可能会变得可见，但不能保证。

4

1 回答 1

1

您的进程内数据库设置不适合您正在执行的测试。

替代方案是：

  1. 尝试运行服务器并使用 MVCC 重复测试。
  2. 尝试为与 MVCC 和进程内数据库的每个连接使用单独的线程。

当在进程内使用时，如您的示例，HSQLDB 要求每个连接都由单独的线程拥有。否则 Java 并发特性将无法工作。

当使用单独的线程运行时，您需要使用 MVCC 事务模型才能使其工作。在您使用的默认锁定模式下，插入将锁定另一个连接，直到提交。

于 2015-01-31T23:09:33.710 回答