org.flowable.eventsubscription.service.impl.persistence.entity.data.impl

Class MybatisEventSubscriptionDataManager

java.lang.Object

org.flowable.common.engine.impl.db.AbstractDataManager<EntityImpl>

org.flowable.eventsubscription.service.impl.persistence.entity.data.AbstractEventSubscriptionDataManager<EventSubscriptionEntity>

org.flowable.eventsubscription.service.impl.persistence.entity.data.impl.MybatisEventSubscriptionDataManager

All Implemented Interfaces:

DataManager<EventSubscriptionEntity>, EventSubscriptionDataManager

public class MybatisEventSubscriptionDataManager
extends AbstractEventSubscriptionDataManager<EventSubscriptionEntity>
implements EventSubscriptionDataManager

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field and Description
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByExecutionAndTypeMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByExecutionIdMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByNameMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByProcessInstanceAndTypeMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByProcInstTypeAndActivityMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByScopeDefinitionIdAndTypeAndNullScopeIdMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByScopeDefinitionIdAndTypeMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsByScopeIdAndTypeMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	eventSubscriptionsBySubScopeIdMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	messageEventSubscriptionsByProcInstAndEventNameMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	signalEventSubscriptionByEventNameMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	signalEventSubscriptionByNameAndExecutionMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	signalEventSubscriptionByProcInstAndEventNameMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	signalEventSubscriptionByScopeAndEventNameMatcher
protected CachedEntityMatcher<EventSubscriptionEntity>	signalEventSubscriptionByScopeIdAndTypeMatcher

Fields inherited from class org.flowable.eventsubscription.service.impl.persistence.entity.data.AbstractEventSubscriptionDataManager

eventSubscriptionServiceConfiguration

Fields inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

MAX_ENTRIES_IN_CLAUSE

Constructor Summary

Constructors

Constructor and Description
MybatisEventSubscriptionDataManager(EventSubscriptionServiceConfiguration eventSubscriptionServiceConfiguration)

Method Summary

Modifier and Type	Method and Description
void	clearEventSubscriptionLockTime(String eventSubscriptionId)
EventSubscriptionEntity	create()
CompensateEventSubscriptionEntity	createCompensateEventSubscription()
GenericEventSubscriptionEntity	createGenericEventSubscriptionEntity()
MessageEventSubscriptionEntity	createMessageEventSubscription()
SignalEventSubscriptionEntity	createSignalEventSubscription()
void	deleteEventSubscriptionsByExecutionId(String executionId)
void	deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)
void	deleteEventSubscriptionsForScopeDefinitionIdAndType(String scopeDefinitionId, String scopeType)
void	deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId(String scopeDefinitionId, String scopeType)
void	deleteEventSubscriptionsForScopeIdAndType(String scopeId, String scopeType)
long	findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
List<EventSubscriptionEntity>	findEventSubscriptionsByExecution(String executionId)
List<EventSubscriptionEntity>	findEventSubscriptionsByExecutionAndType(String executionId, String type)
List<EventSubscriptionEntity>	findEventSubscriptionsByName(String type, String eventName, String tenantId)
List<EventSubscriptionEntity>	findEventSubscriptionsByNameAndExecution(String type, String eventName, String executionId)
List<EventSubscriptionEntity>	findEventSubscriptionsByProcessInstanceAndActivityId(String processInstanceId, String activityId, String type)
List<EventSubscriptionEntity>	findEventSubscriptionsByProcessInstanceAndType(String processInstanceId, String type)
List<EventSubscription>	findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
List<EventSubscriptionEntity>	findEventSubscriptionsByScopeIdAndType(String scopeId, String type)
List<EventSubscriptionEntity>	findEventSubscriptionsBySubScopeId(String subScopeId)
List<EventSubscriptionEntity>	findEventSubscriptionsByTypeAndProcessDefinitionId(String type, String processDefinitionId, String tenantId)
List<MessageEventSubscriptionEntity>	findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
MessageEventSubscriptionEntity	findMessageStartEventSubscriptionByName(String messageName, String tenantId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByEventName(String eventName, String tenantId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByNameAndExecution(String name, String executionId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByScopeAndEventName(String scopeId, String scopeType, String eventName)
protected IdGenerator	getIdGenerator()
Class<? extends EventSubscriptionEntity>	getManagedEntityClass()
List<Class<? extends EventSubscriptionEntity>>	getManagedEntitySubClasses()
protected List<MessageEventSubscriptionEntity>	toMessageEventSubscriptionEntityList(List<EventSubscriptionEntity> result)
protected List<SignalEventSubscriptionEntity>	toSignalEventSubscriptionEntityList(List<EventSubscriptionEntity> result)
boolean	updateEventSubscriptionLockTime(String eventSubscriptionId, Date lockDate, String lockOwner, Date currentTime)
void	updateEventSubscriptionTenantId(String oldTenantId, String newTenantId)

Methods inherited from class org.flowable.eventsubscription.service.impl.persistence.entity.data.AbstractEventSubscriptionDataManager

getEventSubscriptionServiceConfiguration, setEventSubscriptionServiceConfiguration

Methods inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

bulkDelete, bulkDeleteEntities, bulkUpdateEntities, createSafeInValuesList, delete, delete, deleteCachedEntities, deleteCachedEntities, executeChangeWithInClause, findById, findByQuery, getCommandContext, getDbSqlSession, getEntity, getEntityCache, getList, getList, getList, getList, getList, getListFromCache, getListFromCache, getSession, insert, isEntityInserted, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.data.DataManager

delete, delete, findById, insert, update

Field Detail

eventSubscriptionsByNameMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByNameMatcher

eventSubscriptionsByExecutionIdMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByExecutionIdMatcher

eventSubscriptionsBySubScopeIdMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsBySubScopeIdMatcher

eventSubscriptionsByProcInstTypeAndActivityMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByProcInstTypeAndActivityMatcher

eventSubscriptionsByExecutionAndTypeMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByExecutionAndTypeMatcher

eventSubscriptionsByProcessInstanceAndTypeMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByProcessInstanceAndTypeMatcher

eventSubscriptionsByScopeDefinitionIdAndTypeMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByScopeDefinitionIdAndTypeMatcher

eventSubscriptionsByScopeDefinitionIdAndTypeAndNullScopeIdMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByScopeDefinitionIdAndTypeAndNullScopeIdMatcher

eventSubscriptionsByScopeIdAndTypeMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> eventSubscriptionsByScopeIdAndTypeMatcher

signalEventSubscriptionByNameAndExecutionMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> signalEventSubscriptionByNameAndExecutionMatcher

signalEventSubscriptionByProcInstAndEventNameMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> signalEventSubscriptionByProcInstAndEventNameMatcher

signalEventSubscriptionByScopeAndEventNameMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> signalEventSubscriptionByScopeAndEventNameMatcher

signalEventSubscriptionByScopeIdAndTypeMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> signalEventSubscriptionByScopeIdAndTypeMatcher

signalEventSubscriptionByEventNameMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> signalEventSubscriptionByEventNameMatcher

messageEventSubscriptionsByProcInstAndEventNameMatcher

protected CachedEntityMatcher<EventSubscriptionEntity> messageEventSubscriptionsByProcInstAndEventNameMatcher

Constructor Detail

MybatisEventSubscriptionDataManager

public MybatisEventSubscriptionDataManager(EventSubscriptionServiceConfiguration eventSubscriptionServiceConfiguration)

Method Detail

getManagedEntityClass

public Class<? extends EventSubscriptionEntity> getManagedEntityClass()

Specified by:

getManagedEntityClass in class AbstractDataManager<EventSubscriptionEntity>

getManagedEntitySubClasses

public List<Class<? extends EventSubscriptionEntity>> getManagedEntitySubClasses()

Overrides:

getManagedEntitySubClasses in class AbstractDataManager<EventSubscriptionEntity>

create

public EventSubscriptionEntity create()

Specified by:

create in interface DataManager<EventSubscriptionEntity>

createCompensateEventSubscription

public CompensateEventSubscriptionEntity createCompensateEventSubscription()

Specified by:

createCompensateEventSubscription in interface EventSubscriptionDataManager

createMessageEventSubscription

public MessageEventSubscriptionEntity createMessageEventSubscription()

Specified by:

createMessageEventSubscription in interface EventSubscriptionDataManager

createSignalEventSubscription

public SignalEventSubscriptionEntity createSignalEventSubscription()

Specified by:

createSignalEventSubscription in interface EventSubscriptionDataManager

createGenericEventSubscriptionEntity

public GenericEventSubscriptionEntity createGenericEventSubscriptionEntity()

Specified by:

createGenericEventSubscriptionEntity in interface EventSubscriptionDataManager

findEventSubscriptionCountByQueryCriteria

public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)

Specified by:

findEventSubscriptionCountByQueryCriteria in interface EventSubscriptionDataManager

findEventSubscriptionsByQueryCriteria

public List<EventSubscription> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)

Specified by:

findEventSubscriptionsByQueryCriteria in interface EventSubscriptionDataManager

findMessageEventSubscriptionsByProcessInstanceAndEventName

public List<MessageEventSubscriptionEntity> findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId,
                                                                                                       String eventName)

Specified by:

findMessageEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionDataManager

findSignalEventSubscriptionsByEventName

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByEventName(String eventName,
                                                                                   String tenantId)

Specified by:

findSignalEventSubscriptionsByEventName in interface EventSubscriptionDataManager

findSignalEventSubscriptionsByProcessInstanceAndEventName

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId,
                                                                                                     String eventName)

Specified by:

findSignalEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionDataManager

findSignalEventSubscriptionsByScopeAndEventName

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByScopeAndEventName(String scopeId,
                                                                                           String scopeType,
                                                                                           String eventName)

Specified by:

findSignalEventSubscriptionsByScopeAndEventName in interface EventSubscriptionDataManager

findSignalEventSubscriptionsByNameAndExecution

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByNameAndExecution(String name,
                                                                                          String executionId)

Specified by:

findSignalEventSubscriptionsByNameAndExecution in interface EventSubscriptionDataManager

findEventSubscriptionsByExecutionAndType

public List<EventSubscriptionEntity> findEventSubscriptionsByExecutionAndType(String executionId,
                                                                              String type)

Specified by:

findEventSubscriptionsByExecutionAndType in interface EventSubscriptionDataManager

findEventSubscriptionsByProcessInstanceAndType

public List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceAndType(String processInstanceId,
                                                                                    String type)

Specified by:

findEventSubscriptionsByProcessInstanceAndType in interface EventSubscriptionDataManager

findEventSubscriptionsByProcessInstanceAndActivityId

public List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceAndActivityId(String processInstanceId,
                                                                                          String activityId,
                                                                                          String type)

Specified by:

findEventSubscriptionsByProcessInstanceAndActivityId in interface EventSubscriptionDataManager

findEventSubscriptionsByExecution

public List<EventSubscriptionEntity> findEventSubscriptionsByExecution(String executionId)

Specified by:

findEventSubscriptionsByExecution in interface EventSubscriptionDataManager

findEventSubscriptionsBySubScopeId

public List<EventSubscriptionEntity> findEventSubscriptionsBySubScopeId(String subScopeId)

Specified by:

findEventSubscriptionsBySubScopeId in interface EventSubscriptionDataManager

findEventSubscriptionsByTypeAndProcessDefinitionId

public List<EventSubscriptionEntity> findEventSubscriptionsByTypeAndProcessDefinitionId(String type,
                                                                                        String processDefinitionId,
                                                                                        String tenantId)

Specified by:

findEventSubscriptionsByTypeAndProcessDefinitionId in interface EventSubscriptionDataManager

findEventSubscriptionsByScopeIdAndType

public List<EventSubscriptionEntity> findEventSubscriptionsByScopeIdAndType(String scopeId,
                                                                            String type)

Specified by:

findEventSubscriptionsByScopeIdAndType in interface EventSubscriptionDataManager

findEventSubscriptionsByName

public List<EventSubscriptionEntity> findEventSubscriptionsByName(String type,
                                                                  String eventName,
                                                                  String tenantId)

Specified by:

findEventSubscriptionsByName in interface EventSubscriptionDataManager

findEventSubscriptionsByNameAndExecution

public List<EventSubscriptionEntity> findEventSubscriptionsByNameAndExecution(String type,
                                                                              String eventName,
                                                                              String executionId)

Specified by:

findEventSubscriptionsByNameAndExecution in interface EventSubscriptionDataManager

findMessageStartEventSubscriptionByName

public MessageEventSubscriptionEntity findMessageStartEventSubscriptionByName(String messageName,
                                                                              String tenantId)

Specified by:

findMessageStartEventSubscriptionByName in interface EventSubscriptionDataManager

updateEventSubscriptionTenantId

public void updateEventSubscriptionTenantId(String oldTenantId,
                                            String newTenantId)

Specified by:

updateEventSubscriptionTenantId in interface EventSubscriptionDataManager

updateEventSubscriptionLockTime

public boolean updateEventSubscriptionLockTime(String eventSubscriptionId,
                                               Date lockDate,
                                               String lockOwner,
                                               Date currentTime)

Specified by:

updateEventSubscriptionLockTime in interface EventSubscriptionDataManager

clearEventSubscriptionLockTime

public void clearEventSubscriptionLockTime(String eventSubscriptionId)

Specified by:

clearEventSubscriptionLockTime in interface EventSubscriptionDataManager

deleteEventSubscriptionsForProcessDefinition

public void deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)

Specified by:

deleteEventSubscriptionsForProcessDefinition in interface EventSubscriptionDataManager

deleteEventSubscriptionsByExecutionId

public void deleteEventSubscriptionsByExecutionId(String executionId)

Specified by:

deleteEventSubscriptionsByExecutionId in interface EventSubscriptionDataManager

deleteEventSubscriptionsForScopeIdAndType

public void deleteEventSubscriptionsForScopeIdAndType(String scopeId,
                                                      String scopeType)

Specified by:

deleteEventSubscriptionsForScopeIdAndType in interface EventSubscriptionDataManager

deleteEventSubscriptionsForScopeDefinitionIdAndType

public void deleteEventSubscriptionsForScopeDefinitionIdAndType(String scopeDefinitionId,
                                                                String scopeType)

Specified by:

deleteEventSubscriptionsForScopeDefinitionIdAndType in interface EventSubscriptionDataManager

deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId

public void deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId(String scopeDefinitionId,
                                                                              String scopeType)

Specified by:

deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId in interface EventSubscriptionDataManager

toSignalEventSubscriptionEntityList

protected List<SignalEventSubscriptionEntity> toSignalEventSubscriptionEntityList(List<EventSubscriptionEntity> result)

toMessageEventSubscriptionEntityList

protected List<MessageEventSubscriptionEntity> toMessageEventSubscriptionEntityList(List<EventSubscriptionEntity> result)

getIdGenerator

protected IdGenerator getIdGenerator()

Specified by:

getIdGenerator in class AbstractDataManager<EventSubscriptionEntity>