Neo4jItemReader
を拡張してください。@Deprecated public abstract class AbstractNeo4jItemReader<T> extends AbstractPaginatedDataItemReader<T> implements org.springframework.beans.factory.InitializingBean
ページング技術を介してグラフデータベース Neo4j からオブジェクトを読み取る再起動可能な ItemReader
。
リクエストされたデータを取得するために提供されたステートメントフラグメントから構築された暗号クエリを実行します。クエリは、AbstractPaginatedDataItemReader.setPageSize(int)
で指定されたサイズのページリクエストを使用して実行されます。AbstractItemCountingItemStreamItemReader.read()
メソッドが呼び出されると、必要に応じて追加のページがリクエストされます。再起動すると、リーダーは中断したのと同じ番号の項目から再開します。
パフォーマンスは、Neo4J 構成(埋め込みまたはリモート)とページサイズに依存します。かなり大きなページサイズを設定し、ページサイズと一致するコミット間隔を使用すると、パフォーマンスが向上するはずです。
この実装は AbstractItemCountingItemStreamItemReader.open(org.springframework.batch.item.ExecutionContext)
の呼び出し間でスレッドセーフですが、マルチスレッド環境で使用する場合は saveState=false
を設定する必要があります(再起動は利用できません)。
修飾子と型 | フィールドと説明 |
---|---|
protected org.apache.commons.logging.Log | logger 使用すべきではありません。 |
page, pageSize, results
コンストラクターと説明 |
---|
AbstractNeo4jItemReader() 使用すべきではありません。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() 使用すべきではありません。 必須プロパティをチェックします |
protected java.lang.String | generateLimitCypherQuery() 使用すべきではありません。 |
protected java.util.Map<java.lang.String,java.lang.Object> | getParameterValues() 使用すべきではありません。 |
protected org.neo4j.ogm.session.SessionFactory | getSessionFactory() 使用すべきではありません。 |
protected java.lang.Class<T> | getTargetType() 使用すべきではありません。 |
void | setMatchStatement(java.lang.String matchStatement) 使用すべきではありません。 暗号クエリのオプションの一致フラグメント。 |
void | setOrderByStatement(java.lang.String orderByStatement) 使用すべきではありません。 結果を並べ替えるプロパティのリスト。 |
void | setParameterValues(java.util.Map<java.lang.String,java.lang.Object> parameterValues) 使用すべきではありません。 暗号クエリで使用されるオプションのパラメーター。 |
void | setReturnStatement(java.lang.String returnStatement) 使用すべきではありません。 暗号クエリの return ステートメント。 |
void | setSessionFactory(org.neo4j.ogm.session.SessionFactory sessionFactory) 使用すべきではありません。 リーダーのセッションファクトリを確立します。 |
void | setStartStatement(java.lang.String startStatement) 使用すべきではありません。 暗号クエリの開始セグメント。 |
void | setTargetType(java.lang.Class<T> targetType) 使用すべきではありません。 AbstractItemCountingItemStreamItemReader.read() への各呼び出しから返されるオブジェクト型 |
void | setWhereStatement(java.lang.String whereStatement) 使用すべきではありません。 暗号クエリのオプションの where フラグメント。 |
doClose, doOpen, doPageRead, doRead, jumpToItem, setPageSize
close, getCurrentItemCount, isSaveState, open, read, setCurrentItemCount, setMaxItemCount, setSaveState, update
getExecutionContextKey, setExecutionContextName, setName
public void setParameterValues(java.util.Map<java.lang.String,java.lang.Object> parameterValues)
parameterValues
- 暗号クエリで使用されるパラメーター値 protected final java.util.Map<java.lang.String,java.lang.Object> getParameterValues()
public void setStartStatement(java.lang.String startStatement)
startStatement
- 暗号クエリの開始フラグメント。public void setReturnStatement(java.lang.String returnStatement)
returnStatement
- 暗号クエリの戻りフラグメント。public void setMatchStatement(java.lang.String matchStatement)
matchStatement
- 暗号クエリの一致フラグメント public void setWhereStatement(java.lang.String whereStatement)
whereStatement
- 暗号クエリのフラグメント public void setOrderByStatement(java.lang.String orderByStatement)
orderByStatement
- 暗号クエリのフラグメントによる順序付け。protected org.neo4j.ogm.session.SessionFactory getSessionFactory()
public void setSessionFactory(org.neo4j.ogm.session.SessionFactory sessionFactory)
sessionFactory
- リーダーに使用するファクトリ。public void setTargetType(java.lang.Class<T> targetType)
AbstractItemCountingItemStreamItemReader.read()
への各呼び出しから返されるオブジェクト型 targetType
- 返すオブジェクトの型。protected final java.lang.Class<T> getTargetType()
protected java.lang.String generateLimitCypherQuery()
public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception
InitializingBean.afterPropertiesSet()