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

Class JPATaskDAO

java.lang.Object

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

All Implemented Interfaces:

DAO<Task<?>>, TaskDAO

public class JPATaskDAO
extends Object
implements TaskDAO

Field Summary

Fields

Modifier and Type	Field	Description
protected final EntityManager	entityManager
protected static final org.slf4j.Logger	LOG
protected final RealmSearchDAO	realmSearchDAO
protected final RemediationDAO	remediationDAO
protected final SecurityProperties	securityProperties
protected final TaskUtilsFactory	taskUtilsFactory

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

DEFAULT_SORT

Constructor Summary

Constructors

Constructor	Description
JPATaskDAO(RealmSearchDAO realmSearchDAO, RemediationDAO remediationDAO, TaskUtilsFactory taskUtilsFactory, SecurityProperties securityProperties, EntityManager entityManager)

Method Summary

Modifier and Type	Method	Description
protected final <T extends Task<T>> StringBuilder	buildFindAllQuery(TaskType type)
protected StringBuilder	buildFindAllQuery(TaskType type, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey, boolean orderByTaskExecInfo, List<Object> parameters)
long	count()
long	count(TaskType type, ExternalResource resource, Notification notification, AnyTypeKind anyTypeKind, String entityKey)
long	countToExec(TaskType type)
void	delete(TaskType type, String key)
void	delete(Task<?> task)
void	deleteAll(ExternalResource resource, TaskType type)
void	deleteById(String key)
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, org.springframework.data.domain.Pageable pageable)
List<PropagationTaskTO>	purgePropagations(OffsetDateTime since, List<ExecStatus> statuses, List<String> resources)
<T extends Task<?>> T	save(T task)
protected int	setParameter(List<Object> parameters, Object parameter)
protected String	toOrderByStatement(Class<? extends Task<?>> beanClass, Stream<org.springframework.data.domain.Sort.Order> orderByClauses, String prefix)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

realmSearchDAO

protected final RealmSearchDAO realmSearchDAO

remediationDAO

protected final RemediationDAO remediationDAO

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

securityProperties

protected final SecurityProperties securityProperties

entityManager

protected final EntityManager entityManager

Constructor Details

JPATaskDAO

public JPATaskDAO(RealmSearchDAO realmSearchDAO,
 RemediationDAO remediationDAO,
 TaskUtilsFactory taskUtilsFactory,
 SecurityProperties securityProperties,
 EntityManager entityManager)

Method Details

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

buildFindAllQuery

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

countToExec

public long countToExec(TaskType type)

Specified by:

countToExec in interface TaskDAO

toOrderByStatement

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

findToExec

public <T extends Task<T>> List<T> findToExec(TaskType type,
 org.springframework.data.domain.Pageable pageable)

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

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)

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

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

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