java - java + sqlite3 中的事务

Question

我怎样才能在java + sqlite3中进行事务我已经检查了谷歌。我想将其设为回滚语句，因此如果语句中的某个地方出错，所有语句都会转到“空间”并且数据库回滚到开始事务之前的时刻.

这里有类似的东西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;

Answer 1

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

在连接级别:

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()检查您的数据库/驱动程序是否支持批量事务。