Spring Batch--使用JDBCursorItemReader从数据源中读取并使用ResultSet

Question

我试图使用Spring Batch创建一个使用DataSource（配置之前）并运行查询的作业。我希望能够遍历返回的ResultSet，用返回的数据创建一个新表。

@Bean
public JdbcCursorItemReader<ResultSet> reader(String query, DataSource dataSource) {
    JdbcCursorItemReader<ResultSet> itemReader = new JdbcCursorItemReader<>();
    itemReader.setDataSource(dataSource);
    itemReader.setSql(query);
    return itemReader;
}

我的ItemProcessor应该收到什么？这个？

public class ExtractionItemProcessor implements ItemProcessor<ResultSet, String>{    
@Override
    public String process(ResultSet item) throws Exception {
        // transform the resultSet into a SQL INSERT
  }
}

编辑：我知道查询结果的唯一方法是ResultSet元数据，所以我不能创建POJO和设置属性。

Answer 1

创建一个POJO类来表示记录，例如foo:

public class Foo {
     private final long id;
     // more properties

     public Foo(long id // ,...) {
         this.id = id;
         // set other properties
     }

     public long getId() {
         return id;
     }
}

因此，阅读器将是JDBCursorItemReader 。

并创建rowmapper ，例如：

public FooRowMapper implements implements RowMapper<Foo> {

    @Override
    public Foo mapRow(ResultSet rs, int rowNum) throws SQLException {
        long id = rs.getLong("id");
        // more properties 
        return new Foo(id // more properties);
    }
}

public class ExtractionItemProcessor implements ItemProcessor<Foo, String>{    
@Override
    public String process(Foo item) throws Exception {
    int someValue = transform(foo);
    return "INSERT INTO blah blah blah..." + someValue + "...";  // potentially dangerous - see SQL injection attack
  }
}

为了更进一步，也许ExtractionItemProcessor转换foo应该创建bar。然后看起来像：

public class ExtractionItemProcessor implements ItemProcessor<Foo, Bar>{    
@Override
    public Bar process(Foo item) throws Exception {
    int someValue = transform(foo);
    // more values....
       return new Bar(someValue // more values);
  }
}

因此，ItemWriterimpelementation将获得列表 ，它知道如何安全地将bar插入到另一个表中。