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

クラス MongoPagingItemReader<T>

java.lang.ObjectSE
org.springframework.batch.item.ItemStreamSupport
org.springframework.batch.item.support.AbstractItemStreamItemReader<T>
org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader<T>
org.springframework.batch.item.data.AbstractPaginatedDataItemReader<T>
org.springframework.batch.item.data.MongoItemReader<T>
org.springframework.batch.item.data.MongoPagingItemReader<T>
型パラメーター:
T - 読むアイテムの種類
実装されたすべてのインターフェース:
ItemReader<T>、ItemStream、ItemStreamReader<T>、org.springframework.beans.factory.InitializingBean
public class MongoPagingItemReader<T> extends MongoItemReader<T>

ページング手法を使用して MongoDB からドキュメントを読み取る再起動可能な ItemReader。

JSON 文字列クエリ MongoItemReader.setQuery(String) を設定すると、リクエストされたドキュメントを取得するために JSON が実行されます。

Query オブジェクト MongoItemReader.setQuery(Query) を設定すると、リクエストされたドキュメントを取得するために Query が実行されます。

クエリは、AbstractPaginatedDataItemReader.setPageSize(int) で指定されたページリクエストを使用して実行されます。AbstractItemCountingItemStreamItemReader.read() メソッドが呼び出されると、データを提供するために必要に応じて追加のページがリクエストされます。

提供される JSON 文字列クエリは、?<index> プレースホルダーを介したパラメーター置換をサポートします。<index> は、置換する parameterValue のインデックスを示します。

実装は AbstractItemCountingItemStreamItemReader.open(ExecutionContext) の呼び出し間でスレッドセーフですが、マルチスレッドクライアントで使用する場合は saveState=false を使用することを忘れないでください（再起動は利用できません）。

導入:
5.1
作成者:
Michael Minella, Takaaki Iida, Mahmoud Ben Hassine, Parikshit Dutta

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

    • MongoPagingItemReader

      public MongoPagingItemReader()
      新しい MongoPagingItemReader を作成します。