1

我想在一个表中插入记录，同时我想更新另一个表中的记录。为此，如果任何一个查询失败，我想使用事务，那么所有查询都会回滚。为此，我正在使用批处理...步骤如下

首先，我设置AutoCommit(false)为连接 obj。

然后dmlPreparedStatement = dbConnection.prepareStatement(Insertquery);

  • 设置参数为dmlPreparedStatement
  • dmlPreparedStatement.addBatch();

在此之后，我想为此UPDATE批量添加查询-

  • dmlPreparedStatement = dbConnection.prepareStatement(Updatequery);相同的 PreparedStatement 对象，但具有新的更新查询
  • 设置参数为dmlPreparedStatement
  • dmlPreparedStatement.addBatch();

当dmlPreparedStatement.executeBatch();完成时它只执行更新语句插入操作未完成。

他们是否有任何方式将相同的 PreparedStatement 对象用于多个差异。查询。

尝试块中的代码

String query="INSERT INTO CANDIDATEANSWER " +
                "(CANDIDATEEXAMITEMID,FKCANDIDATEID,FKITEMID,OPTIONID,ATTEMPTEDTIME,ISCORRECT) " +
                "VALUES (?,?,?,?,?,?)";
        dbConnection = icrudCandidate.getConnection();
        dbConnection.setAutoCommit(false);
        dmlPreparedStatement = dbConnection.prepareStatement(query);
        for (CandidateAnswer candidateAnswer : candidateItemAssociation.getCandidateAnswers()) {
            if(candidateAnswer.getOptionID() != 0)
            {
                dmlPreparedStatement.setLong(1, candidateAnswer.getCandidateExamItemID());
                dmlPreparedStatement.setLong(2, candidateAnswer.getFkcandidateID());
                dmlPreparedStatement.setLong(3, candidateAnswer.getFkItemID());
                dmlPreparedStatement.setLong(4, candidateAnswer.getOptionID());
                java.util.Date dt =  new java.util.Date();
                dmlPreparedStatement.setObject(5, dt,java.sql.Types.TIMESTAMP,java.sql.Types.TIMESTAMP);
                String sql = "SELECT ISCORRECT FROM ITEMOPTION IO WHERE IO.OPTIONID="+candidateAnswer.getOptionID();
                preparedStatement = dbConnection.prepareStatement(query);
                resultSet = preparedStatement.executeQuery(sql);
                while(resultSet.next())
                {
                    if(resultSet.getBoolean("ISCORRECT"))
                    {
                        dmlPreparedStatement.setBoolean(6, true);
                    }
                    else
                    {
                        isCorrect=false;
                        dmlPreparedStatement.setBoolean(6, false);
                    }
                }
                resultSet.close();
            }
            dmlPreparedStatement.addBatch();
        }
         query="UPDATE CANDIDATEITEMASSOCIATION SET ISCORRECT=?,MARKSOBTAINED=? WHERE CANDIDATEEXAMITEMID="+candidateItemAssociation.getCandidateAnswers().get(0).getCandidateExamItemID();
         PreparedStatement dmlPreparedStatement1 = dbConnection.prepareStatement(query);
         dmlPreparedStatement1.setBoolean(1, isCorrect);
         if(isCorrect)
         {
             dmlPreparedStatement1.setString(2, String.valueOf(getPerItemMarksByPaperId(paperId)));              
         }
         else
         {               
             dmlPreparedStatement1.setString(2, String.valueOf((getNagetiveMarksPerItemByPaperIdAndEventID(eventID,paperId)*-1)));
         }
         dmlPreparedStatement1.addBatch();

        int[] count = dmlPreparedStatement.executeBatch();
        count = dmlPreparedStatement1.executeBatch();
        dbConnection.commit();
        return true;
4

2 回答 2

2

批处理和事务是两件不同的事情：使用批处理时，如果两者之间出现故障，您不会得到回滚。批处理的主要优点是它允许您使用多个参数执行相同的指令。

您需要做的是dmlPreparedStatement.executeBatch();在开始执行更新之前执行第一个插入批处理。

执行更新批处理后，您需要提交事务connection.commit();或在失败时回滚它。

此示例中的更多信息

于 2013-07-23T06:05:21.003 回答
0

PreparedStatement 对象用于多次执行同一 SQL 语句，而不是多次执行多个 SQL 语句。根据文档

SQL 语句被预编译并存储在 PreparedStatement 对象中，因此您可以通过更改输入参数多次执行相同的预编译 SQL 语句，从而提高性能。

在这里，您没有更改输入参数，而是 通过语句 更改 PreparedStatement 对象dmlPreparedStatement = dbConnection.prepareStatement(Updatequery);
然后您正在调用executeBatch()newley 创建的对象的方法。
这意味着您将执行最后一个预编译查询并输入前一个查询。

于 2013-07-23T06:27:46.490 回答