3

我有一个在多台计算机上运行的 java 应用程序，它们都连接到同一个 MySQL 数据库。我需要事务以确保正确更新数据库。

我在释放锁时遇到问题。这是代码：

public boolean bookSeats(int numeroSala, Calendar dataOra, List<Posto> posti) {
    JDBConnection connection = JDBConnection.getDbConnection();
    Connection conn = connection.conn;
    java.sql.Date javaSqlDate = new java.sql.Date(dataOra.getTime().getTime());
    java.sql.Time javaSqlTime = new java.sql.Time(dataOra.getTime().getTime());

    try {
        conn.setAutoCommit(false);
        conn.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
    } catch (SQLException e) {
        e.printStackTrace();
    }

    try
    {
        Posto p = null;
        ListIterator<Posto> itr = posti.listIterator();
        PreparedStatement stmt = null;
        stmt = conn.prepareStatement(
            "INSERT INTO sala?_tickets " + 
            "(giornoSpettacolo, orarioSpettacolo, fila, posto) " + 
            "VALUES (?, ?, ?, ?)");

        stmt.setInt(1, numeroSala);
        while(itr.hasNext())
        {
            p = itr.next();
            stmt.setString(2, javaSqlDate.toString()); // giornoSpettacolo
            stmt.setString(3, javaSqlTime.toString()); // orarioSpettacolo
            stmt.setInt(4, p.getFila()); // fila
            stmt.setInt(5, p.getNumero()); // posto
            stmt.addBatch();
        }

        stmt.executeBatch();

        conn.commit();
        return true;
    }
    catch (SQLException e) {
        e.printStackTrace();
    }

    return false;
}

此方法工作正常，但是当我尝试同时在另一台计算机上执行此方法时，即使conn.commit()已完成，我也会收到 DEADLOCK 错误。

一旦我关闭第一个应用程序，另一个应用程序就可以运行该方法而不会出现死锁错误。好像 COMMIT 没有释放锁？

4

4 回答 4

3

根据 MySQL 文档，关于 SERIALIZABLE：

此级别类似于 REPEATABLE READ，但如果禁用自动提交，InnoDB 会将所有普通 SELECT 语句隐式转换为 SELECT ... LOCK IN SHARE MODE。

您可能想在提交后尝试重新启用自动提交，或尝试连接。REPEATABLE_READ 代替。

于 2012-05-11T01:41:11.160 回答
1

您可以参考此文档以了解如何使用裸 JDBC 进行事务。希望能帮助到你。

于 2012-05-11T01:38:21.550 回答
0

您应该始终conn.close()在一个finally块中执行 a 以确保释放您的方法使用的任何资源。

于 2012-05-11T01:40:53.597 回答
0

是的，按照第一个答案的说明关闭连接。但是，此外，如果您可以将上述代码放入“同步”方法中，它将确保一次只有一个线程可以访问它。

除此之外，只需看看下面的链接，它讨论了 JDBC 中的死锁处理

Java中的死锁检测

于 2012-05-11T07:19:23.150 回答