Spring Batch如何作为Reader读取多个表(查询)并将其作为平面文件写入
在我的项目中,我读取了具有不同查询的多个表,并将这些结果集合并到平面文件中。我怎样才能做到这一点。我的意思是JdbcReader直接接受1个SELECT查询,我如何自定义它。
解决方案
如果JdbcCursorItemReader不符合您的需要,您始终可以通过实现ItemReader接口自由实现自定义读取器。
public interface ItemReader<T> {
T read() throws Exception, UnexpectedInputException, ParseException;
}
只需编写实现此接口的类并插入jdbcTemplate即可查询多个表。
public Class MyCompositeJdbcReader implements ItemReader<ConsolidateResult>{
private JdbcTemplate jdbcTemplate;
public ConsolidateResult read()
throws Exception, UnexpectedInputException, ParseException{
ConsolidateResult cr = new ConsolidateResult();
String name= this.jdbcTemplate.queryForObject(
"select name from customer where id = ?",new Object[]{1}, String.class);
String phoneNumber= this.jdbcTemplate.queryForObject(
"select phone from customer_contact where custid = ?",
new Object[]{1},String.class);
cr.setName(name);
cr.setPhone(phoneNumber);
return cr;
}
}
我没有编译代码,但我希望它能提供一些启示。
相关文章