Как добавить пробелы перед разделителем для каждого столбца, используя пакетную пружину? - PullRequest
0 голосов
/ 24 апреля 2019

Мне нужно добавить пробелы на основе условий перед разделителем для каждого столбца при записи из db в csv-файл с использованием Spring Batch.

Например, мне нужен интервал в CSV-файле

Column1;Column2;Column3;Column4
AI22;FIENC234DK;EDEJJEDK;JEND4
OR2 ;JFJRN3D   ;DEDERF3E;FEF
EK3R;DJE3DJJEJE;JDJENEJ ;3NEN3

Я показал блок кода, запущенный в данный момент

  @Bean
ItemReader<CdVehicle> databaseToCsvItemReader() {
    JdbcCursorItemReader<CdVehicle> databaseReader = new JdbcCursorItemReader<>();

    databaseReader.setDataSource(dataSource);
    databaseReader.setSql(QUERY_FIND_FRIENDS);
    databaseReader.setRowMapper(new BeanPropertyRowMapper<>(CdVehicle.class));

    return databaseReader;
}
@Bean
ItemWriter<CdVehicle> databaseToCsvItemWriter() {
    FlatFileItemWriter<CdVehicle> csvFileWriter = new FlatFileItemWriter<>();

    String exportFileHeader = "CV20VEHID;CV20RFDPR;CV20USAGE;CV20CRVEH;CV20PERID;CV20SITE;CV27PROJ;CV27TYCAI;CV27PHASE;CV27MILLE;CV27CRV;O;CV20DTECL;CV20TEINT;CV20PRINCIPALE;CV20SECONDAIRE;CV20CRBIS;CV36TYPRX";
    StringHeaderWriter headerWriter = new StringHeaderWriter(exportFileHeader);
    csvFileWriter.setHeaderCallback(headerWriter);
    String userhome = System.getProperty("user.home");
    String exportFilePath = userhome + "/tmp/cdv.txt";
    csvFileWriter.setResource(new FileSystemResource(exportFilePath));

    LineAggregator<CdVehicle> lineAggregator = newPersonLineAggregator();
    csvFileWriter.setLineAggregator(lineAggregator);

    return csvFileWriter;
}

@Bean
public Step databaseToCsvStep() {
    return stepBuilderFactory.get("databaseToCsvStep")
            .<CdVehicle, CdVehicle>chunk(100)
            .reader(databaseToCsvItemReader())
            .writer(databaseToCsvItemWriter())
            .build();
}

@Bean
Job databaseToCsvJob() {
    return jobBuilderFactory.get("databaseToCsvJob")
            .incrementer(new RunIdIncrementer())
            .flow(databaseToCsvStep())
            .end()
            .build();
}

private LineAggregator<CdVehicle> newPersonLineAggregator() {
    DelimitedLineAggregator<CdVehicle> lineAggregator = new DelimitedLineAggregator<>();
    lineAggregator.setDelimiter(";");
    FieldExtractor<CdVehicle> fieldExtractor = newPersonFieldExtractor();
    lineAggregator.setFieldExtractor(fieldExtractor);
    return lineAggregator;
}

private FieldExtractor<CdVehicle> newPersonFieldExtractor() {
    BeanWrapperFieldExtractor<CdVehicle> extractor = new BeanWrapperFieldExtractor<>();
    extractor.setNames(new String[] {"CV20VEHID","CV20RFDPR","CV20USAGE","CV20CRVEH","CV20DTAPP","CV20PERID","CV20SITE","CV27PROJ","CV27TYCAI","CV27PHASE","CV27MILLE","CV27CRV","CV27TYMOT","O","CV20DTECL","CV20TEINT","CV20PRINCIPALE", "CV20SECONDAIRE","CV20CRBIS","CV36TYPRX"});
    return extractor;
}

После выполнения весеннего пакетного задания я получаю результат, например,

    Column1;Column2;Column3;Column4
    AI22;FIENC234DK;EDEJJEDK;JEND4
    OR2;JFJRN3D;DEDERF3E;FEF
    EK3R;DJE3DJJEJE;JDJENEJ;3NEN3

чтобы получить интервал, как проверять столбец за столбцом с условиями. Кто-нибудь знает, как проверить по условию имени заголовка столбца и дать пробел перед разделителем во время итерации.

1 Ответ

1 голос
/ 24 апреля 2019

Вы можете воспользоваться синтаксисом String Formatter, используя Spring Batch FormatterLineAggregator.Просто замените существующую реализацию LineAggregator на следующую:

private LineAggregator<CdVehicle> newPersonLineAggregator() {
    FormatterLineAggregator<CdVehicle> lineAggregator = new FormatterLineAggregator<>();
    lineAggregator.setFieldExtractor(newPersonFieldExtractor());
    lineAggregator.setFormat("%-4s;%-10s;%-8d;%-5s");
    return lineAggregator;
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...