クラス MongoCursorItemReader<T>

実装されたすべてのインターフェース:
ItemReader<T>ItemStreamItemStreamReader<T>org.springframework.beans.factory.InitializingBean

public class MongoCursorItemReader<T> extends AbstractItemCountingItemStreamItemReader<T> implements org.springframework.beans.factory.InitializingBean
MongoDB 用のカーソルベースの ItemReader 実装。
導入:
5.1
作成者:
LEE Juchan, Mahmoud Ben Hassine
  • コンストラクターの詳細

    • MongoCursorItemReader

      public MongoCursorItemReader()
      新しい MongoCursorItemReader を作成します。
  • メソッドの詳細

    • setTemplate

      public void setTemplate(org.springframework.data.mongodb.core.MongoOperations template)
      MongoDB インスタンスに対して操作を実行するために使用されます。ドキュメントのオブジェクトへのマッピングも処理します。
      パラメーター:
      template - 使用する MongoOperations インスタンス
      関連事項:
      • MongoOperations
    • setTargetType

      public void setTargetType(ClassSE<? extends T> targetType)
      AbstractItemCountingItemStreamItemReader.read() 呼び出しに対して返されるオブジェクトの targetType。
      パラメーター:
      targetType - 返すオブジェクトの targetType
    • setCollection

      public void setCollection(StringSE collection)
      パラメーター:
      collection - 照会する Mongo コレクション。
    • setQuery

      public void setQuery(org.springframework.data.mongodb.core.query.Query query)
      使用する Mongo クエリ。
      パラメーター:
      query - 使用する Mongo クエリ。
    • setQuery

      public void setQuery(StringSE queryString)
      JSON 形式の MongoDB クエリ。提供されたクエリのパラメーター化は、?<index> プレースホルダーを介して許可されます。<index> は、置換する parameterValue のインデックスを示します。
      パラメーター:
      queryString - JSON 形式の Mongo クエリ
    • setParameterValues

      public void setParameterValues(ListSE<ObjectSE> parameterValues)
      クエリの各パラメーターに代入される ListSE の値。
      パラメーター:
      parameterValues - 個の値
    • setFields

      public void setFields(StringSE fields)
      MongoDB によって一致するドキュメントから返されるフィールドを定義する JSON。
      パラメーター:
      fields - ソートするフィールドを識別する JSON 文字列。
    • setSort

      public void setSort(MapSE<StringSE,org.springframework.data.domain.Sort.Direction> sorts)
      入力を並べ替えるプロパティ名 /Sort.Direction 値の MapSE
      パラメーター:
      sorts - プロパティのマップとそれぞれを並べ替える方向。
    • setHint

      public void setHint(StringSE hint)
      使用するインデックスを MongoDB に指示する JSON 文字列。
      パラメーター:
      hint - 使用するインデックスを示す文字列。
    • setBatchSize

      public void setBatchSize(int batchSize)
      結果を反復処理するときに使用するバッチのサイズ。
      パラメーター:
      batchSize - size カーソルに適用するバッチサイズ
      関連事項:
      • Query.cursorBatchSize(int)
    • setLimit

      public void setLimit(int limit)
      クエリ制限。
      パラメーター:
      limit - 限界
      関連事項:
      • Query.limit(int)
    • setMaxTime

      public void setMaxTime(DurationSE maxTime)
      クエリの最大実行時間
      パラメーター:
      maxTime - 最大時間
      関連事項:
      • Query.maxTime(Duration)
    • afterPropertiesSet

      public void afterPropertiesSet()
      必須プロパティをチェックします
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBeanafterPropertiesSet 
      関連事項:
      • InitializingBean.afterPropertiesSet()
    • doOpen

      protected void doOpen() throws ExceptionSE
      クラスからコピーされた説明: AbstractItemCountingItemStreamItemReader
      入力の読み取りを開始するために必要なリソースを開きます。
      次で指定:
      クラス AbstractItemCountingItemStreamItemReader<T>doOpen 
      例外:
      ExceptionSE - サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
    • doRead

      protected T doRead() throws ExceptionSE
      クラスからコピーされた説明: AbstractItemCountingItemStreamItemReader
      入力から次の項目を読み取ります。
      次で指定:
      クラス AbstractItemCountingItemStreamItemReader<T>doRead 
      戻り値:
      データソースが使い果たされた場合、アイテムまたは null 
      例外:
      ExceptionSE - サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
    • doClose

      protected void doClose() throws ExceptionSE
      クラスからコピーされた説明: AbstractItemCountingItemStreamItemReader
      AbstractItemCountingItemStreamItemReader.doOpen() で開いたリソースを閉じます。
      次で指定:
      クラス AbstractItemCountingItemStreamItemReader<T>doClose 
      例外:
      ExceptionSE - サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします