如何使用Spring Batch存储整个读取行？

Tony Edwards 发表于 Dev

托尼·爱德华兹

我正在使用Spring Boot 1.4和Spring Batch 1.4来读取文件，并且当然将数据解析到数据库中。

我想做的是在映射字段之前将整个读取的行存储在数据库中。整个行将作为字符串存储在数据库中。这是出于审计目的，因此我不想从其组件重建行字符串。

我们都已经看到了使用通用映射器从定界线获取数据的方法：

@Bean
@StepScope
public FlatFileItemReader<Claim> claimFileReader(@Value("#{jobParameters[fileName]}") String pathToFile) {
    logger.debug("Setting up FlatFileItemReader for claim");
    logger.debug("Job Parameter for input filename: " + pathToFile);

    FlatFileItemReader<Claim> reader = new FlatFileItemReader<Claim>();
    reader.setResource(new FileSystemResource(pathToFile));
    reader.setLineMapper(claimLineMapper());
    logger.debug("Finished setting up FlatFileItemReader for claim");
    return reader;
}

@Bean
public LineMapper<Claim> claimLineMapper() {
    logger.debug("Setting up lineMapper");

    DefaultLineMapper<Claim> lineMapper = new DefaultLineMapper<Claim>();

    DelimitedLineTokenizer lineTokenizer = new DelimitedLineTokenizer();
    lineTokenizer.setDelimiter("|");
    lineTokenizer.setStrict(false);
    lineTokenizer.setNames(new String[] { "RX_NUMBER", "SERVICE_DT", "CLAIM_STS", "PROCESSOR_CLAIM_ID", "CARRIER_ID", "GROUP_ID", "MEM_UNIQUE_ID" });

    BeanWrapperFieldSetMapper<Claim> fieldSetMapper = new BeanWrapperFieldSetMapper<Claim>();
    fieldSetMapper.setTargetType(Claim.class);

    lineMapper.setLineTokenizer(lineTokenizer);
    lineMapper.setFieldSetMapper(claimFieldSetMapper());

    logger.debug("Finished Setting up lineMapper");

    return lineMapper;
}

如果这是我的行：463832 | 20160101 | PAID | 504419000000 | XYZ | GOLD PLAN | 561868

我想将“ 463832 | 20160101 | PAID | 504419000000 | HBT | GOLD PLAN | 561868”作为字符串存储在数据库中（可能带有一些额外的数据，例如job_instance_id）。

关于如何在文件读取过程中将其挂接到钩子的任何想法？

Nghia Do

除了使用DefaultLineMapper，您还可以创建一个新类（建议CustomLineMapper），如下所示

public class CustomLineMapper extends DefaultLineMapper<Claim> {

    @Override
    public Claim mapLine(String line, int lineNumber) throws Exception {
        // here you can handle *line content*
        return super.mapLine(line, lineNumber);
    }
}

行对象将包含将其映射到对象之前的原始数据。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。