Получить объект, который не прошел проверку Проверка весной партии

Question

У меня есть эта задача для обработки входных файлов .csv, .txt и хранения данных в базе данных. Для этой цели я использую Spring Batch. Перед тем, как сбрасывать данные в базу данных, я должен выполнить некоторые проверки проверки данных. Я использую Spring Batch's ValidatingItemProcessor и Hibernate's JSR-303 эталонный вариант реализации hibernate для того же самого. Код выглядит примерно так:

public class Person{ 

@Pattern(regexp = "someregex") 
String name; 
@NotNull 
String address; 
@NotNull 
String age; 

//getters and setters 

} 

И тогда я написал валидатор, который выглядит примерно так -

import javax.validation.ConstraintViolation; 
import javax.validation.Validation; 
import javax.validation.ValidatorFactory; 

import org.springframework.batch.item.validator.ValidationException; 
import org.springframework.beans.factory.InitializingBean; 

import org.springframework.batch.item.validator.Validator; 

class MyBeanValidator implements Validator<Person>, InitializingBean{ 

    private javax.validation.Validator validator; 

     @Override 
     public void afterPropertiesSet() throws Exception { 
      ValidatorFactory validatorFactory = Validation.buildDefaultValidatorFactory(); 
      validator = validatorFactory.usingContext().getValidator(); 
     } 

     @Override 
     public void validate(Person person) throws ValidationException { 
      Set<ConstraintViolation<Object>> constraintViolations = validator.validate(person); 

      if(constraintViolations.size() > 0) { 
       generateValidationException(constraintViolations); 
      } 

     } 
private void generateValidationException(Set<ConstraintViolation<Object>> constraintViolations) { 
      StringBuilder message = new StringBuilder(); 

      for (ConstraintViolation<Object> constraintViolation : constraintViolations) { 
       message.append(constraintViolation.getMessage() + "\n"); 
      } 

      throw new ValidationException(message.toString()); 
} 

И тогда у меня есть процессор, который подкласс Spring Batch-х ValidatingItemProcessor.

public class ValidatingPersonItemProcessor extends ValidatingItemProcessor<Person>{ 


@Override 
public Person process(Person person) { 

//some code 
} 

Записи, которые проходят проверку достоверности будет передан на другой процессор для дальнейшей обработки, но не смогли из них будут очищены, а затем перешел к следующему процессору.

1. Теперь я хочу поймать записи, которые не прошли проверку. Моя цель - сообщить обо всех входных записях, которые не прошли проверку и очистить эти записи, прежде чем я смогу передать эти записи следующему процессору для дальнейшей обработки. Как я могу это достичь?

2. Будет ли процесс весенней партии прекращаться, если проверка не выполняется для некоторого ввода? Если да, как этого избежать? Моя конфигурация процессора выглядит примерно так:

   <batch:chunk reader="personItemReader" writer="personDBWriter" processor="personProcessor" 
         commit-interval="100" skip-limit="100"> 
         <batch:skippable-exception-classes> 
          <batch:include class="org.springframework.batch.item.validator.ValidationException"/> 
         </batch:skippable-exception-classes> 
         <batch:listeners> 
          <batch:listener> 
           <bean 
             class="org.someorg.poc.batch.listener.PersonSkipListener" /> 
          </batch:listener> 
         </batch:listeners> 
        </batch:chunk> 
   <bean id="personProcessor" 
   class="org.springframework.batch.item.support.CompositeItemProcessor"> 
       <property name="delegates"> 
       <list> 
        <ref bean="validatingPersonItemProcessor" /> 
        <ref bean="personVerifierProcessor" /> 
       </list> 
       </property> 
   </bean> 
       <bean id="validatingPersonItemProcessor" class="org.someorg.poc.batch.processor.ValidatingPersonItemProcessor" scope="step"> 
       <property name="validator" ref="myBeanValidator" /> 
       </bean> 
   
       <bean id="myBeanValidator" class="org.someorg.poc.batch.validator.MyBeanValidator"> 
   </bean> 
   
       <bean id="personVerifierProcessor" class="org.someorg.poc.batch.processor.PersonVerifierProcessor"  scope="step"/> 
       </beans> 
   

Answer 1

Я предполагаю, что ваш validatingPersonItemProcessor боб имеет свой параметр валидатор установить с myBeanValidator. Таким образом, процессор Exception будет выброшен.

Создайте свой собственный SkipListener. Здесь вы помещаете логику того, что происходит, когда элемент не проверяется (записывается в файл, DB и т. Д.), В onSkipInProcess();.

Вы должны добавить ValidationException вы бросаете в <batch:skippable-exception-classes> так что они будут пойманной (и не прекращает свой пакет), и добавить SkipListener в <batch:listeners>, так что это будет назвать, когда исключение.

EDIT: Ответить на комментарий. Если ваш процессор является ValidatingItemProcessor, и вы устанавливаете валидатор, он должен автоматически вызывать подтверждение. Однако, если вы сделаете свой собственный ValidatingItemProcessor, расширив его, вы должны прямо позвонить super.process(yourItem); (process() of ValidatingItemProcessor), чтобы подтвердить свой товар.