`SELECT ... FOR UPDATE` 锁何时释放？

Question

我正在开发一个允许多个用户访问数据库（MySQL）的程序，并且在不同的时间我得到一个 SQLException: Lock wait timeout exceeded 。

使用以下方式创建连接：

conn = DriverManager.getConnection(connString, username, password);
conn.setAutoCommit(false);

所有调用都通过这段代码：

try { 
    saveRecordInternal(record);
    conn.commit();
} catch (Exception ex) {
    conn.rollback();
    throw ex;
}

saveRecordInternal 有一些内部逻辑，保存给定的记录。一路上的某个地方是我怀疑是问题的方法：

private long getNextIndex() throws Exception {
    String query = "SELECT max(IDX) FROM MyTable FOR UPDATE";
    PreparedStatement stmt = conn.prepareStatement(query);

    ResultSet rs = stmt.executeQuery();
    if (rs.next()) {
        return (rs.getLong("IDX") + 1);
    } else {
        return 1;
    }
}

如果需要，此方法由saveRecordInternal 在其操作过程中的某处调用。 由于目前我无法控制的原因，我不能使用自动增量索引，而且无论如何，某些内部程序逻辑需要插入的索引。

我认为调用conn.commit() 或conn.rollback() 就足以释放锁，但显然不是。所以我的问题是——我应该在getNextIndex 中使用stmt.close() 还是rs.close()？是在事务提交或回滚之前释放锁，还是只是确保在调用conn.commit() 或conn.rollback() 时确实释放了锁？

我还有什么遗漏/完全错误的吗？

编辑：在锁定发生时，所有连接的客户端似乎都有响应，目前没有查询正在进行，但关闭所有连接的客户端确实可以解决问题。这让我认为，即使事务（假设？）通过提交或回滚结束，锁也会以某种方式被保留。

Answer 1

即使不关闭 Statement 或 ResultSet 是个坏主意，但该函数似乎不对您收到的错误负责。函数，getNextIndex() 正在创建本地 Statement 和ResultSet 但不关闭它。在那里关闭它们或在saveRecordInternal() 中创建那些Statement 和ResultSetobjects 并作为参数传递，或者如果在您的起点创建并一次又一次地重用则更好。最后，在不再需要时关闭它们（按以下顺序 - ResultSet, Statement, Connection）。

错误仅表示某个数据库对象（连接、表、行等）上存在锁，而另一个线程/进程同时需要它但必须等待（已锁定）但由于超过预计等待。

请参阅 How to Avoid Lock wait timeout exceeded exception.? 以了解有关此问题的更多信息。

总而言之，这是您的环境特定问题，需要在您的机器上调试并启用大量日志记录。

希望对你有帮助！！

Answer 2

从上面的陈述中，我没有看到任何保持打开状态的锁！ 通常，MySql 应该在调用提交或回滚时或连接关闭时释放锁。

你的情况

SELECT max(IDX) FROM MyTable FOR UPDATE

会导致锁定整个表，但我认为这是预期的逻辑！您锁定表，直到插入新行，然后释放它以让其他人插入。 我会测试：

   SELECT IDX FROM MyTable FOR UPDATE Order by IDX Desc LIMIT 1

确保锁即使在锁定单行时也保持打开状态。

如果不是这种情况，我可能是由于表非常大而导致锁超时。

Answer 3

所以，我认为这里发生的是：您的查询试图在某个表上执行，但该表被另一个进程锁定。因此，在旧锁不会从表中释放之前，您的查询将等待执行，一段时间后如果锁没有释放，您将获得锁超时异常。

您还可以查看表级锁和行级锁。 简而言之：表级锁锁定整个表，直到锁在那里，您希望能够在同一张表上执行任何其他查询。 尽管 行级锁将锁定特定行，因此除了该行之外，您还可以对表执行查询。

您还可以检查是否有任何查询长时间在表上运行，因此您无法执行另一个查询并出现异常。如何检查这将因数据库而异，但您可以通过谷歌搜索您的特定数据库以查找查询以获取数据库上的打开连接或长时间运行的查询。