如何使用 jdbc 和 JUNIT 创建数据库死锁

Question

我正在尝试创建数据库死锁并且我正在使用 JUnit。我正在运行两个并发测试，它们都在循环中一遍又一遍地更新表中的同一行。

我的想法是，您在一次测试中一遍又一遍地更新表 A 中的 A 行，然后再更新表 B 中的 B 行。然后同时您一遍又一遍地更新 B 行表 B 和 A 行表 A。据我了解，这最终会导致死锁。

这是第一次测试的代码。

public static void testEditCC()
{
    try{
        int rows = 0;
        int counter = 0;
        int large=10000000;
        Connection c=DataBase.getConnection();
        while(counter<large)
        {
            int pid = 87855;
            int cCode = 655;
            String newCountry="Egypt";              
            int bpl = 0;
            stmt = c.createStatement();

            rows = stmt.executeUpdate("UPDATE main " +              //create lock on main table
                                                  "SET BPL="+cCode+
                                                  "WHERE ID="+pid);
            rows = stmt.executeUpdate("UPDATE BPL SET DESCRIPTION='SomeWhere' WHERE ID=602"); //create lock on bpl table
            counter++;
        }

        assertTrue(rows == 1);
        //rows = stmt.executeUpdate("Insert into BPL (ID, DESCRIPTION) VALUES ("+cCode+", '"+newCountry+"')");

    }
    catch(SQLException ex)
    {
        ex.printStackTrace();
        //ex.getMessage();
    }
}

这是第二次测试的代码。

public static void testEditCC()
{
    try{
        int rows = 0;
        int counter = 0;
        int large=10000000;
        Connection c=DataBase.getConnection();
        while(counter<large)
        {
            int pid = 87855;
            int cCode = 655;
            String newCountry="Jordan";         
            int bpl = 0;
            stmt = c.createStatement();
            //stmt.close();
            rows = stmt.executeUpdate("UPDATE BPL SET DESCRIPTION='SomeWhere' WHERE ID=602"); //create lock on bpl table
            rows = stmt.executeUpdate("UPDATE main " +          //create lock on main table
                                                  "SET BPL="+cCode+
                                                  "WHERE ID="+pid);
            counter++;
        }

        assertTrue(rows == 1);
        //rows = stmt.executeUpdate("Insert into BPL (ID, DESCRIPTION) VALUES ("+cCode+", '"+newCountry+"')");

    }
    catch(SQLException ex)
    {
        ex.printStackTrace();
    }
}

我同时运行这两个单独的 JUnit 测试，并连接到我在 Eclipse 中以网络模式运行的 apache Derby 数据库。谁能帮我弄清楚为什么没有发生死锁？也许我用错了 JUnit。

Answer 1

您应该检查事务隔离级别，因为它决定了数据库是否锁定了事务所触及的行。如果隔离级别太低，则不会发生锁定，因此也不会出现死锁。

更新： 根据this page，Derby 的默认 tx 隔离级别是已提交读，应该没问题。顺便说一句，该页面值得一读，因为它解释了 tx 隔离及其不同级别，以及它解决了哪些问题。

接下来的问题是：您的代码中的DataBase 是什么？这似乎是一种非标准的连接方式。

Update2：我想我明白了。引用the API doc:

注意：默认情况下，Connection 对象处于自动提交模式，这意味着它会在执行每条语句后自动提交更改。如果自动提交模式已被禁用，则必须显式调用 commit 方法以提交更改；否则，数据库更改将不会被保存。

换句话说，行不会被锁定，因为您的有效事务仅在单个更新的生命周期内持续。您应该在开始使用您的连接之前关闭自动提交：

Connection c=DataBase.getConnection();
c.setAutoCommit(false);