小编lak*_*nth的帖子

Spring批处理步骤范围如何工作

我有一个要求,我需要根据其中我得到文件名的其余调用来处理文件,我将它添加到job参数并在创建bean时使用它.

我正在为(读者,作家)和使用job参数创建步骤范围Bean.我正在一个新线程中开始工作,因为我使用异步任务exceutor来启动工作,我的问题是如何通过spring创建bean当我们定义 @StepScope

jobParametersBuilder.addString("fileName", request.getFileName());
jobExecution = jobLauncher.run(job, jobParametersBuilder.toJobParameters());
@Bean
public JobLauncher jobLauncher() {
    SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
    jobLauncher.setJobRepository(jobRepository());
    jobLauncher.setTaskExecutor(asyncTaskExecutor());
    return jobLauncher;
}

@Bean
@StepScope
public ItemWriter<Object> writer(@Value ("#{jobParameters['fileName']}"String    fileName) {
    JdbcBatchItemWriter<Object> writer = new JdbcBatchItemWriter<>();
    writer.setItemSqlParameterSourceProvider(
        new BeanPropertyItemSqlParameterSourceProvider<Object>());
    writer.setSql(queryCollection.getquery());
    writer.setDataSource(dataSource(fileName));
    return writer;
}
Run Code Online (Sandbox Code Playgroud)

spring spring-batch

17
推荐指数
1
解决办法
2万
查看次数

标签 统计

spring ×1

spring-batch ×1