如何在@Transactional 模式下强制提交实体

Question

我正在使用 Spring 数据 jpa 和 jdbc（使用 entityManager.unwrap(Session.class) ）连接。
我的请求通过 3 种方法流动。第一 -> 第二 -> 第三。
第一个和第三个用@Transactional 注释。
在第一种和第二种方法中通过 JPA CRUD 存储库保存实体。
在第三种方法中，使用基本的 jdbc 查询来检索保存在第二种方法中的值。
正如我们所知，@Transaction 实体在 JPA 提交事务之前不会提交到数据库。
我在第二种方法中也使用了 saveAndFlush，但在方法 3 中使用 jdbc 查询时看不到检索更新的值。

第一种方法 - update()

@Transactional
@Override
public ApiResponse update(RequestInput input) {
    ApiResponse response = doRestOfWork(input);   // calling 2nd method
    // .... some other entity save....
}

第二种方法 - doRestOfWork()：设置 status=true 并调用 saveAndFlush 方法

@Override
public ApiResponse doRestOfWork(Request request) {
    Insight insight = insightRepository.findOne(request.getTypeId());
    insight.setStatus(true);
    insightRepository.saveAndFlush(insight);

    processOperation();    // calling 3rd method
}

第三种方法 - processOperation()：通过 jdbc 连接检索更新的状态值。

@Transactional
public void processOperation() {
Connection conn = null;
        SessionImplementor sessionImpl = (SessionImplementor) entityManager.unwrap(Session.class);
        try {
            conn = sessionImpl.getJdbcConnectionAccess().obtainConnection();
            Connection conn = null;
            String stmt = "SELECT status from insight";
            PreparedStatement ps = conn.prepareStatement(stmt);
            ResultSet rs = ps.executeQuery();
            while (rs.next()) {
               boolean value = rs.getBoolean(status);   // returning false, i want this to return true as already set true in 2nd method and called saveAndFlush 
        }
    } catch (SQLException ex) {
    } finally {
        JdbcUtility.closeResources(conn, ps, rs);
    }
}

InsightRepository 正在扩展 JpaRepository

@Repository
public interface InsightRepository extends JpaRepository<Insight, Long> {}

我想在方法 3 中更新状态值（布尔值 true - 在方法 2 中更新）。 如何做到这一点？

更新

我搜索了很多，不认为如果一个方法用 @Transactional 注释，那么你可以在完成 JPA 事务之前提交更改。所以解决办法是去掉@Transactional注解，如果想控制JPA事务，使用entityManager.getTransaction()。

Answer 1

在不同于第二个方法的 bean 中创建一个用于更新的方法（第四个方法）@Transactional(propagation = Propagation.REQUIRES_NEW) 注释，并将第二个方法更改为调用第四个方法，如下所示：

@Component //or Service etc..
public class AnotherBean{

  @Transactional(propagation = Propagation.REQUIRES_NEW)
  public void doUpdateWork(Request request){
    Insight insight = insightRepository.findOne(request.getTypeId());
    insight.setStatus(true);
    insightRepository.save(insight);
  }
} 

和

    @Override
    public ApiResponse doRestOfWork(Request request) {
        anotherBean.doUpdateWork(request);
        processOperation();    // calling 3rd method
    }

Answer 2

如果你想控制事务，不要使用@Transactional

em; //entityManager

Transaction tx=em.getTransaction();
try{
   tx.begin();
   //do work
   tx.commit(); // comminted transaction 
 // start another transaction if you need to, doo more work etc.
...
}

这是使用 JPA 进行原子操作的最基本和最基本的代码块。

也不需要unwrap实体管理器，使用纯JPA。通过展开，您将当前实现绑定到 JPA 提供者，这与 JPA 独立于底层 JPA 实现提供者的想法相反。换句话说，如果由于某些原因 Spring 将其 JPA 实现从 Hibrnate 更改为 eg，它将停止工作。 Eclipse 链接。