DataSourceを持たないSpringブート+ Springバッチ

Question

Springブートプロジェクト内でSpringバッチを構成しようとしています。データソースなしで使用したいのですが。私はResourcelessTransactionManagerが行く方法だが、私はそれを動作させることができないことがわかった。問題はすでに3つの別のdataSourcesが定義されていますが、springBatchでそれらのいずれかを使用したくないということです。

私はデフォルト実装DefaultBatchConfigurerをチェックしましたが、dataSourceが見つからない場合は、私が欲しいものを正確に行います。問題は、私はそれらの3つを持っていないし、任意のものを使用したいです。

私はそれを望んでいないので、hsqlまたは他のメモリDBを使用することをお勧めしません。

Answer 1

@SpringBootApplicationのDataSourceAutoConfigurationを除外することができます。以下のサンプルコードを参照してください。

import org.springframework.batch.core.Job; 
import org.springframework.batch.core.Step; 
import org.springframework.batch.core.StepContribution; 
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing; 
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; 
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; 
import org.springframework.batch.core.scope.context.ChunkContext; 
import org.springframework.batch.core.step.tasklet.Tasklet; 
import org.springframework.batch.repeat.RepeatStatus; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.SpringBootApplication; 
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; 
import org.springframework.context.annotation.Bean; 

@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class }) 
@EnableBatchProcessing 
public class SampleBatchApplication { 

@Autowired 
private JobBuilderFactory jobs; 

@Autowired 
private StepBuilderFactory steps; 

@Bean 
protected Tasklet tasklet() { 

    return new Tasklet() { 
     @Override 
     public RepeatStatus execute(StepContribution contribution, ChunkContext context) { 
      return RepeatStatus.FINISHED; 
     } 
    }; 
} 

@Bean 
public Job job() throws Exception { 
    return this.jobs.get("job").start(step1()).build(); 
} 

@Bean 
protected Step step1() throws Exception { 
    return this.steps.get("step1").tasklet(tasklet()).build(); 
} 

public static void main(String[] args) throws Exception { 
    System.exit(SpringApplication.exit(SpringApplication.run(SampleBatchApplication.class, args))); 
    } 
} 

とサンプルテストクラス

import org.junit.Rule; 
import org.junit.Test; 
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.test.rule.OutputCapture; 
import static org.assertj.core.api.Assertions.assertThat; 
public class SampleBatchApplicationTests { 
@Rule 
public OutputCapture outputCapture = new OutputCapture(); 

@Test 
public void testDefaultSettings() throws Exception { 
    assertThat(SpringApplication.exit(SpringApplication.run(SampleBatchApplication.class))).isEqualTo(0); 
    String output = this.outputCapture.toString(); 
    assertThat(output).contains("completed with the following parameters"); 
    } 
} 

Answer 2

、ご使用の構成に複数のDataSource（関係なく、あなたがそれらを使用する場合のかどうか）がある場合は、あなたがあなた自身のBatchConfigurerを定義する必要があります。これは、フレームワークがそのような状況で何をすべきかを知る唯一の方法です。

現在のドキュメントでBatchConfigurer詳細を読むことができます：http://docs.spring.io/spring-batch/trunk/apidocs/org/springframework/batch/core/configuration/annotation/BatchConfigurer.html

Answer 3

が、私はそれが任意のデータソースを無視するように、それはマップベースJobRepositoryを設定します結果として、DefaultBatchConfigurerクラスを拡張することでこの問題を回避ました。

例：

@Configuration 
@EnableBatchProcessing 
public class BatchConfig extends DefaultBatchConfigurer { 

    @Override 
    public void setDataSource(DataSource dataSource) { 
     //This BatchConfigurer ignores any DataSource 
    } 
} 

Answer 4

我々は、同様の問題を持っていた私たちは春のブートJDBCを使用していたし、私たちはDBに春のバッチテーブルを格納したくなかったが、我々はまだ私たちのために春のトランザクション管理を使用していました情報元。

独自のBatchConfigurerの実装が終了しました。

@Component 
public class TablelessBatchConfigurer implements BatchConfigurer { 
    private final PlatformTransactionManager transactionManager; 
    private final JobRepository jobRepository; 
    private final JobLauncher jobLauncher; 
    private final JobExplorer jobExplorer; 
    private final DataSource dataSource; 

    @Autowired 
    public TablelessBatchConfigurer(DataSource dataSource) { 
     this.dataSource = dataSource; 
     this.transactionManager = new DataSourceTransactionManager(this.dataSource); 

     try { 
      final MapJobRepositoryFactoryBean jobRepositoryFactory = new MapJobRepositoryFactoryBean(this.transactionManager); 
      jobRepositoryFactory.afterPropertiesSet(); 
      this.jobRepository = jobRepositoryFactory.getObject(); 

      final MapJobExplorerFactoryBean jobExplorerFactory = new MapJobExplorerFactoryBean(jobRepositoryFactory); 
      jobExplorerFactory.afterPropertiesSet(); 
      this.jobExplorer = jobExplorerFactory.getObject(); 

      final SimpleJobLauncher simpleJobLauncher = new SimpleJobLauncher(); 
      simpleJobLauncher.setJobRepository(this.jobRepository); 
      simpleJobLauncher.afterPropertiesSet(); 
      this.jobLauncher = simpleJobLauncher; 
     } catch (Exception e) { 
      throw new BatchConfigurationException(e); 
     } 
    } 
    // ... override getters 
} 

と偽

spring.batch.initializer.enabled=false