首页 > 解决方案 > JDBC 事务的问题。不能让它成为原子性

问题描述

我有代码:

 @Override
    public void update(Duck entity) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
       try {
            connection = DriverManager.getConnection(daoProperties.getUrl(), daoProperties.getUser(), daoProperties.getPassword());
            connection.setAutoCommit(false);
            connection.commit()
            preparedStatement = connection.prepareStatement(INSERT_FROG);

            preparedStatement.setInt(ID, entity.getFrogId());
            preparedStatement.setString(NAME, entity.getMyFrogFriend().name());
            preparedStatement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
            try {
                connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }

        try {
            PreparedStatement duckPreparedStatement = connection.prepareStatement(INSERT_DUCK);

            duckPreparedStatement.setInt(ID, entity.id());
            //..
            duckPreparedStatement.executeUpdate();
   //         throw new SQLException();
    //        connection.commit();
        } catch (SQLException e) {
            log.warning("error with statements or connection");
            try {
                connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }
    }

我想要,如果第二次插入失败,那么我们不进行第一次插入。但是这段代码不起作用,如果我们删除第一个评论,第一次插入就会完成。我究竟做错了什么?

标签: javajdbctransactions

解决方案


try-catchwithrollback应该覆盖整个工作单元。现在你在第一次失败后回滚,然后继续,好像什么都没发生一样。结果,第二个插入将在它自己的事务中(因此与第一个不同的事务),并单独成功。

相反,您需要在两个语句(整个事务)之后回滚,而不是每个语句。

try {
    // first insert
    // second insert
} catch (SQLException e) {
    connection.rollback();
}

顺便说一句,在您的工作单元commit() 之前有一个没有意义,并且似乎表明整个事务管理中断。您在工作单元之后注释掉的事实commit()也是不可取的。如果连接关闭,您的事务将被回滚(或某些数据库:已提交),如果您的连接被重用,则工作将被提交或回滚,具体取决于后续代码重用连接将执行的操作。


推荐阅读