Package org.apache.syncope.core.persistence.neo4j.dao.repo

Class AnyObjectRepoExtImpl

java.lang.Object

org.apache.syncope.core.persistence.neo4j.dao.AbstractDAO

org.apache.syncope.core.persistence.neo4j.dao.repo.AbstractAnyRepoExt<AnyObject,Neo4jAnyObject>

org.apache.syncope.core.persistence.neo4j.dao.repo.AnyObjectRepoExtImpl

All Implemented Interfaces:

AnyObjectRepoExt, AnyRepoExt<AnyObject>

public class AnyObjectRepoExtImpl
extends AbstractAnyRepoExt<AnyObject,Neo4jAnyObject>
implements AnyObjectRepoExt

Field Summary

Fields

Modifier and Type	Field	Description
protected final javax.cache.Cache<EntityCacheKey,Neo4jAnyObject>	anyObjectCache
protected final GroupDAO	groupDAO
protected final NodeValidator	nodeValidator
protected final UserDAO	userDAO

Fields inherited from class org.apache.syncope.core.persistence.neo4j.dao.repo.AbstractAnyRepoExt

anyTypeClassDAO, anyTypeDAO, anyUtils, derSchemaDAO, dynRealmDAO, plainSchemaDAO

Fields inherited from class org.apache.syncope.core.persistence.neo4j.dao.AbstractDAO

LOG, neo4jClient, neo4jTemplate

Fields inherited from interface org.apache.syncope.core.persistence.neo4j.dao.repo.AnyObjectRepoExt

CACHE

Fields inherited from interface org.apache.syncope.core.persistence.neo4j.dao.repo.AnyRepoExt

REGEX_CHARS

Constructor Summary

Constructors

Constructor

Description

AnyObjectRepoExtImpl(AnyUtilsFactory anyUtilsFactory, AnyTypeDAO anyTypeDAO, AnyTypeClassDAO anyTypeClassDAO, PlainSchemaDAO plainSchemaDAO, DerSchemaDAO derSchemaDAO, DynRealmDAO dynRealmDAO, UserDAO userDAO, GroupDAO groupDAO, org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate, org.springframework.data.neo4j.core.Neo4jClient neo4jClient, NodeValidator nodeValidator, javax.cache.Cache<EntityCacheKey,Neo4jAnyObject> anyObjectCache)

Method Summary

Modifier and Type	Method	Description
protected javax.cache.Cache<EntityCacheKey,Neo4jAnyObject>	cache()
Map<String,Long>	countByRealm(AnyType anyType)
Map<AnyType,Long>	countByType()
void	delete(AnyObject anyObject)
void	deleteMembership(AMembership membership)
protected <S extends AnyObject> Pair<S,GroupDAO.DynMembershipInfo>	doSave(S anyObject)
Collection<String>	findAllGroupKeys(AnyObject anyObject)
Collection<Group>	findAllGroups(AnyObject anyObject)
List<Relationship<Any,AnyObject>>	findAllRelationships(AnyObject anyObject)
Collection<String>	findAllResourceKeys(String key)
Collection<ExternalResource>	findAllResources(AnyObject anyObject)
protected List<ARelationship>	findARelationships(AnyObject anyObject)
List<AnyObject>	findByName(String name)
Optional<? extends AnyObject>	findByName(String type, String name)
List<Group>	findDynGroups(String key)
Optional<OffsetDateTime>	findLastChange(String key)
AMembership	findMembership(String key)
protected List<URelationship>	findURelationships(AnyObject anyObject)
<S extends AnyObject> S	save(S anyObject)
GroupDAO.DynMembershipInfo	saveAndGetDynGroupMembs(AnyObject anyObject)
void	securityChecks(Set<String> authRealms, String key, String realm, Collection<String> groups)
protected void	securityChecks(AnyObject anyObject)

Methods inherited from class org.apache.syncope.core.persistence.neo4j.dao.repo.AbstractAnyRepoExt

authFind, checkBeforeSave, deleteById, findAllowedSchemas, findById, findByKeys, findByResourcesContaining, findDynRealms, findLastChange, split

Methods inherited from class org.apache.syncope.core.persistence.neo4j.dao.AbstractDAO

cascadeDelete, deleteRelationship, findById, findByRelationship, findByRelationship, toList, toOptional

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.syncope.core.persistence.neo4j.dao.repo.AnyRepoExt

authFind, deleteById, findAllowedSchemas, findByKeys, findByResourcesContaining, findDynRealms

Field Details

userDAO

protected final UserDAO userDAO

groupDAO

protected final GroupDAO groupDAO

nodeValidator

protected final NodeValidator nodeValidator

anyObjectCache

protected final javax.cache.Cache<EntityCacheKey,Neo4jAnyObject> anyObjectCache

Constructor Details

AnyObjectRepoExtImpl

public AnyObjectRepoExtImpl(AnyUtilsFactory anyUtilsFactory,
 AnyTypeDAO anyTypeDAO,
 AnyTypeClassDAO anyTypeClassDAO,
 PlainSchemaDAO plainSchemaDAO,
 DerSchemaDAO derSchemaDAO,
 DynRealmDAO dynRealmDAO,
 UserDAO userDAO,
 GroupDAO groupDAO,
 org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate,
 org.springframework.data.neo4j.core.Neo4jClient neo4jClient,
 NodeValidator nodeValidator,
 javax.cache.Cache<EntityCacheKey,Neo4jAnyObject> anyObjectCache)

Method Details

cache

protected javax.cache.Cache<EntityCacheKey,Neo4jAnyObject> cache()

Specified by:

cache in class AbstractAnyRepoExt<AnyObject,Neo4jAnyObject>

findByName

public Optional<? extends AnyObject> findByName(String type,
 String name)

Specified by:

findByName in interface AnyObjectRepoExt

findByName

public List<AnyObject> findByName(String name)

Specified by:

findByName in interface AnyObjectRepoExt

findLastChange

@Transactional(readOnly=true)
public Optional<OffsetDateTime> findLastChange(String key)

Specified by:

findLastChange in interface AnyRepoExt<AnyObject>

securityChecks

@Transactional(readOnly=true)
public void securityChecks(Set<String> authRealms,
 String key,
 String realm,
 Collection<String> groups)

Specified by:

securityChecks in interface AnyObjectRepoExt

securityChecks

protected void securityChecks(AnyObject anyObject)

Specified by:

securityChecks in class AbstractAnyRepoExt<AnyObject,Neo4jAnyObject>

countByType

public Map<AnyType,Long> countByType()

Specified by:

countByType in interface AnyObjectRepoExt

countByRealm

public Map<String,Long> countByRealm(AnyType anyType)

Specified by:

countByRealm in interface AnyObjectRepoExt

findMembership

public AMembership findMembership(String key)

Specified by:

findMembership in interface AnyObjectRepoExt

deleteMembership

public void deleteMembership(AMembership membership)

Specified by:

deleteMembership in interface AnyObjectRepoExt

findAllRelationships

public List<Relationship<Any,AnyObject>> findAllRelationships(AnyObject anyObject)

Specified by:

findAllRelationships in interface AnyObjectRepoExt

doSave

protected <S extends AnyObject>
Pair<S,GroupDAO.DynMembershipInfo> doSave(S anyObject)

save

public <S extends AnyObject> S save(S anyObject)

Specified by:

save in interface AnyObjectRepoExt

Specified by:

save in interface AnyRepoExt<AnyObject>

saveAndGetDynGroupMembs

public GroupDAO.DynMembershipInfo saveAndGetDynGroupMembs(AnyObject anyObject)

Specified by:

saveAndGetDynGroupMembs in interface AnyObjectRepoExt

findARelationships

protected List<ARelationship> findARelationships(AnyObject anyObject)

findURelationships

protected List<URelationship> findURelationships(AnyObject anyObject)

findDynGroups

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public List<Group> findDynGroups(String key)

Specified by:

findDynGroups in interface AnyObjectRepoExt

findAllGroups

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<Group> findAllGroups(AnyObject anyObject)

Specified by:

findAllGroups in interface AnyObjectRepoExt

findAllGroupKeys

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<String> findAllGroupKeys(AnyObject anyObject)

Specified by:

findAllGroupKeys in interface AnyObjectRepoExt

findAllResources

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<ExternalResource> findAllResources(AnyObject anyObject)

Specified by:

findAllResources in interface AnyObjectRepoExt

findAllResourceKeys

@Transactional(readOnly=true)
public Collection<String> findAllResourceKeys(String key)

Specified by:

findAllResourceKeys in interface AnyRepoExt<AnyObject>

delete

public void delete(AnyObject anyObject)

Specified by:

delete in interface AnyObjectRepoExt

Specified by:

delete in interface AnyRepoExt<AnyObject>