Question

我正在尝试使用@ Transactional within @Async方法追踪文件转换过程如下:

@Async
@Transactional
public void convertFile(String documentId) {
     
    CustomLog customLog = new CustomLog();
    customLog.setStatus("IN_PROGRESS");
    mySpringDataRepo.save(customLog);

    try {
      doConvertFunction(documentId);    
    } catch (Exception e) {
      customLog.setStatus("FAIL");
      mySpringDataRepo.save(customLog);
      return;
    }

    customLog.setStatus("SUCCESS");
    mySpringDataRepo.save(customLog);   
}

我正在使用以下技术:

Spring Boot 2.7.18
Hibernate Core 5.6.15.Final
Websphere ND 9.0.5.13
Java 1.8

我的客户实体组合:

@Primary
@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory(EntityManagerFactoryBuilder builder,
    DataSource dataSource) {
    LocalContainerEntityManagerFactoryBean em = builder.dataSource(dataSource).packages("com.myapp").persistenceUnit("MyEntityManagerFactory").properties(jpaProperties()).build();
    JpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
    em.setJpaVendorAdapter(vendorAdapter);
    return em;
}

protected Map<String, Object> jpaProperties() {
        Map<String, Object> props = new HashMap<>();
        props.put("hibernate.physical_naming_strategy", CamelCaseToUnderscoresNamingStrategy.class.getName());
        props.put("hibernate.implicit_naming_strategy", SpringImplicitNamingStrategy.class.getName());
        return props;
}

当操作上述《汤姆斯法典》时 9 它完全是罚款的,但在试图在网上进行交易时,交易是公开的,储蓄方法根本就没有执行!

I made several tries with no luck as follows:

使用@ Transactional(propagation = Propagation。 REQUIRES_NEW

将储蓄方法推至新的单独服务方法,具体如下:

@Service
public class MyService {

  @Autowired
  private MySpringDataRepo mySpringDataRepo;

  @Transactional(propagation = Propagation.REQUIRES_NEW)
  public CustomLog save(CustomLog customLog) {
     mySpringDataRepo.save(customLog);
     return customLog;
  }

}

UPDATE:

<>只有>解决办法在网上开展工作,即从实体管理基金会创建实体管理:

@Service
public class CustomLogService {

    @Autowired
    private EntityManagerFactory entityManagerFactory;

    
    public Long save(CustomLog customLog) {
        EntityManager entityManager = entityManagerFactory.createEntityManager();
        entityManager.getTransaction().begin();
        entityManager.persist(customLog);
        entityManager.flush();
        entityManager.getTransaction().commit();
        return customLog.getId();
    }

    public CustomLog find(Long id) {
        EntityManager entityManager = entityManagerFactory.createEntityManager();
        entityManager.getTransaction().begin();
        CustomLog customLog = entityManager.find(CustomLog.class, id);
        entityManager.getTransaction().commit();
        return customLog;
    }

    public void update(CustomLog customLog) {
        EntityManager entityManager = entityManagerFactory.createEntityManager();
        entityManager.getTransaction().begin();
        entityManager.merge(customLog);
        entityManager.getTransaction().commit();
    }

}

更改我的<代码>@Async 守则如下:

@Async
public void convertFile(String documentId) {

    CustomLog customLog = new CustomLog();
    customLog.setStatus("IN_PROGRESS");
    customLogService.save(customLog);

    try {
       doConvertFunction(documentId);    
    } catch (Exception e) {
      customLog = customLogService.find(customLog.getId());
      customLog.setStatus("FAIL");
      customLogService.update(customLog);
      return;
    }

    customLog = customLogService.find(customLog.getId());
    customLog.setStatus("SUCCESS");
    customLogService.update(customLog);

}

我试图注入实体经理,但只有创建实体才能工作。实体经理:

@PersistenceContext(name = "MyEntityManagerFactory")
private EntityManager entityManager;

Are there any disadvantages/things to consider in this solution because I will be heavily using this method and it returns a new EntityManager instance each time it is invoked?

Answer 1

1. 更新你的配置代码。

@Configuration
@EnableJpaRepositories(basePackages = { "com.myapp.dao" }, transactionManagerRef = "websphereTxManager")
@EnableTransactionManagement
public class WebSphereDBConfiguration {

    @Resource(lookup = "jdbc/sample", name = "java:comp/env/jdbc/sample")
    private DataSource dataSource;

    @Primary
    @Bean
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean() {
        LocalContainerEntityManagerFactoryBean entityManagerFactoryBean = new LocalContainerEntityManagerFactoryBean();
        entityManagerFactoryBean.setPackagesToScan("com.myapp.entity");
        entityManagerFactoryBean.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
        entityManagerFactoryBean.setDataSource(dataSource);
        entityManagerFactoryBean.setJpaPropertyMap(jpaProperties());
        return entityManagerFactoryBean;
    }

    @Bean
    public EntityManagerFactory entityManagerFactory(LocalContainerEntityManagerFactoryBean entityManagerFactoryBean) {
        return entityManagerFactoryBean.getObject();
    }

    @Bean
    public PlatformTransactionManager websphereTxManager(EntityManagerFactory entityManagerFactory) {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(entityManagerFactory);
        return transactionManager;
    }


    protected Map<String, Object> jpaProperties() {
        Map<String, Object> props = new HashMap<>();
        props.put("hibernate.physical_naming_strategy", CamelCaseToUnderscoresNamingStrategy.class.getName());
        props.put("hibernate.implicit_naming_strategy", SpringImplicitNamingStrategy.class.getName());
        return props;
    }


}

采用相同的法典:

@Async
@Transactional
public void convertFile(String documentId) {
     
    CustomLog customLog = new CustomLog();
    customLog.setStatus("IN_PROGRESS");
    mySpringDataRepo.save(customLog);
    
    try {
      doConvertFunction(documentId);    
    } catch(Exception e) {
      customLog.setStatus("FAIL");
      mySpringDataRepo.save(customLog);
      return;
    }

    customLog.setStatus("SUCCESS");
    mySpringDataRepo.save(customLog);
       
}

www.un.org/Depts/DGACM/index_spanish.htm 注意的要点很少:

Creating a bean of LocalContainerEntityManagerFactoryBean.
Creating a bean of EntityManagerFactory via injecting LocalContainerEntityManagerFactoryBean and getting the object via LocalContainerEntityManagerFactoryBean.getObject(). Also, make that bean as the primary bean for the whole application.
You will need to create a custom transaction manager. So, creating a JpaTransactionManager bean via injection and using the EntityManagerFactory bean.
You can see this annotation @EnableTransactionManagement. By use of this annotation, you will tell Spring to use this configuration class to manage your transaction.
See this annotation @EnableJpaRepositories. By this annotation, you will tell Spring which packages to scan containing the JPA repositories and also tell which transaction manager to use via this property transactionManagerRef by default.
You have to configure datasource on the WebSphere (I guess you already did) and inject it via @Resource and set that datasource in the LocalContainerEntityManagerFactoryBean bean.

如果有这种帮助的话。

Answer 2

请注意,我没有用于网站和最近版本的jakartaEE。

只是一些一般性考虑:

@Async methods defer the process to another thread.
Transaction propagation rely on a threadLocal context and so the current transaction / entityManager instance is probably not reachable from your @Async method thread.
All of this is very probably dependent on provider implementation. Maybe you could have better result using Container Managed transaction Manager provided by the Websphere server itself.
Generally speaking using both a jakartaEE server and Spring might lead to additional complexity as their scope often overlap (You can use either Spring or JakartaEE containers in many cases: JPA, DI, Security, etc and problems will emerge if you mix features from both)
Regarding your workaround, instantiating an new EntityManager instance for each method is not necessarily shocking, particularly if the method is directly invoked through a dedicated http request (see https://stackoverflow.com/a/22773758/2087640)

友情链接