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

クラス Neo4jItemReader<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.Neo4jItemReader<T>
実装されたすべてのインターフェース:
ItemReader<T>、ItemStream、ItemStreamReader<T>、org.springframework.beans.factory.InitializingBean
@DeprecatedSE public class Neo4jItemReader<T> extends AbstractPaginatedDataItemReader<T> implements org.springframework.beans.factory.InitializingBean
使用すべきではありません。
5.0 以降、... のアイテムリーダーを優先

ページング技術を介してグラフデータベース Neo4j からオブジェクトを読み取る再起動可能な ItemReader。

リクエストされたデータを取得するために提供されたステートメントフラグメントから構築された暗号クエリを実行します。クエリは、AbstractPaginatedDataItemReader.setPageSize(int) で指定されたサイズのページリクエストを使用して実行されます。AbstractItemCountingItemStreamItemReader.read() メソッドが呼び出されると、必要に応じて追加のページがリクエストされます。再起動すると、リーダーは中断したのと同じ番号の項目から再開します。

パフォーマンスは、Neo4J 構成（埋め込みまたはリモート）とページサイズに依存します。かなり大きなページサイズを設定し、ページサイズと一致するコミット間隔を使用すると、パフォーマンスが向上するはずです。

この実装は AbstractItemCountingItemStreamItemReader.open(org.springframework.batch.item.ExecutionContext) の呼び出し間でスレッドセーフですが、マルチスレッド環境で使用する場合は saveState=false を設定する必要があります（再起動は利用できません）。

作成者:
Michael Minella, Mahmoud Ben Hassine

  • フィールドの詳細

    • logger

      protected org.apache.commons.logging.Log logger
      使用すべきではありません。

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

    • Neo4jItemReader

      public Neo4jItemReader()
      使用すべきではありません。

  • メソッドの詳細

    • setParameterValues

      public void setParameterValues(MapSE<StringSE,ObjectSE> parameterValues)
      使用すべきではありません。
      暗号クエリで使用されるオプションのパラメーター。
      パラメーター:
      parameterValues - 暗号クエリで使用されるパラメーター値

    • getParameterValues

      protected final MapSE<StringSE,ObjectSE> getParameterValues()
      使用すべきではありません。

    • setStartStatement

      public void setStartStatement(StringSE startStatement)
      使用すべきではありません。
      暗号クエリの開始セグメント。START は、提供されたステートメントの前に付加されるため、含めるべきではありません。
      パラメーター:
      startStatement - 暗号クエリの開始フラグメント。

    • setReturnStatement

      public void setReturnStatement(StringSE returnStatement)
      使用すべきではありません。
      暗号クエリの return ステートメント。RETURN は、提供されたステートメントの前に付加されるため、含めるべきではありません
      パラメーター:
      returnStatement - 暗号クエリの戻りフラグメント。

    • setMatchStatement

      public void setMatchStatement(StringSE matchStatement)
      使用すべきではありません。
      暗号クエリのオプションの一致フラグメント。MATCH は、提供されたステートメントの前に付加されるため、含めるべきではありません。
      パラメーター:
      matchStatement - 暗号クエリの一致フラグメント

    • setWhereStatement

      public void setWhereStatement(StringSE whereStatement)
      使用すべきではありません。
      暗号クエリのオプションの where フラグメント。WHERE は、提供されたステートメントの前に付加されるため、含めるべきではありません。
      パラメーター:
      whereStatement - 暗号クエリのフラグメント

    • setOrderByStatement

      public void setOrderByStatement(StringSE orderByStatement)
      使用すべきではありません。
      結果を並べ替えるプロパティのリスト。これは、後続のページリクエストが結果のセグメントを正しくプルバックするために必要です。ORDER BY は、提供されたステートメントの前に付加されるため、含めるべきではありません。
      パラメーター:
      orderByStatement - 暗号クエリのフラグメントによる順序付け。

    • getSessionFactory

      protected org.neo4j.ogm.session.SessionFactory getSessionFactory()
      使用すべきではありません。

    • setSessionFactory

      public void setSessionFactory(org.neo4j.ogm.session.SessionFactory sessionFactory)
      使用すべきではありません。
      リーダーのセッションファクトリを確立します。
      パラメーター:
      sessionFactory - リーダーに使用するファクトリ。

    • setTargetType

      public void setTargetType(ClassSE<T> targetType)
      使用すべきではありません。
      AbstractItemCountingItemStreamItemReader.read() への各呼び出しから返されるオブジェクト型
      パラメーター:
      targetType - 返すオブジェクトの型。

    • getTargetType

      protected final ClassSE<T> getTargetType()
      使用すべきではありません。

    • generateLimitCypherQuery

      protected StringSE generateLimitCypherQuery()
      使用すべきではありません。

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      使用すべきではありません。
      必須プロパティをチェックします
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      例外:
      ExceptionSE
      関連事項:
      • InitializingBean.afterPropertiesSet()

    • doPageRead

      protected IteratorSE<T> doPageRead()
      使用すべきではありません。
      クラスからコピーされた説明: AbstractPaginatedDataItemReader
      この ItemStreamReader がページを読み取る実際の作業のために委譲するメソッド。このメソッドが呼び出されるたびに、結果の IteratorSE には、次のページ内で読み取られた項目が含まれている必要があります。

      返されたときに IteratorSE が空または null の場合、この ItemReader は入力が使い果たされたと想定します。
      次で指定:
      クラス AbstractPaginatedDataItemReader<T> の doPageRead 
      戻り値:
      ページ内のアイテムを含む IteratorSE。