JDBC 和并发问题

Question

我想要一些关于 jdbc 并发问题的建议，我基本上需要更新一个值，然后使用更新然后选择检索该值，我假设通过关闭自动提交没有其他事务可以访问此表，因此，在提交之前，其他事务将无法执行更新和选择查询。

下面是一些示例代码。你认为这会奏效吗？还有其他人有更好的解决方案来实现吗？

int newVal=-1;
con.setAutoCommit(false);
PreparedStatement statement = con.prepareStatement("UPDATE atable SET val=val+1 WHERE id=?");
statement.setInt(1, id);
int result = statement.executeUpdate();
if (result != 1) {
    throw new SQLException("Nothing updated");
} else {
    statement = con.prepareStatement("SELECT val FROM atable WHERE id=?");
    statement.setInt(1, id);
    ResultSet resultSet = statement.executeQuery();
    if (resultSet.next()) {
        newVal =  resultSet.getInt("val");
    }
}
statement.close();
con.commit();
con.setAutoCommit(true);

谢谢。

Answer 1

在您的连接上设置autocommit=false 将不会阻止其他连接/线程更改数据库中的行！它只会在对该特定连接进行每次 JDBC 操作后禁用自动提交。

您将需要锁定该行，例如。使用select ... for update 来防止针对该行的其他事务，并且您还需要在单个事务中进行选择和更新。

干杯，

Answer 2

假设您使用某种形式的数据源，如果您需要事务性和隔离级别，您可以在那里进行配置。但要明确：

try(Connection con = ds.getConnection()){
   con.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
   con.setAutoCommit(false);
   //...
} catch(SQLException sqle) {
   throw new MyModelException(e)
}

现在，您可以通过更新表中的版本（或时间戳）字段来触发悲观锁定。这将触发数据库中的锁定（很可能在记录级别）：

try(PreparedStatement pStm = con.prepareStatement("update atable set version=version+1")){
   pStm.executeUpdate();
}

此时，如果另一个用户尝试同时更新同一条记录，则此连接将等待或超时，因此您必须为这两件事做好准备。在您的事务结束（提交或回滚）之前，该记录不会被解锁。

然后，您可以安全地选择和更新您想要的任何内容，并确保在您处理数据时没有其他人接触您的记录。如果其他人尝试，他们将等待直到您完成（或者他们将超时，具体取决于连接配置）。

或者，您可以使用乐观锁定。在这种情况下，您阅读您的记录，对其进行修改，但在更新中，您通过检查版本/时间戳字段与您最初阅读的字段是否相同，确保自从您阅读它以来没有其他人更改过它。在这种情况下，如果您意识到您有过时/过时的数据，您必须准备好重试事务（或全部中止）。

即update atable set afield=? where id=? and version=1

如果受影响的行数为 0，那么您知道该记录很可能在您读取和更新之间发生了更新，并且该记录不再是版本 1。