java - Java + sqlite3中的交易

我如何在java + sqlite3中进行事务处理，我已经检查过google。我想使其成为回滚语句，因此，如果语句中某处出错，所有语句都将转到“空格”，并且数据库会回滚到开始事务之前的时刻。

像这样Roolback-stmt我希望我的问题是可以理解的。因此请记住，英语不是我的母语。这是我要声明的一部分代码:

ArrayList <String> al = new ArrayList <String> ();
try {
    // transaction begin;
    ResultSet rs = stat.executeQuery("select _id, godziny_id from tblZmiany where harmonogram_id = " + h_id + " order by pracownik_id, Dzien");
    while (rs.next()) {
        al.add("insert into tblWykonanie (Zmiana_id, Godziny_id) values ('" + rs.getLong(1) + "', " + rs.getInt(2) + ");");
    }
    for (String s : al)
        if (stat.executeUpdate(s) < 1) {
            // Jeśli insert nie wstawił kolejnego rekordu
            //rollback;
            error_code = "Wystąpił problem podczas zatwierdzania harmonogramu.";
            return false;
        }
        // commit;
} catch (SQLException e) {
    e.printStackTrace();
    System.out.println(e.getMessage());
    return false;
} catch (Exception e) {
    error_code = e.getMessage();
    return false;
}
return true;

最佳答案

您可以通过两种方式之一在连接级别或通过批处理语句执行此操作。

在连接级别:

final boolean oldAutoCommit = stat.getConnection().getAutoCommit();
stat.getConnection().setAutoCommit(false);

try {
    // Your update and insert code here
} catch(Exception e) {
    stat.getConnection().rollback();
} finally {
    stat.getConnection().commit();
    stat.getConnection().setAutoCommit(oldAutoCommit);
}

错误处理已从伪代码中省略，但是您可以理解。您可能希望避免弄乱连接，而是使用批处理语句:

for(String query: queries) {
    stat.addBatch(query);
}

try {
    stat.executeBatch();
} catch(Exception e) {
    // ...
}

哪个更清洁。请记住，您始终可以通过DatabaseMetaData.supportsBatchUpdates()检查您的数据库/驱动程序是否支持批量事务。