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

Class Neo4jTaskDAO

java.lang.Object

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

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

All Implemented Interfaces:

DAO<Task<?>>, TaskDAO

public class Neo4jTaskDAO
extends AbstractDAO
implements TaskDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected static final Logger	LOG
protected final NodeValidator	nodeValidator
protected final RealmSearchDAO	realmSearchDAO
protected final RemediationDAO	remediationDAO
protected final SecurityProperties	securityProperties
protected final TaskUtilsFactory	taskUtilsFactory

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

neo4jClient, neo4jTemplate

Fields inherited from interface org.apache.syncope.core.persistence.api.dao.DAO

DEFAULT_SORT

Constructor Summary

Constructors

Constructor	Description
Neo4jTaskDAO(RealmSearchDAO realmSearchDAO, RemediationDAO remediationDAO, TaskUtilsFactory taskUtilsFactory, SecurityProperties securityProperties, org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate, org.springframework.data.neo4j.core.Neo4jClient neo4jClient, NodeValidator nodeValidator)

Method Summary

Modifier and Type	Method	Description
long	count()
long	count(TaskType type, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey)
void	delete(TaskType type, String key)
void	delete(Task<?> task)
void	deleteAll(ExternalResource resource, TaskType type)
void	deleteById(String key)
static String	execRelationship(TaskType type)
boolean	existsById(String key)
List<? extends Task<?>>	findAll()
<T extends Task<T>> List<T>	findAll(TaskType type)
<T extends Task<T>> List<T>	findAll(TaskType type, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey, org.springframework.data.domain.Pageable pageable)
List<MacroTask>	findByCommand(Implementation command)
List<SchedTask>	findByDelegate(Implementation delegate)
Optional<? extends Task<?>>	findById(String key)
<T extends Task<T>> Optional<T>	findById(TaskType type, String key)
List<PullTask>	findByInboundActions(Implementation inboundActions)
<T extends SchedTask> Optional<T>	findByName(TaskType type, String name)
List<PushTask>	findByPushActions(Implementation pushActions)
List<MacroTask>	findByRealm(Realm realm)
List<PullTask>	findByReconFilterBuilder(Implementation reconFilterBuilder)
<T extends Task<T>> List<T>	findToExec(TaskType type)
List<PropagationTaskTO>	purgePropagations(OffsetDateTime since, List<ExecStatus> statuses, List<String> resources)
protected StringBuilder	query(TaskType type, TaskUtils taskUtils, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey, Map<String,Object> parameters)
<T extends Task<?>> T	save(T task)
protected String	toOrderByStatement(Class<? extends Task<?>> beanClass, Stream<org.springframework.data.domain.Sort.Order> orderByClauses)

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

Field Details

LOG

protected static final Logger LOG

realmSearchDAO

protected final RealmSearchDAO realmSearchDAO

remediationDAO

protected final RemediationDAO remediationDAO

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

securityProperties

protected final SecurityProperties securityProperties

nodeValidator

protected final NodeValidator nodeValidator

Constructor Details

Neo4jTaskDAO

public Neo4jTaskDAO(RealmSearchDAO realmSearchDAO,
 RemediationDAO remediationDAO,
 TaskUtilsFactory taskUtilsFactory,
 SecurityProperties securityProperties,
 org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate,
 org.springframework.data.neo4j.core.Neo4jClient neo4jClient,
 NodeValidator nodeValidator)

Method Details

execRelationship

public static String execRelationship(TaskType type)

existsById

public boolean existsById(String key)

Specified by:

existsById in interface DAO<Task<?>>

findById

@Transactional(readOnly=true)
public <T extends Task<T>> Optional<T> findById(TaskType type,
 String key)

Specified by:

findById in interface TaskDAO

findByName

@Transactional(readOnly=true)
public <T extends SchedTask> Optional<T> findByName(TaskType type,
 String name)

Specified by:

findByName in interface TaskDAO

findById

public Optional<? extends Task<?>> findById(String key)

Specified by:

findById in interface DAO<Task<?>>

findByDelegate

public List<SchedTask> findByDelegate(Implementation delegate)

Specified by:

findByDelegate in interface TaskDAO

findByReconFilterBuilder

public List<PullTask> findByReconFilterBuilder(Implementation reconFilterBuilder)

Specified by:

findByReconFilterBuilder in interface TaskDAO

findByInboundActions

public List<PullTask> findByInboundActions(Implementation inboundActions)

Specified by:

findByInboundActions in interface TaskDAO

findByPushActions

public List<PushTask> findByPushActions(Implementation pushActions)

Specified by:

findByPushActions in interface TaskDAO

findByRealm

public List<MacroTask> findByRealm(Realm realm)

Specified by:

findByRealm in interface TaskDAO

findByCommand

public List<MacroTask> findByCommand(Implementation command)

Specified by:

findByCommand in interface TaskDAO

findToExec

public <T extends Task<T>> List<T> findToExec(TaskType type)

Specified by:

findToExec in interface TaskDAO

findAll

public List<? extends Task<?>> findAll()

Specified by:

findAll in interface DAO<Task<?>>

findAll

@Transactional(readOnly=true)
public <T extends Task<T>> List<T> findAll(TaskType type)

Specified by:

findAll in interface TaskDAO

query

protected StringBuilder query(TaskType type,
 TaskUtils taskUtils,
 ExternalResource resource,
 Notification notification,
 AnyTypeKind anyTypeKind,
 String entityKey,
 Map<String,Object> parameters)

count

public long count()

Specified by:

count in interface DAO<Task<?>>

count

public long count(TaskType type,
 ExternalResource resource,
 Notification notification,
 AnyTypeKind anyTypeKind,
 String entityKey)

Specified by:

count in interface TaskDAO

toOrderByStatement

protected String toOrderByStatement(Class<? extends Task<?>> beanClass,
 Stream<org.springframework.data.domain.Sort.Order> orderByClauses)

findAll

public <T extends Task<T>> List<T> findAll(TaskType type,
 ExternalResource resource,
 Notification notification,
 AnyTypeKind anyTypeKind,
 String entityKey,
 org.springframework.data.domain.Pageable pageable)

Specified by:

findAll in interface TaskDAO

save

@Transactional(rollbackFor=java.lang.Throwable.class)
public <T extends Task<?>> T save(T task)

Specified by:

save in interface DAO<Task<?>>

delete

public void delete(TaskType type,
 String key)

Specified by:

delete in interface TaskDAO

deleteById

public void deleteById(String key)

Specified by:

deleteById in interface DAO<Task<?>>

delete

public void delete(Task<?> task)

Specified by:

delete in interface DAO<Task<?>>

deleteAll

public void deleteAll(ExternalResource resource,
 TaskType type)

Specified by:

deleteAll in interface TaskDAO

purgePropagations

public List<PropagationTaskTO> purgePropagations(OffsetDateTime since,
 List<ExecStatus> statuses,
 List<String> resources)

Specified by:

purgePropagations in interface TaskDAO