パッケージ org.springframework.batch.item.data

クラス MongoItemWriter<T>

java.lang.ObjectSE
org.springframework.batch.item.data.MongoItemWriter<T>
実装済みのインターフェース一覧:
ItemWriter<T>, org.springframework.beans.factory.InitializingBean
public class MongoItemWriter<T> extends ObjectSE implements ItemWriter<T>, org.springframework.beans.factory.InitializingBean

Spring Data の MongoOperations の実装を使用して MongoDB ストアに書き込む ItemWriter 実装。MongoDB はトランザクションストアではないため、書き込まれたデータを最後の瞬間に保持し、それでもジョブステータス契約を尊重するように最善を尽くします。書き込み中にエラーが発生した場合、ロールバックは試行されません。

このライターは、すべてのプロパティが設定されるとスレッドセーフになるため（通常のシングルトン動作）、複数の同時トランザクションで使用できます。

作成者:
Michael Minella, Parikshit Dutta, Mahmoud Ben Hassine

  • コンストラクター概要

    コンストラクター
    コンストラクター
    説明
    MongoItemWriter()

  • 方法の概要

    修飾子と型
    メソッド
    説明
    void
    afterPropertiesSet()
    protected void
    doWrite(Chunk<? extends T> chunk)
    テンプレートを介してストアへの実際の書き込みを実行します。
    protected org.springframework.data.mongodb.core.MongoOperations
    getTemplate()
    書き込むアイテムを保存するために使用する MongoOperations を入手します。
    void
    setCollection(StringSE collection)
    書き込む Mongo コレクションの名前を設定します。
    void
    setDelete(boolean delete)
    ライターに渡されるアイテムを保存するか、データストアから削除するかを示します。
    void
    setTemplate(org.springframework.data.mongodb.core.MongoOperations template)
    書き込むアイテムを保存するために使用する MongoOperations を設定します。
    void
    write(Chunk<? extends T> chunk)
    トランザクションがアクティブな場合、コミットの直前に書き込まれるアイテムをバッファリングします。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

  • コンストラクターの詳細

    • MongoItemWriter

      public MongoItemWriter()

  • 方法の詳細

    • setDelete

      public void setDelete(boolean delete)
      ライターに渡されるアイテムを保存するか、データストアから削除するかを示します。false（デフォルト）に設定すると、アイテムが保存されます。true に設定すると、アイテムは削除されます。
      パラメーター:
      delete - 除去インジケーター

    • setTemplate

      public void setTemplate(org.springframework.data.mongodb.core.MongoOperations template)
      書き込むアイテムを保存するために使用する MongoOperations を設定します。
      パラメーター:
      template - 使用するテンプレートの実装。

    • getTemplate

      protected org.springframework.data.mongodb.core.MongoOperations getTemplate()
      書き込むアイテムを保存するために使用する MongoOperations を入手します。これは、必要に応じてサブクラスから呼び出すことができます。
      戻り値:
      テンプレート使用するテンプレート実装。

    • setCollection

      public void setCollection(StringSE collection)
      書き込む Mongo コレクションの名前を設定します。
      パラメーター:
      collection - コレクションの名前。

    • write

      public void write(Chunk<? extends T> chunk) throws ExceptionSE
      トランザクションがアクティブな場合、コミットの直前に書き込まれるアイテムをバッファリングします。それ以外の場合は、提供されたテンプレートを使用してアイテムを記述します。
      次で指定:
      インターフェース ItemWriter<T> 内の write 
      パラメーター:
      chunk - 書きこまれる項目。null であってはなりません。
      例外:
      ExceptionSE - エラーがある場合。フレームワークは例外をキャッチし、必要に応じて変換または再スローします。
      関連事項:

    • doWrite

      protected void doWrite(Chunk<? extends T> chunk)
      テンプレートを介してストアへの実際の書き込みを実行します。これは、必要に応じてサブクラスによってオーバーライドできます。
      パラメーター:
      chunk - 永続化されるアイテムのチャンク。

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean 内の afterPropertiesSet 
      例外:
      ExceptionSE