How to get File Name in to the Item Reader or Item Processor of spring batch?

user_11389218 0
Viewed 783

I am Using MultiResourceItemReader to read the multiple resources which is setting to the Resource[], and by using Fixed Length Tokenizer I am able to set the data to the POJO class. in the Item Processor I am able to get the Object which has been created by Item Reader and able to get the data from the object.

The Challenging which I am facing is to get the File Name for the specific object which has been created or processed and passed to the Item Processor.

I required store the File Name also along with the specific object data in to the database.

Appreciate the help on this, Thank you

*Here is the batch configuration *

@Configuration
@EnableBatchProcession
    public class BatchConfig {
    
    
    @Value("")
    private Resource[] resource;

    /* Job */
    public Job job(){
    return jobBuilderFactory.get("job").listerner(listener()).incrementer(new 
    RunIdIncrementer())
           .start(step()).build();
    }
    /*  Step */
    public Step step(){
    return stepBuilderFactory.get("step")<mypojo,mypojo>chunk(10)
    .reader(multiREsourceItemReader()).processor(processor()).writer(writer()).build();
    }
    
    /* Multi Resource Item Reader */
    @Bean
    @StepScope
    public MultiResourceItemReader<mypojo> multiResourceItemReader() {
    MultiResourceItemReader<mypojo> multireader = new MultiResourceItemReader<mypojo>();
    multireader.setResource(resources);
    multireader.setDelegate(reader());
    return mutlireader;
    }

   /* Flat FIle Item Reader */
   @Bean 
   public FlatFileItemReader<mypojo> reader() {
   FlatFileItmeReader<mypojo> reader = new FlatFileItemReader<mypojo>();
   reader.setLineMapper(new DefaultLineMapper() {
   {
   setLineTokenizer(new FixedLengthTokenizer(){ {  
   setName(new String[]{"my pojo class attributes ..."});
   setColumns( new Range { new Range[1,3] .....});
   setStrickt(false);
      }
   });
   setFieldSetMapper(new BeanWrapperFieldsSetMapper<mypojo>(){
    {  
    setTargetType(AckResponse.class):
    }
   });  }});
   return reader;
   }

  @Bean
  public CustomItemProcessor processor(){
  return new ResponseFileProcessor();
   }

  @Bean
  public CustomFileWriter<mypojo> writer(){
  return new CustomFileWriter<mypojo>();
  }
  }

/ Here is the Item Processor /

public class CustomProcessor implements ItemProcessor<mypojo,mypojo>{

public mypojo process(mypojo item) thows Exception {

return item;
}
spring-batch-admin spring-batch spring-boot java
2 Answers
user_113892180

Used ResourceAware as mentioned in the accepted answer and it worked perfectly. Adding a simple sample for visual aid.

@Data
public class Contact implements ResourceAware {
    private String name;
    private String phoneNumber;
    private String inputSrcFileName;
    private Resource resource;

    @Override
    public void setResource(Resource resource) {
        this.resource = resource;
        this.inputSrcFileName = resource.getFilename();
    }
}

Implemented on the reader input POJO

user_67761420
Related