甲骨文 - 如何正确执行交易

Question

我的陈述：

statement.addBatch("START TRANSACTION;" +
                "UPDATE FIRST_TABLE SET FIRST_FIELD = 1;" +
                "UPDATE SECOND_TABLE SET SECOND_FIELD = 2;" +
                "UPDATE THIRD_TABLE SET THIRD_FIELD = 3;" +
                "COMMIT;");

异常在下一行中抛出：

statement.executeBatch();

如果我使用以下方法execute也会发生同样的事情：

statement.execute(myTransaction);

例外情况：

java.sql.BatchUpdateException: ORA-00900: invalid SQL statement

我使用甲骨文。如果我在命令行或 SQL IDE 中执行此语句，我没有任何例外。在这种情况下，它可以正常工作。仅在 java 代码中存在此例外。怎么了？

Answer 1

尝试，

connection.setAutoCommit(false);
statement.addBatch("UPDATE FIRST_TABLE SET FIRST_FIELD = 1");
statement.addBatch("UPDATE SECOND_TABLE SET SECOND_FIELD = 2");
statement.addBatch("UPDATE THIRD_TABLE SET THIRD_FIELD = 3");
int [] counts = statement.executeBatch();
connection.commit();

Answer 2

尝试将每个更新语句添加到单独的addBatch()

Answer 3

通常，您将使用连接的setAutoCommit（）方法来启动事务，运行语句，最后适当地调用commit（）或rollback（）。这是一种与数据库无关的事务处理方式。不确定，为什么要为相同的SQL构建！您能详细说明一下您的用例吗？

Connection con = dataSource.getConnection();
try {
    con.setAutoCommit(false);
    Statement stmt = con.prepareStatement("<your update statement with placeholders for  parameters");
    stmt.set(1, <Value1>);
    stmt.set(2, <Value2>);
    stmt.execute();
    con.commit();
}
catch (SQLException sqle) {
    // Handle the exception
    con.rollback();
}
finally {
    con.close();
}

注意：在获取连接和关闭连接时，上面的代码中有许多极端情况需要处理，暂时省略以使它看起来很简单！

Answer 4

作为旁注，为了创建一批 SQL，您必须将每个语句分别添加到批处理中。

因此，而不是：

     statement.addBatch("START TRANSACTION;" +
            "UPDATE FIRST_TABLE SET FIRST_FIELD = 1;" +
            "UPDATE SECOND_TABLE SET SECOND_FIELD = 2;" +
            "UPDATE THIRD_TABLE SET THIRD_FIELD = 3;" +
            "COMMIT;");

用：

     statement.addBatch("START TRANSACTION;");
     statement.addBatch("UPDATE FIRST_TABLE SET FIRST_FIELD = 1;");
     ....

但是，这不是运行事务的标准方式。运行事务：

    con.setAutoCommit(false); //so that a transaction is not committed after each
                              //statement
    //run you queries
    statement.executeUpdate(); //or statement.executeBatch();
    ...
    //in the end commit
    con.commit();