Spring批处理在Mongodb中保存csv文件记录

Question

我正在开发 Spring Batch，它从一个位置从 csv 文件中读取记录并保存到 mongo DB 中。我想读取特定对象类型的记录，但在写入时它应该是不同的对象类型。 就像我正在使用 obj1 读取文件一样，我想将 obj1 设置为 obj2 并保存到 DB。 下面是我的代码。

@Bean
    public Job readCSVFileJob() {
        return jobBuilderFactory
                .get("readCSVFileJob")
                .incrementer(new RunIdIncrementer())
                .start(step())
                .build();
    }

    @Bean
    public Step step() {
        return stepBuilderFactory
                .get("step")
                .<FileObj, FileObj>chunk(5)
                .reader(reader(null))
                .faultTolerant().skipPolicy(fileVerificationSkipper())
                .writer(writer())
                .build();
    }

    @Bean
    public SkipPolicy fileVerificationSkipper() {
        return new FileVerificationSkipper();
    }

    @Bean
    @StepScope
    public FlatFileItemReader<FileObj> reader(@Value("#{jobParameters['fullPathFileName']}") String fullPathFileName) {
        FlatFileItemReader<FileObj> itemReader = new FlatFileItemReader<FileObj>();
        itemReader.setLineMapper(lineMapper());
        itemReader.setLinesToSkip(1);
        try {
            itemReader.setResource(new PathResource(fullPathFileName)); // set resource from a FTP location
        } catch (Exception e) {
            e.printStackTrace();
        }
        return itemReader;
    }

    @Bean
    public LineMapper<FileObj> lineMapper() {
       //code for line mapper this works fine
        return lineMapper;
    }

    @Bean
    public MongoItemWriter<OBJ2> writer() {
       // in this I want to write in mongo DB with OBJ2 something like below
    repository.save(obj2);
        return writer;
    }

Answer 1

您需要添加一个ItemProcessor，将obj1 项目转换为obj2。数据转换是ItemProcessor 的典型用例。