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

Class JPATaskDAO

java.lang.Object

org.apache.syncope.core.persistence.jpa.dao.AbstractDAO<Task<?>>

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

All Implemented Interfaces:

DAO<Task<?>>, TaskDAO

public class JPATaskDAO
extends AbstractDAO<Task<?>>
implements TaskDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected RealmDAO	realmDAO
protected RemediationDAO	remediationDAO
protected SecurityProperties	securityProperties
protected TaskUtilsFactory	taskUtilsFactory

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

LOG

Constructor Summary

Constructors

Constructor	Description
JPATaskDAO(RealmDAO realmDAO, RemediationDAO remediationDAO, TaskUtilsFactory taskUtilsFactory, SecurityProperties securityProperties)

Method Summary

Modifier and Type	Method	Description
protected StringBuilder	buildFindAllQuery(TaskType type, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey, boolean orderByTaskExecInfo, List<Object> parameters)
protected <T extends Task<T>> StringBuilder	buildFindAllQueryJPA(TaskType type)
int	count(TaskType type, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey)
void	delete(TaskType type, String id)
void	delete(Task<?> task)
void	deleteAll(ExternalResource resource, TaskType type)
boolean	exists(TaskType type, String key)
Optional<Task<?>>	find(String key)
<T extends Task<T>> T	find(TaskType type, String key)
<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, int page, int itemsPerPage, List<OrderByClause> orderByClauses)
List<MacroTask>	findByCommand(Implementation command)
List<SchedTask>	findByDelegate(Implementation delegate)
<T extends SchedTask> Optional<T>	findByName(TaskType type, String name)
List<PullTask>	findByPullActions(Implementation pullActions)
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<ExternalResource> externalResources)
<T extends Task<T>> T	save(T task)
protected int	setParameter(List<Object> parameters, Object parameter)
protected String	toOrderByStatement(Class<? extends Task<?>> beanClass, List<OrderByClause> orderByClauses)

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

detach, entityManager, entityManagerFactory, isOracle, refresh

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.api.dao.DAO

detach, refresh

Field Detail

realmDAO

protected final RealmDAO realmDAO

remediationDAO

protected final RemediationDAO remediationDAO

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

securityProperties

protected final SecurityProperties securityProperties

Constructor Detail

JPATaskDAO

public JPATaskDAO(RealmDAO realmDAO,
                  RemediationDAO remediationDAO,
                  TaskUtilsFactory taskUtilsFactory,
                  SecurityProperties securityProperties)

Method Detail

exists

@Transactional(readOnly=true)
public boolean exists(TaskType type,
                      String key)

Specified by:

exists in interface TaskDAO

find

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

Specified by:

find in interface TaskDAO

findByName

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

Specified by:

findByName in interface TaskDAO

find

public Optional<Task<?>> find(String key)

Specified by:

find in interface TaskDAO

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

findByPullActions

public List<PullTask> findByPullActions(Implementation pullActions)

Specified by:

findByPullActions 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

buildFindAllQueryJPA

protected final <T extends Task<T>> StringBuilder buildFindAllQueryJPA(TaskType type)

findToExec

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

Specified by:

findToExec in interface TaskDAO

findAll

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

Specified by:

findAll in interface TaskDAO

setParameter

protected int setParameter(List<Object> parameters,
                           Object parameter)

buildFindAllQuery

protected StringBuilder buildFindAllQuery(TaskType type,
                                          ExternalResource resource,
                                          Notification notification,
                                          AnyTypeKind anyTypeKind,
                                          String entityKey,
                                          boolean orderByTaskExecInfo,
                                          List<Object> parameters)

toOrderByStatement

protected String toOrderByStatement(Class<? extends Task<?>> beanClass,
                                    List<OrderByClause> orderByClauses)

findAll

public <T extends Task<T>> List<T> findAll(TaskType type,
                                           ExternalResource resource,
                                           Notification notification,
                                           AnyTypeKind anyTypeKind,
                                           String entityKey,
                                           int page,
                                           int itemsPerPage,
                                           List<OrderByClause> orderByClauses)

Specified by:

findAll in interface TaskDAO

count

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

Specified by:

count in interface TaskDAO

save

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

Specified by:

save in interface TaskDAO

delete

public void delete(TaskType type,
                   String id)

Specified by:

delete in interface TaskDAO

delete

public void delete(Task<?> task)

Specified by:

delete in interface TaskDAO

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<ExternalResource> externalResources)

Specified by:

purgePropagations in interface TaskDAO