Spring Batch - Passer L'Enregistrement Sur Les Processus

Je voulais sauter certaines enregistrement sur le processus.

ce que j'ai essayé, j'ai créé exception personnalisée et jeter l'exception quand je veux sauter l'enregistrement et le son de l'appel de la Sauter auditeur onSkipInProcess méthode.Son travail très bien.

veuillez trouver la configuration.

 <batch:chunk reader="masterFileItemReader" writer="masterFileWriter" processor="itemProcessor" commit-interval="5000" skip-limit="100000" >
  <batch:skippable-exception-classes>
        <batch:include class="org.springframework.batch.item.file.FlatFileParseException"/>
        <batch:include class="com.exception.SkipException"/>
  </batch:skippable-exception-classes>
  <batch:listeners>
        <batch:listener ref="recordSkipListener"/>
</batch:listeners>

Mais je voudrais savoir est-il un autre moyen de sauter l'enregistrement sur le processus?

Ce qui concerne,
Shankar

oui, on peut sauter l'enregistrement sur coditional base.s'il vous plaît trouver l'extrait de code beelow ce
Vous pouvez toujours lire les docs ici et ici. Vous pouvez également trouver de bons exemples ici.

OriginalL'auteur Shankar | 2015-03-13

  1. 8

    Il y a en effet deux façons de le faire, comme vous le mentionnez avec skip mécanisme et l'autre avec le retour des null qui va filtrer élément et de ne pas l'écrire. Voici documentation lien - 6.3.2. Le filtrage des enregistrements où il est joliment expliqué quelle est la différence entre les deux approches. Aussi cette post de blog explique sauter dans les détails et les transactions dans le lot.

    Lorsque vous c'est à dire analyser le fichier csv et vous vous attendez à 5 pièces par ligne, mais une ligne contient 6 éléments élément non valide, et vous pouvez choisir de l'ignorer (par marquage lecteur exception comme désactivables et la définition de la condition de la politique que vous avez donné l'exemple). Toutefois, si chaque ligne a nom et votre cas est de ne pas écrire des articles qui commencent par la lettre N qui est mieux mis en œuvre avec le retour des null (filtrage de l'élément), puisqu'il est valide, mais pas selon votre.

    Veuillez noter également que si vous retournez null nombre de ces articles seront en StepContext dans getFilterCount() et si vous utilisez le saut de l'approche qu'ils seront en getReadSkipCount(), getProcessorSkipCount et getWriteSkipCount respectueusement.

    Merci @Nenad pour la réponse détaillée et aussi lors de l'utilisation de null et lors de l'utilisation de skip auditeur.
    Salut Nenad, getFilterCount() la méthode est en StepExecution classe, comment obtenir ce par le biais de java?je voudrais prendre le nombre d'enregistrements ignorés dans le travail.
    Dans mon test, je suis en cours d'exécution d'emplois et d'économie que l'exécution de la tâche et lorsque je veux vérifier combien sont filtrés utilisation jobExecution.getStepExecutions() qui est de la collection, mais je peux courir à travers elle et de trouver mon étape de l'exécution par un nom qui a la méthode getFilterCount()
    Merci beaucoup @Nenad...

    OriginalL'auteur Nenad Bozic

  2. 1
    @Component
@Scope(value = "step")
public class XyzItemProcessor implements ItemProcessor<ABCInfo , ABCInfo > {

@Override
public ABCInfo process(ABCInfo abcInfo) throws Exception {

    if (abcInfo.getRecordType().equals("H") || extVoterInfo.getRecordType().equals("T"))
        return null;////this is how we skip particular record to persist in database
    else {
        return abcInfo;
    }
}
}

    Retourner la valeur null ignorer l'enregistrement particulier être conservées dans la base de données

    Merci @Bhaji.. je vais vérifier et vous permettent de savoir..
    Si vous avez besoin d'un régulier à sauter qui est de filtrer enregistrement en fonction de critères que vous pouvez identifier les valeur null à ignorer les enregistrements en cours d'écriture. Le onSkipInProcess doit être utilisé lorsqu'une exception se produit lors de la transformation et de continuer le traitement, mais souhaitez prendre des mesures pour l'enregistrement d'erreur (journalisation, alertes e-mail)
    De retour null ne sera pas exactement ignorer... Retour null voudrais juste filtre. Sauter est utilisé pour la gestion des exceptions. Lire le la documentation liée par Nenad.
    Avez-vous été en mesure de résoudre ce problème ?
    Désolé, je ne me rappel Il y a quelques temps je suis passé par cette question. Mais je vous recommande la lecture de la documentation.

    OriginalL'auteur Baji Shaik

  3. 0

    lorsque nous retourner la valeur null dans la méthode process (), il va filtrer l'enregistrement et d'augmenter le filtre comte.

    @Transactional(propagation = Propagation.REQUIRED)
    @Override
    public SomeObject process(SomeObject someObject) throws Exception {
        if (some condition) {
            return null;
        }   
}

    Si Nous voulons sauter l'enregistrement , de lever une exception. Cela permettra de sauter l'enregistrement et l'augmentation processSkipCount.

    @Transactional(propagation = Propagation.REQUIRED)
    @Override
    public SomeObject process(SomeObject someObject) throws Exception {
        if (some condition) {
            throw new Exception("invalid record");
        }   
}

    Ajouter cette Exception fichier de contexte.

    <batch:skippable-exception-classes>
<batch:include class="java.lang.Exception" />
</batch:skippable-exception-classes>

    OriginalL'auteur AKT

  4. 0

    Il y a, ainsi, une autre façon de ne pas écrire (en sautant) quelque chose. Par exemple, disons que nous avons de cette étape:

            <batch:step id="createCsvStep">
         <batch:tasklet>
            <batch:chunk reader="jdbcCursorItemReader" processor="processor" writer="compositeWriter"
                         commit-interval="#{jobParameters['commit.interval']}" />
         </batch:tasklet>
        </batch:step>

        <bean id="compositeWriter" class="org.springframework.batch.item.support.CompositeItemWriter" scope="step">
         <property name="delegates">
          <list>
            <ref bean="csvFileItemWriter1"/>
            <ref bean="csvFileItemWriter2"/>
          </list>
        </property>
       </bean>

    Supposons que premier auteur va écrire toutes les valeurs, mais dans le même temps, la deuxième écrivain ignorer certains d'entre eux. Pour arriver à cela, nous avons pu étendre notre écrivain(par ex. FlatFileItemWriter), et de remplacer la méthode d'écriture comme ceci:

        @Override
public void write(List<? extends T> items) throws Exception {
    //...
    if (itemsPassesCheckingCondition) {
        super.write(items);
    }
}

    OriginalL'auteur MaxKing