Plusieurs itemwriters dans Spring batch

Je suis actuellement à la rédaction d'un Spring batch où je suis de la lecture d'un bloc de données, le traitement et puis je tiens à transmettre ces données à des 2 auteurs. Un écrivain serait tout simplement de mettre à jour la base de données tandis que le second auteur va écrire dans un fichier csv.

Je prévois d'écrire mon propre écrivain et injecter les deux itemWriters dans le customItemWriter et d'appeler les méthodes d'écriture de l'article écrivains dans la méthode d'écriture de customItemWriter. Cette approche est-elle correcte? Il n'existe aucun ItemWriter implémentations disponibles qui répondent à mes besoins?

Merci d'avance

OriginalL'auteur Pratik Shelar | 2013-09-20

  1. 17

    Vous pouvez utiliser le Printemps CompositeItemWriter et délégué à les auteurs.

    voici une exemple de configuration.

    L'exemple a été vraiment utile.
    Salut Pratique - Pourriez-vous s'il vous plaît partager un exemple de code? Je suis épuisé dans l'obtention de la solution de ce problème.

    OriginalL'auteur Oussama Zoghlami

  2. 8

    Vous n'avez pas nécessairement besoin d'utiliser xml comme dans l'exemple. Si le reste de votre code utilise l'annotation, vous pouvez simplement faire ce qui suit.

    public ItemWriter<T> writerOne(){
    ItemWriter<T> writer = new ItemWriter<T>();
    //your logic here
    return writer;
}

public ItemWriter<T> writerTwo(){
    ItemWriter<T> writer = new ItemWriter<T>();
    //your logic here
    return writer;
}

public CompositeItemWriter<T> compositeItemWriter(){
    CompositeItemWriter writer = new CompositeItemWriter();
    writer.setDelegates(Arrays.asList(writerOne(),writerTwo()));
    return writer;
}

    OriginalL'auteur Yilei

  3. 2

    Vous avez eu raison. SB est heavly basé sur la délégation en utilisant un CompositeItemWriter est le bon choix pour vos besoins.

    savez-vous comment obtenir ce par le multi threading les écrivains?

    OriginalL'auteur Luca Basso Ricci

  4. 0

    Selon votre besoin, une autre option est d'étendre la classe Writer et ajouter des fonctionnalités. Par exemple, j'ai un projet où je suis étendre HibernateItemWriter et puis en substituant écrire(les éléments de la Liste). J'ai ensuite envoyer les objets que j'ai écris avec mon sessionFactory à la doWrite méthode de l'Écrivain: doWrite(sessionFactory, filteredRecords).

    Ainsi dans l'exemple ci-dessus, je pourrais écrire le fichier csv dans mon extension de la classe et puis les HibernateItemWriter voudrais écrire à la base de données. Évidemment, cela peut ne pas être idéal pour cet exemple, mais pour certains scénarios, il est une bonne option.

    OriginalL'auteur MattC

  5. 0

    Java Config façon SpringBatch4 

    @Bean
    public Step step1() {
            return this.stepBuilderFactory.get("step1")
                                    .<String, String>chunk(2)
                                    .reader(itemReader())
                                    .writer(compositeItemWriter())
                                    .stream(fileItemWriter1())
                                    .stream(fileItemWriter2())
                                    .build();
    }

    /**
     * In Spring Batch 4, the CompositeItemWriter implements ItemStream so this isn't
     * necessary, but used for an example.
     */
    @Bean
    public CompositeItemWriter compositeItemWriter() {
            List<ItemWriter> writers = new ArrayList<>(2);
            writers.add(fileItemWriter1());
            writers.add(fileItemWriter2());

            CompositeItemWriter itemWriter = new CompositeItemWriter();

            itemWriter.setDelegates(writers);

            return itemWriter;
    }

    OriginalL'auteur Niraj Sonawane