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

Class JPATaskExecDAO

java.lang.Object

org.apache.syncope.core.persistence.jpa.dao.JPATaskExecDAO

All Implemented Interfaces:

DAO<TaskExec<?>>, TaskExecDAO

public class JPATaskExecDAO
extends Object
implements TaskExecDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected final EntityManager	entityManager
protected final TaskDAO	taskDAO
protected final TaskUtilsFactory	taskUtilsFactory

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

DEFAULT_SORT

Constructor Summary

Constructors

Constructor	Description
JPATaskExecDAO(TaskDAO taskDAO, TaskUtilsFactory taskUtilsFactory, EntityManager entityManager)

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(StringBuilder select, Task<?> task, OffsetDateTime before, OffsetDateTime after)
<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 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

entityManager

protected final EntityManager entityManager

Constructor Details

JPATaskExecDAO

public JPATaskExecDAO(TaskDAO taskDAO,
 TaskUtilsFactory taskUtilsFactory,
 EntityManager entityManager)

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(StringBuilder select,
 Task<?> task,
 OffsetDateTime before,
 OffsetDateTime after)

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<?>>