使用Cassandra数据库进行春季批处理实现

Question

我正在尝试更改现有的 spring batch job(XML config(，它从 oracle 数据库中读取数据并以所需的格式写入 txt AND XML 文件，但现在我想更改相同的实现以从 Cassandra 数据库而不是 oracle 读取数据，但我在 Cassandra db 的 spring 批处理中没有看到任何可用的 JdbcCursorItemReader 的项目读取器。

有人可以告诉我应该使用哪个ItemReader从Cassandra db读取数据吗？或者我是否需要创建自定义 ItemReader 才能从 Cassandra 数据库读取数据？

Answer 1

您可以创建一个 CustomItemReader

public class CustomItemReader implements ItemReader<List<YOUR_DOMAIN_OBJECT>> {
    @PostConstruct
    public void init() throws IOException {
        //establish cassandra db connection
    }
    @Override
    public List<YOUR_DOMAIN_OBJECT> read()
        throws Exception{
        //user cassandra connection to read data and build List<YOUR_DOMAIN_OBJECT>
       return data;
    }
}