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

Class Neo4jTaskExecDAO

java.lang.Object

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

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

All Implemented Interfaces:

DAO<TaskExec<?>>, TaskExecDAO

public class Neo4jTaskExecDAO
extends AbstractDAO
implements TaskExecDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected final NodeValidator	nodeValidator
protected final TaskDAO	taskDAO
protected final TaskUtilsFactory	taskUtilsFactory

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

LOG, neo4jClient, neo4jTemplate

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

DEFAULT_SORT

Constructor Summary

Constructors

Constructor	Description
Neo4jTaskExecDAO(TaskDAO taskDAO, TaskUtilsFactory taskUtilsFactory, 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(Task<?> task, OffsetDateTime before, OffsetDateTime after)
<T extends Task<T>> void	delete(TaskType taskType, String key)
void	delete(TaskExec<?> execution)
void	deleteById(String key)
boolean	existsById(String key)
List<? extends TaskExec<?>>	findAll()
List<TaskExec<?>>	findAll(Task<?> task, OffsetDateTime before, OffsetDateTime after, org.springframework.data.domain.Pageable pageable)
Optional<? extends TaskExec<?>>	findById(String key)
<T extends Task<T>> Optional<TaskExec<T>>	findById(TaskType type, String key)
protected Optional<? extends TaskExec<?>>	findLatest(TaskType type, Task<?> task, String field)
Optional<? extends TaskExec<?>>	findLatestEnded(TaskType type, Task<?> task)
Optional<? extends TaskExec<?>>	findLatestStarted(TaskType type, Task<?> task)
List<TaskExec<?>>	findRecent(int max)
protected <T extends Task<T>> List<TaskExec<T>>	findRecent(TaskType type, int max)
protected StringBuilder	query(Task<?> task, OffsetDateTime before, OffsetDateTime after, Map<String,Object> parameters)
<S extends TaskExec<?>> S	save(S execution)
<T extends Task<T>> void	saveAndAdd(TaskType taskType, String taskKey, TaskExec<T> execution)
protected String	toOrderByStatement(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

taskDAO

protected final TaskDAO taskDAO

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

nodeValidator

protected final NodeValidator nodeValidator

Constructor Details

Neo4jTaskExecDAO

public Neo4jTaskExecDAO(TaskDAO taskDAO,
 TaskUtilsFactory taskUtilsFactory,
 org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate,
 org.springframework.data.neo4j.core.Neo4jClient neo4jClient,
 NodeValidator nodeValidator)

Method Details

existsById

public boolean existsById(String key)

Specified by:

existsById in interface DAO<TaskExec<?>>

findById

public <T extends Task<T>> Optional<TaskExec<T>> findById(TaskType type,
 String key)

Specified by:

findById in interface TaskExecDAO

findById

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

Specified by:

findById in interface DAO<TaskExec<?>>

findRecent

protected <T extends Task<T>> List<TaskExec<T>> findRecent(TaskType type,
 int max)

findRecent

public List<TaskExec<?>> findRecent(int max)

Specified by:

findRecent in interface TaskExecDAO

findLatest

protected Optional<? extends TaskExec<?>> findLatest(TaskType type,
 Task<?> task,
 String field)

findLatestStarted

public Optional<? extends TaskExec<?>> findLatestStarted(TaskType type,
 Task<?> task)

Specified by:

findLatestStarted in interface TaskExecDAO

findLatestEnded

public Optional<? extends TaskExec<?>> findLatestEnded(TaskType type,
 Task<?> task)

Specified by:

findLatestEnded in interface TaskExecDAO

count

public long count()

Specified by:

count in interface DAO<TaskExec<?>>

query

protected StringBuilder query(Task<?> task,
 OffsetDateTime before,
 OffsetDateTime after,
 Map<String,Object> parameters)

count

public long count(Task<?> task,
 OffsetDateTime before,
 OffsetDateTime after)

Specified by:

count in interface TaskExecDAO

toOrderByStatement

protected String toOrderByStatement(Stream<org.springframework.data.domain.Sort.Order> orderByClauses)

findAll

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

Specified by:

findAll in interface DAO<TaskExec<?>>

findAll

public List<TaskExec<?>> findAll(Task<?> task,
 OffsetDateTime before,
 OffsetDateTime after,
 org.springframework.data.domain.Pageable pageable)

Specified by:

findAll in interface TaskExecDAO

save

@Transactional(rollbackFor=java.lang.Throwable.class)
public <S extends TaskExec<?>> S save(S execution)

Specified by:

save in interface DAO<TaskExec<?>>

saveAndAdd

@Transactional(rollbackFor=java.lang.Throwable.class)
public <T extends Task<T>> void saveAndAdd(TaskType taskType,
 String taskKey,
 TaskExec<T> execution)

Specified by:

saveAndAdd in interface TaskExecDAO

delete

public <T extends Task<T>> void delete(TaskType taskType,
 String key)

Specified by:

delete in interface TaskExecDAO

delete

public void delete(TaskExec<?> execution)

Specified by:

delete in interface DAO<TaskExec<?>>

deleteById

public void deleteById(String key)

Specified by:

deleteById in interface DAO<TaskExec<?>>