Neo4jEntityPersister (GORM for Neo4j

org.grails.datastore.gorm.neo4j.engine.Neo4jEntityPersister

```
public class Neo4jEntityPersister
extends EntityPersister
```
Core EntityPersister implementation responsible for CRUD operations against the Graph.
Authors:
Stefan Armbruster ([email protected])
Graeme Rocher
Since:
1.0

Field Summary

Fields
Modifiers	Name	Description
`static java.lang.String`	`DYNAMIC_ASSOCIATION_PARAM`
`private static org.slf4j.Logger`	`log`

Inherited fields
Fields inherited from class	Fields
`class EntityPersister`	`mappingContext, persistentEntity, proxyFactory, publisher, reflector, session`

Constructor Summary

Constructors
Constructor and description
`Neo4jEntityPersister (MappingContext mappingContext, PersistentEntity entity, Session session, org.springframework.context.ApplicationEventPublisher publisher)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`private int`	`calcInheritenceChain(PersistentEntity current)`
	`public static long`	`countUpdates(org.neo4j.driver.Result execute)`
	`private java.util.Collection`	`createCollection(Association association)`
	`private java.util.Collection`	`createDirtyCheckableAwareCollection(EntityAccess entityAccess, Association association, java.util.Collection delegate)`
	`private PendingDeleteAdapter`	`createPendingDeleteOne(Neo4jSession session, PersistentEntity pe, EntityAccess entityAccess, java.lang.Object obj)`
	`public Query`	`createQuery()`
	`protected void`	`deleteEntities(PersistentEntity pe, java.lang.Iterable objects)`
	`protected void`	`deleteEntity(PersistentEntity pe, java.lang.Object obj)`
	`private PersistentEntity`	`findDerivedPersistentEntityWithLabel(PersistentEntity parent, java.lang.String label)`
	`public java.io.Serializable`	`getNativeKey()`
	`public java.io.Serializable`	`getNativeKey()`
	`public Neo4jSession`	`getSession()`
	`private void`	`handleRelationshipSide(PersistentEntity persistentEntity, java.util.Map<java.lang.String, java.lang.Object> resultData, java.lang.Object entity, java.lang.String associationNodesKey, Neo4jResultList resultSet, Association association)`
	`private boolean`	`isInParentsChain(PersistentEntity parent, PersistentEntity it)`
	`private PersistentEntity`	`mostSpecificPersistentEntity(PersistentEntity pe, java.lang.Iterable<java.lang.String> labels)`
	`private void`	`persistAssociationsOfEntity(GraphPersistentEntity graphEntity, EntityAccess entityAccess, boolean isUpdate)`
	`protected java.util.List<java.io.Serializable>`	`persistEntities(PersistentEntity pe, java.lang.Iterable objs)`
	`protected java.io.Serializable`	`persistEntity(PersistentEntity entity, java.lang.Object obj, boolean isInsert)`
	`protected java.io.Serializable`	`persistEntity(PersistentEntity pe, java.lang.Object obj)`
	`private void`	`processDynamicAssociationRemoval(GraphPersistentEntity graphEntity, EntityAccess entityAccess, Neo4jSession neo4jSession, MappingContext mappingContext, java.lang.String associationName, java.lang.Object originalValue)`
	`public void`	`processDynamicAssociations(GraphPersistentEntity graphEntity, EntityAccess access, Neo4jMappingContext mappingContext, java.util.Map<java.lang.String, java.util.List<java.lang.Object>> dynamicRelProps, java.util.List<PendingOperation<java.lang.Object, java.io.Serializable>> cascadingOperations, boolean isUpdate)`
	`public java.io.Serializable`	`refresh(java.lang.Object o)`
	`private void`	`registerPendingUpdate(Neo4jSession session, PersistentEntity pe, EntityAccess ea, java.lang.Object obj, java.io.Serializable identifier)`
	`protected java.util.List<java.lang.Object>`	`retrieveAllEntities(PersistentEntity pe, java.io.Serializable[] keys)`
	`protected java.util.List<java.lang.Object>`	`retrieveAllEntities(PersistentEntity pe, java.lang.Iterable<java.io.Serializable> keys)`
	`protected java.lang.Object`	`retrieveEntity(PersistentEntity pe, java.io.Serializable key)`
	`public void`	`run()`
	`public void`	`run()`
	`public void`	`run()`
	`public void`	`run()`
	`public void`	`run()`
	`public void`	`run()`
	`public void`	`run()`
	`public void`	`run()`
	`private boolean`	`shouldIgnore(Neo4jSession session, java.lang.Object obj)`
	`protected java.lang.Object`	`unmarshall(PersistentEntity persistentEntity, java.io.Serializable id, Entity node, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, java.util.Map<java.lang.String, java.lang.Object> resultData)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations, javax.persistence.LockModeType lockModeType)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity entity, org.neo4j.driver.types.Relationship data, java.util.Map<Association, java.lang.Object> initializedAssociations, java.util.Map<java.io.Serializable, org.neo4j.driver.types.Node> initializedNodes)`
	`public java.lang.Object`	`unmarshallOrFromCache(PersistentEntity entity, Entity data, java.util.Map<Association, java.lang.Object> initializedAssociations)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class EntityPersister`	cancelDelete, cancelInsert, cancelLoad, cancelUpdate, createEntityAccess, delete, delete, deleteEntities, deleteEntity, firePostDeleteEvent, firePostInsertEvent, firePostLoadEvent, firePostUpdateEvent, firePreLoadEvent, getCurrentVersion, getMappingContext, getObjectIdentifier, getPersistentEntity, getProxyFactory, getSession, getType, incrementEntityVersion, incrementVersion, insert, isAssignedId, isVersioned, newEntityInstance, persist, persist, persistEntities, persistEntity, persistEntity, proxy, retrieve, retrieveAll, retrieveAll, retrieveAllEntities, retrieveAllEntities, retrieveEntity, setDateVersion, setDateVersionInternal, setObjectIdentifier, setVersion

- Field Detail
  - public static final java.lang.String DYNAMIC_ASSOCIATION_PARAM
  - private static org.slf4j.Logger log
- Constructor Detail
  - public Neo4jEntityPersister(MappingContext mappingContext, PersistentEntity entity, Session session, org.springframework.context.ApplicationEventPublisher publisher)
- Method Detail
  - private int calcInheritenceChain(PersistentEntity current)
  - public static long countUpdates(org.neo4j.driver.Result execute)
  - private java.util.Collection createCollection(Association association)
  - private java.util.Collection createDirtyCheckableAwareCollection(EntityAccess entityAccess, Association association, java.util.Collection delegate)
  - @java.lang.SuppressWarnings("unchecked") private PendingDeleteAdapter createPendingDeleteOne(Neo4jSession session, PersistentEntity pe, EntityAccess entityAccess, java.lang.Object obj)
  - @java.lang.Override public Query createQuery()
  - @java.lang.Override protected void deleteEntities(PersistentEntity pe, @java.lang.SuppressWarnings("rawtypes") java.lang.Iterable objects)
  - @java.lang.Override protected void deleteEntity(PersistentEntity pe, java.lang.Object obj)
  - private PersistentEntity findDerivedPersistentEntityWithLabel(PersistentEntity parent, java.lang.String label)
  - @java.lang.Override public java.io.Serializable getNativeKey()
  - @java.lang.Override public java.io.Serializable getNativeKey()
  - @java.lang.Override public Neo4jSession getSession()
  - private void handleRelationshipSide(PersistentEntity persistentEntity, java.util.Map<java.lang.String, java.lang.Object> resultData, java.lang.Object entity, java.lang.String associationNodesKey, Neo4jResultList resultSet, Association association)
  - private boolean isInParentsChain(PersistentEntity parent, PersistentEntity it)
  - private PersistentEntity mostSpecificPersistentEntity(PersistentEntity pe, java.lang.Iterable<java.lang.String> labels)
  - private void persistAssociationsOfEntity(GraphPersistentEntity graphEntity, EntityAccess entityAccess, boolean isUpdate)
  - @java.lang.Override protected java.util.List<java.io.Serializable> persistEntities(PersistentEntity pe, @java.lang.SuppressWarnings("rawtypes") java.lang.Iterable objs)
  - @java.lang.Override protected java.io.Serializable persistEntity(PersistentEntity entity, java.lang.Object obj, boolean isInsert)
  - @java.lang.Override protected java.io.Serializable persistEntity(PersistentEntity pe, java.lang.Object obj)
  - private void processDynamicAssociationRemoval(GraphPersistentEntity graphEntity, EntityAccess entityAccess, Neo4jSession neo4jSession, MappingContext mappingContext, java.lang.String associationName, java.lang.Object originalValue)
  - public void processDynamicAssociations(GraphPersistentEntity graphEntity, EntityAccess access, Neo4jMappingContext mappingContext, java.util.Map<java.lang.String, java.util.List<java.lang.Object>> dynamicRelProps, java.util.List<PendingOperation<java.lang.Object, java.io.Serializable>> cascadingOperations, boolean isUpdate)
  - @java.lang.Override public java.io.Serializable refresh(java.lang.Object o)
  - private void registerPendingUpdate(Neo4jSession session, PersistentEntity pe, EntityAccess ea, java.lang.Object obj, java.io.Serializable identifier)
  - @java.lang.Override protected java.util.List<java.lang.Object> retrieveAllEntities(PersistentEntity pe, java.io.Serializable[] keys)
  - @java.lang.Override protected java.util.List<java.lang.Object> retrieveAllEntities(PersistentEntity pe, java.lang.Iterable<java.io.Serializable> keys)
  - @java.lang.Override protected java.lang.Object retrieveEntity(PersistentEntity pe, java.io.Serializable key)
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - @java.lang.Override public void run()
  - private boolean shouldIgnore(Neo4jSession session, java.lang.Object obj)
  - protected java.lang.Object unmarshall(PersistentEntity persistentEntity, java.io.Serializable id, Entity node, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, java.util.Map<java.lang.String, java.lang.Object> resultData)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations, javax.persistence.LockModeType lockModeType)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity entity, org.neo4j.driver.types.Relationship data, java.util.Map<Association, java.lang.Object> initializedAssociations, java.util.Map<java.io.Serializable, org.neo4j.driver.types.Node> initializedNodes)
  - public java.lang.Object unmarshallOrFromCache(PersistentEntity entity, Entity data, java.util.Map<Association, java.lang.Object> initializedAssociations)

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

Groovy Documentation

[Java] Class Neo4jEntityPersister

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

public static final java.lang.String DYNAMIC_ASSOCIATION_PARAM

private static org.slf4j.Logger log

Constructor Detail

public Neo4jEntityPersister(MappingContext mappingContext, PersistentEntity entity, Session session, org.springframework.context.ApplicationEventPublisher publisher)

Method Detail

private int calcInheritenceChain(PersistentEntity current)

public static long countUpdates(org.neo4j.driver.Result execute)

private java.util.Collection createCollection(Association association)

private java.util.Collection createDirtyCheckableAwareCollection(EntityAccess entityAccess, Association association, java.util.Collection delegate)

@java.lang.SuppressWarnings("unchecked") private PendingDeleteAdapter createPendingDeleteOne(Neo4jSession session, PersistentEntity pe, EntityAccess entityAccess, java.lang.Object obj)

@java.lang.Override public Query createQuery()

@java.lang.Override protected void deleteEntities(PersistentEntity pe, @java.lang.SuppressWarnings("rawtypes") java.lang.Iterable objects)

@java.lang.Override protected void deleteEntity(PersistentEntity pe, java.lang.Object obj)

private PersistentEntity findDerivedPersistentEntityWithLabel(PersistentEntity parent, java.lang.String label)

@java.lang.Override public java.io.Serializable getNativeKey()

@java.lang.Override public java.io.Serializable getNativeKey()

@java.lang.Override public Neo4jSession getSession()

private void handleRelationshipSide(PersistentEntity persistentEntity, java.util.Map<java.lang.String, java.lang.Object> resultData, java.lang.Object entity, java.lang.String associationNodesKey, Neo4jResultList resultSet, Association association)

private boolean isInParentsChain(PersistentEntity parent, PersistentEntity it)

private PersistentEntity mostSpecificPersistentEntity(PersistentEntity pe, java.lang.Iterable<java.lang.String> labels)

private void persistAssociationsOfEntity(GraphPersistentEntity graphEntity, EntityAccess entityAccess, boolean isUpdate)

@java.lang.Override protected java.util.List<java.io.Serializable> persistEntities(PersistentEntity pe, @java.lang.SuppressWarnings("rawtypes") java.lang.Iterable objs)

@java.lang.Override protected java.io.Serializable persistEntity(PersistentEntity entity, java.lang.Object obj, boolean isInsert)

@java.lang.Override protected java.io.Serializable persistEntity(PersistentEntity pe, java.lang.Object obj)

private void processDynamicAssociationRemoval(GraphPersistentEntity graphEntity, EntityAccess entityAccess, Neo4jSession neo4jSession, MappingContext mappingContext, java.lang.String associationName, java.lang.Object originalValue)

@java.lang.Override public java.io.Serializable refresh(java.lang.Object o)

private void registerPendingUpdate(Neo4jSession session, PersistentEntity pe, EntityAccess ea, java.lang.Object obj, java.io.Serializable identifier)

@java.lang.Override protected java.util.List<java.lang.Object> retrieveAllEntities(PersistentEntity pe, java.io.Serializable[] keys)

@java.lang.Override protected java.util.List<java.lang.Object> retrieveAllEntities(PersistentEntity pe, java.lang.Iterable<java.io.Serializable> keys)

@java.lang.Override protected java.lang.Object retrieveEntity(PersistentEntity pe, java.io.Serializable key)

@java.lang.Override public void run()

@java.lang.Override public void run()

@java.lang.Override public void run()

@java.lang.Override public void run()

@java.lang.Override public void run()

@java.lang.Override public void run()

@java.lang.Override public void run()

@java.lang.Override public void run()

private boolean shouldIgnore(Neo4jSession session, java.lang.Object obj)

protected java.lang.Object unmarshall(PersistentEntity persistentEntity, java.io.Serializable id, Entity node, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations)

public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, java.util.Map<java.lang.String, java.lang.Object> resultData)

public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data)

public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData)

public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations)

public java.lang.Object unmarshallOrFromCache(PersistentEntity defaultPersistentEntity, org.neo4j.driver.types.Node data, java.util.Map<java.lang.String, java.lang.Object> resultData, java.util.Map<Association, java.lang.Object> initializedAssociations, javax.persistence.LockModeType lockModeType)

public java.lang.Object unmarshallOrFromCache(PersistentEntity entity, org.neo4j.driver.types.Relationship data, java.util.Map<Association, java.lang.Object> initializedAssociations, java.util.Map<java.io.Serializable, org.neo4j.driver.types.Node> initializedNodes)

public java.lang.Object unmarshallOrFromCache(PersistentEntity entity, Entity data, java.util.Map<Association, java.lang.Object> initializedAssociations)