为什么 Hibernate 不回滚表中的插入查询？

Question

我有一个这样的伪代码：

Session session = sessionFactory.currentSession();
Connection connection = ((SessionImpl) session).connection();
connection.setAutoCommit(false);
Statement statement = connection.createStatement();
String sql = "INSERT into table...";
statement.execute(query);
connection.rollback(); // just for testing

当我执行此代码时，它应该回滚插入查询，但它没有执行回滚。

我可以看到表格中的数据。那么，根本原因是什么？为什么不回滚？

Answer 1

注意：

此代码用于解释行为以用于学习目的。不建议这样执行sql。

我不确定，因为我们不知道您的代码中还有什么。这是我的代码，它按预期回滚和提交。

@Repository
public class DealRepositoryImpl implements DealRepositoryCustom {

    @PersistenceContext
    EntityManager entityManager;

    //This one gets rolled back
    @Override
    @Transactional 
    public void saveDealWithTransactionAnnotation() {
        try {
            Session session = entityManager.unwrap(Session.class);
            Connection connection = ((SessionImpl) session).connection();
            connection.setAutoCommit(false);
            Statement statement = connection.createStatement();
            String sql = "insert into deal (name, id)  values ('WithTransactionAnnotationAndRollback', 100)";
            statement.execute(sql);
            connection.rollback();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }

    //This one also gets rolled back
    @Override
    public void saveDealWithoutTransactionAnnotation() {
        try {
            Session session = entityManager.unwrap(Session.class);
            Connection connection = ((SessionImpl) session).connection();
            connection.setAutoCommit(false);
            Statement statement = connection.createStatement();
            String sql = "insert into deal (name, id)  values ('WithoutTransactionAnnotationAndRollback', 200)";
            statement.execute(sql);
            connection.rollback();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }

    //this one gets committed
    @Override
    public void saveDealWithCommit() {
        try {
            Session session = entityManager.unwrap(Session.class);
            Connection connection = ((SessionImpl) session).connection();
            connection.setAutoCommit(false);
            Statement statement = connection.createStatement();
            String sql = "insert into deal (name, id)  values ('withCommit', 400)";
            statement.execute(sql);
            connection.commit();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }