Class Neo4jItemWriter<T>
- java.lang.Object
- org.springframework.batch.item.data.Neo4jItemWriter<T>
- All Implemented Interfaces:
ItemWriter<T>
,org.springframework.beans.factory.InitializingBean
public class Neo4jItemWriter<T> extends java.lang.Object implements ItemWriter<T>, org.springframework.beans.factory.InitializingBean
A
ItemWriter
implementation that writes to a Neo4j database.This writer is thread-safe once all properties are set (normal singleton behavior) so it can be used in multiple concurrent transactions.
- Author:
- Michael Minella, Glenn Renfro, Mahmoud Ben Hassine
Field Summary
Fields Modifier and Type Field Description protected static org.apache.commons.logging.Log
logger
Constructor Summary
Constructors Constructor Description Neo4jItemWriter()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
afterPropertiesSet()
Checks mandatory propertiesprotected void
doWrite(java.util.List<? extends T> items)
Performs the actual write using the template.void
setDelete(boolean delete)
Boolean flag indicating whether the writer should save or delete the item at write time.void
setSessionFactory(org.neo4j.ogm.session.SessionFactory sessionFactory)
Establish the session factory that will be used to createSession
instances for interacting with Neo4j.void
write(java.util.List<? extends T> items)
Write all items to the data store.
Method Detail
setDelete
public void setDelete(boolean delete)
Boolean flag indicating whether the writer should save or delete the item at write time.- Parameters:
delete
- true if write should delete item, false if item should be saved. Default is false.
setSessionFactory
public void setSessionFactory(org.neo4j.ogm.session.SessionFactory sessionFactory)
Establish the session factory that will be used to createSession
instances for interacting with Neo4j.- Parameters:
sessionFactory
- sessionFactory to be used.
afterPropertiesSet
public void afterPropertiesSet() throws java.lang.Exception
Checks mandatory properties- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
- Throws:
java.lang.Exception
- See Also:
InitializingBean.afterPropertiesSet()
write
public void write(java.util.List<? extends T> items) throws java.lang.Exception
Write all items to the data store.- Specified by:
write
in interfaceItemWriter<T>
- Parameters:
items
- items to be written- Throws:
java.lang.Exception
- if there are errors. The framework will catch the exception and convert or rethrow it as appropriate.- See Also:
ItemWriter.write(java.util.List)
doWrite
protected void doWrite(java.util.List<? extends T> items)
Performs the actual write using the template. This can be overridden by a subclass if necessary.- Parameters:
items
- the list of items to be persisted.