春季批量自定义jdbc itemreader答案

【问题标题】：spring batch custom jdbc itemreader春季批量自定义jdbc itemreader
【发布时间】：2017-08-22 09:10:38
【问题描述】：

我想创建一个自定义 jdbc itemreader 我找到了这个解决方案

import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.database.JdbcCursorItemReader;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.BeanPropertyRowMapper;

import javax.sql.DataSource;

@Configuration
public class DatabaseToXmlFileJobConfig {

private static final String QUERY_FIND_STUDENTS =
        "SELECT " +
            "email_address, " +
            "name, " +
            "purchased_package " +
        "FROM STUDENTS " +
        "ORDER BY email_address ASC";

@Bean
ItemReader<StudentDTO> databaseXmlItemReader(DataSource dataSource) {
    JdbcCursorItemReader<StudentDTO> databaseReader = new 
JdbcCursorItemReader<>();

    databaseReader.setDataSource(dataSource);
    databaseReader.setSql(QUERY_FIND_STUDENTS);
    databaseReader.setRowMapper(new BeanPropertyRowMapper<>
(StudentDTO.class));

    return databaseReader;
}
}

但我不知道如何使用它来创建我自己的 ItemReader ？无论如何要在这两个类之间建立联系吗？或者无论如何要创建一个自定义 JDBC 阅读器？

public class DatabaseReader implements ItemReader<StudentDTO> {

@Override
public StudentDTO read() throws Exception, UnexpectedInputException, 
ParseException, NonTransientResourceException {

    return null;
}

}

【问题讨论】：

好吧对不起^^，它是自动生成的
哦...我明白了。 Stack Overflow 随机生成标签。

标签： java spring jdbc spring-batch

【解决方案1】：

在 Spring 批处理中，一个步骤有 3 个核心元素

读者
处理器（可选）
作家

Spring batch 已经为最常见的情况提供了一组readers and writers，如果你没有特殊情况可以直接使用它们

根据我在您的问题中看到的情况，您可以按原样使用它。

工作

    @Bean
    public Job jobTest(){
        JobParametersBuilder parametersBuilder = new JobParametersBuilder();
        Instant timestamp =LocalDateTime.now().atZone(ZoneId.systemDefault()).toInstant();

        return jobBuilder.get("myJobName")
                .next(StudentsReport())
                .next(sendReportByEmail())
                .incrementer( jobParameters -> parametersBuilder.addJobParameters(jobParameters)
                                                                .addDate("timeStamp"
                                                                        , Date.from( timestamp)
                                                                 ).toJobParameters()
                )
                .build();
    }

步骤定义

    @Bean
    public Step studentsReport(){
        return stepBuilder.get("getStudentsThatSomething")
                .<User,User>chunk(100)
                .reader(studentsJdbcReader())
                .writer(studentsXMLWriter())
                .build();
    }

JDBC 阅读器 Bean

@Autowired
DataSource dataSource;

private static final String QUERY_FIND_STUDENTS =
        "SELECT " +
            "email_address, " +
            "name, " +
            "purchased_package " +
        "FROM STUDENTS " +
        "ORDER BY email_address ASC";

@Bean
@StepScope
JdbcCursorItemReader<StudentDTO> studentsJdbcReader() {
    JdbcCursorItemReader<StudentDTO> databaseReader = new 
JdbcCursorItemReader<>();

    databaseReader.setDataSource(dataSource);
    databaseReader.setSql(QUERY_FIND_STUDENTS);
    databaseReader.setRowMapper(new BeanPropertyRowMapper<>
(StudentDTO.class));

    return databaseReader;
}

作家豆

    @Bean
    @StepScope
    public ItemWriter<StudentDTO> studentFlatWriter(){
        return new StudentXmlWriter(OUTPUT_FILE);
    }

要创建您的自定义 XML 编写器类，您可以查看 Alexey Saenko 在其Spring Batch Tutorial 中提供的示例，实际上本教程将为您提供了解 Spring Batch 的良好基础。

【讨论】：