javax。坚持不懈即使在回滚事务之外，EntityManager也不会在数据库中插入内容

Question

我不明白为什么我的代码像窗帘一样，如果有人能解释一下，那就太棒了。我面临的问题。。。我有两张桌子。方法一开始，我就在“table1”中插入一些东西，插入之后，我开始事务。让我们假设代码流总是到达事务。回滚（）。我希望第二个查询被回滚，但不是第一个查询。但在我看来，他们两个都是倒退的。

太长，读不下去了

预期结果：

• 第一个查询已提交
• 第二个查询已回滚

当前结果：

• 第一个查询被回滚

//Relevant imports
import java.sql.PreparedStatement;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.jdbc.Work;

public boolean myMethod(String createdBy) {
        final Long messageId = ((BigInteger) myEntityManager.createNativeQuery("insert into table1(created_by) values (:createdBy) returning id")
                .setParameter("createdBy", createdBy)
                .getSingleResult()).longValue();

        Session session = myEntityManager.unwrap(Session.class);
        Transaction tx = session.beginTransaction();

        session.doWork(new Work() {
            @Override
            public void execute(Connection conn) throws SQLException {

                String sqlInsert = "insert into table2(messageId) values (?)";
                try ( PreparedStatement pstmt = conn.prepareStatement(sqlInsert)) {

                    for (Object[] row : unsentRecords) {
                        pstmt.setLong(1, messageId);
                        pstmt.addBatch();
                    }
                    //Execute batch
                    int[] sqlStatmentsStatuses = pstmt.executeBatch();
                    //check if some statement failed
                    //Let's assume it always fails,just to be explicit
                    boolean somethingWentWrong = atLeastOneFailed(sqlStatmentsStatuses);
                    somethingWentWrong = true;
                    if(somethingWentWrong){
                        tx.rollback();
                    }
                }
            }
        }
    }

注：我不知道如何准确地回答这个问题。因此，如果有人能为这个问题建议一个更好的标题，请把它放在评论中，我会更改它。

Answer 1

下面是交易#starinTransaction javadoc

Begin a unit of work and return the associated Transaction object. If a new underlying transaction is required, begin the transaction. Otherwise continue the new work in the context of the existing underlying transaction.

它说，如果不可用，创建并开始新的事务。在您的情况下，您已经在执行一个正在启动事务的查询。所以当你说会话时。beginTransaction（），它不是创建新事务，而是返回现有事务，这就是为什么在回滚该事务时，两个查询都会回滚。