java - 如何在文件读取过程中动态映射 Spring Batch 中的字段集？

Question

关闭。这个问题需要多问 focused 。目前不接受答案。

---

想要改进此问题吗？更新问题，使其仅关注一个问题 editing this post .

已关闭 3 年前。

Improve this question

我需要在 Spring Batch 的帮助下读取文件。但在阅读时需要 LineMapper 。如果文件的列类型不匹配，则会出现错误

我想动态执行此操作或跳过该步骤，我该怎么做？

        DelimitedLineTokenizer lineTokenizer = new DelimitedLineTokenizer();
        lineTokenizer.setNames(new String[] { "col1", "col2", "col3", "col4", "col5" });
        lineTokenizer.setDelimiter(",");
        BeanWrapperFieldSetMapper<InputStream> fieldSetMapper = new BeanWrapperFieldSetMapper<InputStream>();
        fieldSetMapper.setTargetType(InputStream.class);
        fieldSetMapper.setStrict(false);
        DefaultLineMapper<InputStream> lineMapper = new DefaultLineMapper<InputStream>();
        lineMapper.setLineTokenizer(lineTokenizer);
        lineMapper.setFieldSetMapper(fieldSetMapper);
        setLineMapper(lineMapper);

我想要的另一件事

我正在使用 FlatFileItemreader 来读取文件。该文件可能是 csv、xml、txt 格式。我希望 Spring Batch Reader 能够动态识别文件格式并进行相应的处理。我们可以这样做吗

Answer 1

您的问题可能与现有的问题相关 multiple-files-of-different-data-structure-formats-as-input-in-spring-batch 。 Spring Batch 不提供开箱即用的通用 ItemReader 来支持同时读取不同类型的格式。可以使用 MultiResourceItemReader，如 Spring Batch 文档中所述 multi file input reader但仅适用于具有相同格式的输入文件。在您的情况下，您必须根据您拥有的输入文件格式来决定要使用哪种阅读器。例如，您可以尝试在作业配置类中创建您自己的 ItemReader 与此类似的内容

    @Bean
    @StepScope
    public ItemReader<YourDomainClass> itemReader(
            @Value("#{jobParameters}") Resource inputFile) {

        //your logic here
        String fileName = inputFile.getFilename();
        if (isCsv(inputFile)) {
            return csvItemReader(inputFile);
        } else if(isXml(inputFile)){
            return xmlItemReader(inputFile);
        } else {
           ...
        }
    }

    //CSV ItemReader
    public FlatFileItemReader<YourDomainClass> csvItemReader(Resource inputFile) {

        return new FlatFileItemReaderBuilder<YourDomainClass>()
                .name("csvItemReader")
                .delimited()
                .names(new String[] {"col1", "col2", "col3", "col4", "col5"})
                .targetType(YourDomainClass.class)
                .resource(inputFile)
                .build();
    }

    //XML ItemReader
    public ItemReader<YourDomainClass> xmlItemReader(Resource inputFile) {

        ...
    }

    //JSON ItemReader
    public ItemReader<YourDomainClass> jsonItemReader(Resource inputFile) {

        ...
    }

希望对您有帮助。