バーンバッチを使用して空のボディでCSVファイルを書き込む方法

Question

私はバングブートを使用して、送信する必要がある送信バッチを作成し、レコードが見つからない場合にのみヘッダーで空のファイルを作成します。

私はJdbcCursorItemReaderをマップするためにBeanPropertyRowMapperを使用しています...なぜ、BeanPropertyRowMapperを使用するのは、マップする列が多いためです。もし私がrowmapperを使用しているなら、それは私のために地獄になるでしょう。 myDBreader（）クエリが空の結果を返す場合

@Bean 
public Step RawDataOutBoundSteps() throws IOException { 

    return stepBuilderFactory.get("step1").<RawDataExtractionDTO, RawDataExtractionDTO>chunk(1000)//.faultTolerant() 
      //.skip(Exception.class) 
      //.skipLimit(1000) 
      .reader(myDBReader()).processor(myProcessor()) 
      .writer(myWriter()).build(); 
} 

問題がある、私のコードは文句を言わないので、またmyWriterをmyProcessorに行く：これは構成です。

myProcessor：

public class RawDataJobProcessor implements 
ItemProcessor<RawDataExtractionDTO, RawDataExtractionDTO>{ 

@Override 
public RawDataExtractionDTO process(RawDataExtractionDTO item) throws Exception { 
    System.out.println(" Raw DAta Process"); 

    if(item == null) 
    return null; 

    return item; 
}} 

私のDBリーダー：私は私の読者後にデバッグポイントを置けば

@Bean 
ItemReader<RawDataExtractionDTO> rawDataDBReader() { 

    String jobName = Application.jobName; 
    String sql_query = ""; 

    if("RawDataOutBoundweekly".equalsIgnoreCase(jobName)){ 
     log.info("=========RawDataOutBoundweekly========="); 

     sql_query = "select * from vw_rawdata_weekly"; 

    }else if("RawDataOutBoundmonthly".equalsIgnoreCase(jobName)){ 
     log.info("================RawDataOutBoundmonthly============="); 

     sql_query = "select * from vw_rawdata_monthly"; 
    } 
    log.info("ENTERING rawDataDBReader ==================="); 


    JdbcCursorItemReader<RawDataExtractionDTO> datareader = new 
    JdbcCursorItemReader<>(); 
    datareader.setSql(sql_query); 
    datareader.setDataSource(dataSource); 
    datareader.setRowMapper(new BeanPropertyRowMapper<> 
    (RawDataExtractionDTO.class)); 
    return datareader; 
} 

なしエラースローが、それは文句を言わないで、私のすべてのプロセッサに行く、それだけでシャットダウンジョブ。

Answer 1

FlatFileHeaderCallbackを実装して、ファイルのヘッダーを書き込むことができます。

http://docs.spring.io/spring-batch/apidocs/org/springframework/batch/item/file/FlatFileHeaderCallback.html

FlatFileHeaderCallbackを設定するには、いくつかのサンプルコード。読者でさえレコードを読まない場合はFlatFileHeaderCallbackと呼ばれ、ヘッダを書きます。最終的なファイルは、ヘッダのみ

@Bean 
    public FlatFileItemWriter<Person> myWriter() 
    { 
     System.out.println("FlatFileItemWriter*******************"); 
     FlatFileItemWriter<Person> writer = new FlatFileItemWriter<Person>(); 
     writer.setResource(new FileSystemResource("output.csv")); 
     DelimitedLineAggregator<Person> delLineAgg = new DelimitedLineAggregator<Person>(); 
     delLineAgg.setDelimiter(","); 
     BeanWrapperFieldExtractor<Person> fieldExtractor = new BeanWrapperFieldExtractor<Person>(); 
     fieldExtractor.setNames(new String[] {"firstName", "lastName"}); 
     delLineAgg.setFieldExtractor(fieldExtractor); 
     writer.setLineAggregator(delLineAgg); 

    writer.setHeaderCallback(myFlatFileHeaderCallback);  


     return writer; 
    } 


@Component 
public class MyFlatFileHeaderCallback implements FlatFileHeaderCallback { 

    @Override 
    public void writeHeader(Writer writer) throws IOException { 
     System.out.println("Header called"); 

    } 

}