用Cassandra数据库实现Spring批处理

Question

我正在尝试更改现有的spring批处理作业（XML配置），它从oracle数据库读取数据，并以所需格式写入txt和XML文件，但现在我想更改相同的实现，从Cassandra数据库而不是oracle读取数据，但我在spring批处理中找不到类似于JdbcCursorItemReader的项目读取器。

有人能告诉我应该使用哪个ItemReader从Cassandra DB读取数据吗？或者我需要创建一个自定义的ItemReader来从Cassandra DB读取数据吗？

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;
    }

}