用Spring批處理事務管理

Question

我發現實際上Spring和我能夠設置一些工作。現在，我想救我的進口DATAS中使用Hibernate/JPA和我不斷收到此錯誤數據庫：

14:46:43.500 [main] ERROR o.s.b.core.step.AbstractStep - Encountered an error executing the step javax.persistence.TransactionRequiredException: no transaction is in progress 

我看到的問題是與交易。下面是我對entityManager的Spring Java配置和transactionManager：

@Configuration 
public class PersistenceSpringConfig implements EnvironmentAware 
{ 


    @Bean 
    public LocalContainerEntityManagerFactoryBean entityManagerFactory() throws Exception 
    { 
    // Initializes the entity manager 
    LocalContainerEntityManagerFactoryBean factoryBean = new LocalContainerEntityManagerFactoryBean(); 
    factoryBean.setPersistenceUnitName(PERSISTENCE_UNIT_NAME); 
    factoryBean.setJpaVendorAdapter(new HibernateJpaVendorAdapter()); 
    factoryBean.setDataSource(dataSource()); 

    // Scans the database model 
    factoryBean.setPackagesToScan(EntiteJuridiqueJPA.class.getPackage().getName()); 

    // Defines the Hibernate properties 
    Properties jpaProperties = new Properties(); 
    jpaProperties.setProperty("hibernate.show_sql", "false"); 
    jpaProperties.setProperty("hibernate.format_sql", "false"); 
    String connectionURL = "jdbc:h2:file:" + getDatabaseLocation(); 
    jpaProperties.setProperty("hibernate.connection.url", connectionURL); 
    jpaProperties.setProperty("hibernate.connection.username", "sa"); 
    jpaProperties.setProperty("hibernate.connection.driver_class", "org.h2.Driver"); 
    jpaProperties.setProperty("hibernate.dialect", H2Dialect.class.getName()); 
    jpaProperties.setProperty("hibernate.hbm2ddl.auto", "create"); 
    jpaProperties.setProperty("hibernate.hbm2ddl.import_files_sql_extractor", "org.hibernate.tool.hbm2ddl.MultipleLinesSqlCommandExtractor"); 
    jpaProperties.setProperty("hibernate.hbm2ddl.import_files", 
     "org/springframework/batch/core/schema-drop-h2.sql,org/springframework/batch/core/schema-h2.sql"); 

    factoryBean.setJpaProperties(jpaProperties); 
    return factoryBean; 
    } 



@Bean 
    public PlatformTransactionManager transactionManager2() throws Exception 
    { 
    EntityManagerFactory object = entityManagerFactory().getObject(); 
    JpaTransactionManager jpaTransactionManager = new JpaTransactionManager(object); 
    return jpaTransactionManager; 
    } 

我使用JpaItemWriter到DATAS存儲在數據庫中：

@Bean 
    public ItemWriter<EntiteJuridiqueJPA> writer() 
    { 
    JpaItemWriter<EntiteJuridiqueJPA> writer = new JpaItemWriter<EntiteJuridiqueJPA>();  
    writer.setEntityManagerFactory(entityManagerFactory.getObject()); 
    return writer; 
    } 

這是導致異常的代碼：javax.persistence.TransactionRequiredException: no transaction is in progress

任何想法如何解決這個問題？

[編輯]我也把工作定義和步驟定義。我所有的Spring配置都是用Java編寫的。

@Configuration 
@EnableBatchProcessing 
@Import(PersistenceSpringConfig.class) 
public class BatchSpringConfig 
{ 
    @Autowired 
    private JobBuilderFactory jobBuilders; 

    @Autowired 
    private StepBuilderFactory stepBuilders; 

    @Autowired 
    private DataSource   dataSource; 

    @Autowired 
    private LocalContainerEntityManagerFactoryBean entityManagerFactory; 

    @Bean 
    public Step step() 
    { 
    return stepBuilders.get("step").<EntiteJuridique, EntiteJuridiqueJPA> chunk(5).reader(cvsReader(null)) 
     .processor(processor()).writer(writer()).listener(processListener()).build(); 
    } 

    @Bean 
    @StepScope 
    public FlatFileItemReader<EntiteJuridique> cvsReader(@Value("#{jobParameters[input]}") String input) 
    { 
    FlatFileItemReader<EntiteJuridique> flatFileReader = new FlatFileItemReader<EntiteJuridique>(); 
    flatFileReader.setLineMapper(lineMapper()); 
    flatFileReader.setResource(new ClassPathResource(input)); 
    return flatFileReader; 
    } 

    @Bean 
    public LineMapper<EntiteJuridique> lineMapper() 
    { 
    DefaultLineMapper<EntiteJuridique> lineMapper = new DefaultLineMapper<EntiteJuridique>(); 
    DelimitedLineTokenizer lineTokenizer = new DelimitedLineTokenizer(); 
    lineTokenizer.setDelimiter(";"); 
    lineTokenizer.setNames(new String[] { "MEGA_ENTITE", "PORTEFEUILLE", "MEGA_ENTITE", "Libellé" }); 

    BeanWrapperFieldSetMapper<EntiteJuridique> fieldSetMapper = new BeanWrapperFieldSetMapper<EntiteJuridique>(); 
    fieldSetMapper.setTargetType(EntiteJuridique.class); 

    lineMapper.setLineTokenizer(lineTokenizer); 
    lineMapper.setFieldSetMapper(fieldSetMapper); 

    return lineMapper; 
    } 

    @Bean 
    public Job dataInitializer() 
    { 
    return jobBuilders.get("dataInitializer").listener(protocolListener()).start(step()).build(); 
    } 

    @Bean 
    public ItemProcessor<EntiteJuridique, EntiteJuridiqueJPA> processor() 
    { 
    return new EntiteJuridiqueProcessor(); 
    } 

    @Bean 
    public ItemWriter<EntiteJuridiqueJPA> writer() 
    { 
    JpaItemWriter<EntiteJuridiqueJPA> writer = new JpaItemWriter<EntiteJuridiqueJPA>();  
    writer.setEntityManagerFactory(entityManagerFactory.getObject()); 
    return writer; 
    // return new EntiteJuridiqueWriter(); 
    } 

    @Bean 
    public ProtocolListener protocolListener() 
    { 
    return new ProtocolListener(); 
    } 

    @Bean 
    public CSVProcessListener processListener() 
    { 
    return new CSVProcessListener(); 
    } 

    @Bean 
    public PlatformTransactionManager transactionManager2() throws Exception 
    { 
    EntityManagerFactory object = entityManagerFactory.getObject(); 
    JpaTransactionManager jpaTransactionManager = new JpaTransactionManager(object); 
    return jpaTransactionManager; 
    } 

[編輯]我還是堅持了這個問題。我通過設置stepBuilders的事務管理器來遵循@Sean Patrick Floyd和@bellabax的建議，但我仍然得到相同的異常。我已經獨立測試了我的entityManager，並且能夠將任何數據存儲在數據庫中。

但是，當與spring批處理使用相同的實體管理器時，我有這個異常。

任何人都可以提供更多見解如何在春季批次內管理交易？ Thx爲您提供幫助？

Answer 1

問題在於您正在創建第二個事務管理器（transactionManager2），但Spring Batch正在使用另一個事務管理器來啓動事務。如果使用@EnableBatchProcessing，Spring Batch會自動註冊一個事務管理器用於其事務，並且JpaTransactionManager永遠不會被使用。 如果您想更改Spring Batch用於事務的事務管理器，則必須實現接口BatchConfigurer。看看這個例子：https://github.com/codecentric/spring-batch-javaconfig/blob/master/src/main/java/de/codecentric/batch/configuration/WebsphereInfrastructureConfiguration.java。 在這裏，我將事務管理器切換到WebspherUowTransactionManager，並以相同的方式將事務管理器切換到其他事務管理器。 這裏是解釋它的博客文章的鏈接：http://blog.codecentric.de/en/2013/06/spring-batch-2-2-javaconfig-part-3-profiles-and-environments/

Answer 2

你需要明確引用您的步驟定義你的事務管理器：

<job id="sampleJob" job-repository="jobRepository"> 
    <step id="step1"> 
     <tasklet transaction-manager="transactionManager"> 
      <chunk reader="itemReader" writer="itemWriter" commit-interval="10"/> 
     </tasklet> 
    </step> 
</job> 

參見：5.1.1. Configuring a Step

---

啊，看到你使用JavaConfig，你需要的事務管理器分配給TaskletStepBuilder使用builder.transactionManager(transactionManager)（繼承自StepBuilderHelper）