使用Spring Batch根据属性值来解析XML片段

Question

我想根据属性值使用以下弹簧批次分析xml，是xml。

。

<?xml version="1.0" encoding="UTF-8"?>
<customerInfo>
<cutommer dept="IT">
<param value="Jane" name="first-name"/> 
<param value="Doe" name="last-name"/>
<param value="17 Streets" name="address"/> 
<param value="1234567" name="phone-number"/>
</customer>
<cutommer dept="ES">
<param value="Jane" name="first-name"/> 
<param value="Doe" name="last-name"/>
<param value="17 Streets" name="address"/> 
<param value="1234567" name="phone-number"/>
</customer>
</customerInfo>

基于XML上方的基础，只想解析dept ribute值的客户标签是" it"。

更新1：

    @Configuration
@EnableBatchProcessing
public class ControllerInfoParser_Config extends DefaultBatchConfigurer {
    @Autowired
    private JobBuilderFactory jobs;
    @Autowired
    private StepBuilderFactory steps;
    @Bean
    public Job parseComponentInfoXML(Step parseComponentInfo,Step partitionStep, CustomJobExecutionerListener customJobExecutionerListener)
            throws UnexpectedInputException, ParseException, Exception {
        return jobs.get("parseComponentInfoXML").listener(customJobExecutionerListener).start(parseComponentInfo)
                .next(partitionStep).build();

    }
    @Bean
    public Step parseComponentInfo(ItemReader<Customer> oneDeptITItemReader) throws UnexpectedInputException, ParseException, Exception {
        return steps.get("parseComponentInfo").<Customer, Customer> chunk(1)
                .reader(componentInfoReader()).reader(oneDeptITItemReader).processor(componentInfoProcessor())
                .writer(componentInfoWriter()).build();
    }
    @Bean
    public ItemReader<Customer> componentInfoReader() throws UnexpectedInputException, ParseException, Exception {
       //OneDeptITItemReader <Customer> reader1 = new OneDeptITItemReader<Customer>();
        StaxEventItemReader<Customer> reader = new StaxEventItemReader<Customer>();
        reader.setResource(new ClassPathResource("xml//customer.xml"));
        reader.setFragmentRootElementName("customer");
        Jaxb2Marshaller marshaller = new org.springframework.oxm.jaxb.Jaxb2Marshaller();
        marshaller.setClassesToBeBound(Customer.class);
      //  marshaller.setSchema(new ClassPathResource("xml//company.xsd"));
        reader.setUnmarshaller(marshaller);
        return reader;
    }
    @Bean
    public ItemReader<Customer> oneDeptITItemReader(ItemReader<Customer> ir) {
        OneDeptITItemReader<Customer> odIR = new OneDeptITItemReader<Customer>();
        odIR.setDelegate(ir);
        return odIR;
    }
    @Bean
    public ItemProcessor<Customer, Customer> componentInfoProcessor() {
        return new CustomerProcessor();
    }
     @Bean
    public ItemWriter<Object>  componentInfoWriter() {
        return new SqlWritter();
    }
}
public class OneDeptITItemReader <T>  implements  ItemReader <Customer>{
    ItemReader<Customer> delegate;
      public ItemReader<Customer> getDelegate() {
        return delegate;
    }
    public void setDelegate(ItemReader<Customer> delegate) {
        this.delegate = delegate;
    }
    @Override
    public Customer read() {
        boolean read = true;
        Customer item = null;
        while(read)  {
          try {
            item = delegate.read();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            read =false;
        }
         read = !"IT".equals(item.getDept());
        }
        return item;
      }
}

Answer 1

停止阅读的方法是从ItemReader.read()返回null。
在找到" IT"部门后写下自定义项目阅读器代表并停止阅读。

class OneDeptITItemReader implements ItemReader<Customer> {
  ItemReader<Customer> delegate;
  @Override
  public Customer read() {
    boolean read = true;
    while(read)  {
     Customer item = delegate.read();
     read = read != null && !"IT".equals(item.getDept());
    }
    return item;
  }
}

使用委托时，您必须注册委派读者作为流，以使SB管理其生命周期。请参阅6.5代表模式并在步骤

Answer 2

在我的摘要下为我工作。

停止阅读的方法是从itemReader.read（）返回null。在找到" IT"部门后写下自定义项目阅读器代表并停止阅读。

class OneDeptITItemReader implements ItemReader<Customer> {
StaxEventItemReader<Customer> delegate;
public void setDelegate(StaxEventItemReader<Customer> delegate) {
        this.delegate = delegate;
    }
  @Override
  public Customer read() {
    boolean read = true;
   delegate.open(new ExecutionContext ());
   Customer item = null;
    while(read)  {
     item = delegate.read();
     read = item != null && !"IT".equals(item.getDept());
    }
    return item;
  }
}