Class JPATaskPersistenceContext
- java.lang.Object
-
- org.jbpm.services.task.persistence.JPATaskPersistenceContext
-
- All Implemented Interfaces:
org.kie.internal.task.api.TaskPersistenceContext
public class JPATaskPersistenceContext extends Object implements org.kie.internal.task.api.TaskPersistenceContext
-
-
Field Summary
Fields Modifier and Type Field Description protected javax.persistence.EntityManageremprotected booleanisJTAprotected javax.persistence.LockModeTypelockModeprotected booleanpessimisticLocking
-
Constructor Summary
Constructors Constructor Description JPATaskPersistenceContext(javax.persistence.EntityManager em)JPATaskPersistenceContext(javax.persistence.EntityManager em, boolean isJTA)JPATaskPersistenceContext(javax.persistence.EntityManager em, boolean isJTA, boolean locking, String lockingMode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.kie.api.task.model.AttachmentaddAttachmentToTask(org.kie.api.task.model.Attachment attachment, org.kie.api.task.model.Task task)org.kie.api.task.model.CommentaddCommentToTask(org.kie.api.task.model.Comment comment, org.kie.api.task.model.Task task)HashMap<String,Object>addParametersToMap(Object... parameterValues)protected voidcheck()voidclose()List<org.kie.api.task.model.TaskSummary>doTaskSummaryCriteriaQuery(String userId, org.kie.api.task.UserGroupCallback userGroupCallback, Object queryWhere)intexecuteUpdate(String queryName, Map<String,Object> params)intexecuteUpdateString(String updateString)<T> Tfind(Class<T> entityClass, Object primaryKey)org.kie.api.task.model.AttachmentfindAttachment(Long attachmentId)org.kie.api.task.model.CommentfindComment(Long commentId)org.kie.api.task.model.ContentfindContent(Long contentId)org.kie.internal.task.api.model.DeadlinefindDeadline(Long deadlineId)org.kie.api.task.model.EmailfindEmail(String emailId)org.kie.api.task.model.GroupfindGroup(String groupId)org.kie.api.task.model.OrganizationalEntityfindOrgEntity(String orgEntityId)org.kie.api.task.model.TaskfindTask(Long taskId)LongfindTaskIdByContentId(Long contentId)org.kie.api.task.model.UserfindUser(String userId)javax.persistence.EntityManagergetEntityManager()protected javax.persistence.QuerygetQueryByName(String queryName, Map<String,Object> params)booleanisOpen()voidjoinTransaction()<T> Tmerge(T entity)<T> Tpersist(T object)org.kie.api.task.model.AttachmentpersistAttachment(org.kie.api.task.model.Attachment attachment)org.kie.api.task.model.CommentpersistComment(org.kie.api.task.model.Comment comment)org.kie.api.task.model.ContentpersistContent(org.kie.api.task.model.Content content)org.kie.internal.task.api.model.DeadlinepersistDeadline(org.kie.internal.task.api.model.Deadline deadline)org.kie.api.task.model.EmailpersistEmail(org.kie.api.task.model.Email email)org.kie.api.task.model.GrouppersistGroup(org.kie.api.task.model.Group group)org.kie.api.task.model.OrganizationalEntitypersistOrgEntity(org.kie.api.task.model.OrganizationalEntity orgEntity)org.kie.api.task.model.TaskpersistTask(org.kie.api.task.model.Task task)org.kie.api.task.model.UserpersistUser(org.kie.api.task.model.User user)<T> TqueryAndLockStringWithParametersInTransaction(String queryName, Map<String,Object> params, boolean singleResult, Class<T> clazz)<T> TqueryAndLockWithParametersInTransaction(String queryName, Map<String,Object> params, boolean singleResult, Class<T> clazz)<T> TqueryInTransaction(String queryName, Class<T> clazz)<T> TqueryStringInTransaction(String queryString, Class<T> clazz)<T> TqueryStringWithParametersInTransaction(String queryString, boolean singleResult, Map<String,Object> params, Class<T> clazz)<T> TqueryStringWithParametersInTransaction(String queryString, Map<String,Object> params, Class<T> clazz)<T> TqueryWithParametersInTransaction(String queryName, boolean singleResult, Map<String,Object> params, Class<T> clazz)<T> TqueryWithParametersInTransaction(String queryName, Map<String,Object> params, Class<T> clazz)<T> Tremove(T entity)org.kie.api.task.model.AttachmentremoveAttachment(org.kie.api.task.model.Attachment attachment)org.kie.api.task.model.AttachmentremoveAttachmentFromTask(org.kie.api.task.model.Task task, long attachmentId)org.kie.api.task.model.CommentremoveComment(org.kie.api.task.model.Comment comment)org.kie.api.task.model.CommentremoveCommentFromTask(org.kie.api.task.model.Comment comment, org.kie.api.task.model.Task task)org.kie.api.task.model.ContentremoveContent(org.kie.api.task.model.Content content)org.kie.internal.task.api.model.DeadlineremoveDeadline(org.kie.internal.task.api.model.Deadline deadline)org.kie.api.task.model.EmailremoveEmail(org.kie.api.task.model.Email email)org.kie.api.task.model.GroupremoveGroup(org.kie.api.task.model.Group group)org.kie.api.task.model.OrganizationalEntityremoveOrgEntity(org.kie.api.task.model.OrganizationalEntity orgEntity)org.kie.api.task.model.TaskremoveTask(org.kie.api.task.model.Task task)org.kie.api.task.model.UserremoveUser(org.kie.api.task.model.User user)org.kie.api.task.model.TasksetDocumentToTask(org.kie.api.task.model.Content content, org.kie.internal.task.api.model.ContentData contentData, org.kie.api.task.model.Task task)org.kie.api.task.model.TasksetFaultToTask(org.kie.api.task.model.Content content, org.kie.internal.task.api.model.FaultData faultData, org.kie.api.task.model.Task task)org.kie.api.task.model.TasksetOutputToTask(org.kie.api.task.model.Content content, org.kie.internal.task.api.model.ContentData contentData, org.kie.api.task.model.Task task)org.kie.api.task.model.AttachmentupdateAttachment(org.kie.api.task.model.Attachment attachment)org.kie.api.task.model.CommentupdateComment(org.kie.api.task.model.Comment comment)org.kie.api.task.model.ContentupdateContent(org.kie.api.task.model.Content content)org.kie.internal.task.api.model.DeadlineupdateDeadline(org.kie.internal.task.api.model.Deadline deadline)org.kie.api.task.model.EmailupdateEmail(org.kie.api.task.model.Email email)org.kie.api.task.model.GroupupdateGroup(org.kie.api.task.model.Group group)org.kie.api.task.model.OrganizationalEntityupdateOrgEntity(org.kie.api.task.model.OrganizationalEntity orgEntity)org.kie.api.task.model.TaskupdateTask(org.kie.api.task.model.Task task)org.kie.api.task.model.UserupdateUser(org.kie.api.task.model.User user)
-
-
-
Constructor Detail
-
JPATaskPersistenceContext
public JPATaskPersistenceContext(javax.persistence.EntityManager em)
-
JPATaskPersistenceContext
public JPATaskPersistenceContext(javax.persistence.EntityManager em, boolean isJTA)
-
JPATaskPersistenceContext
public JPATaskPersistenceContext(javax.persistence.EntityManager em, boolean isJTA, boolean locking, String lockingMode)
-
-
Method Detail
-
getEntityManager
public javax.persistence.EntityManager getEntityManager()
-
findTask
public org.kie.api.task.model.Task findTask(Long taskId)
- Specified by:
findTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistTask
public org.kie.api.task.model.Task persistTask(org.kie.api.task.model.Task task)
- Specified by:
persistTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateTask
public org.kie.api.task.model.Task updateTask(org.kie.api.task.model.Task task)
- Specified by:
updateTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeTask
public org.kie.api.task.model.Task removeTask(org.kie.api.task.model.Task task)
- Specified by:
removeTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findGroup
public org.kie.api.task.model.Group findGroup(String groupId)
- Specified by:
findGroupin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistGroup
public org.kie.api.task.model.Group persistGroup(org.kie.api.task.model.Group group)
- Specified by:
persistGroupin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateGroup
public org.kie.api.task.model.Group updateGroup(org.kie.api.task.model.Group group)
- Specified by:
updateGroupin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeGroup
public org.kie.api.task.model.Group removeGroup(org.kie.api.task.model.Group group)
- Specified by:
removeGroupin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findUser
public org.kie.api.task.model.User findUser(String userId)
- Specified by:
findUserin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistUser
public org.kie.api.task.model.User persistUser(org.kie.api.task.model.User user)
- Specified by:
persistUserin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateUser
public org.kie.api.task.model.User updateUser(org.kie.api.task.model.User user)
- Specified by:
updateUserin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeUser
public org.kie.api.task.model.User removeUser(org.kie.api.task.model.User user)
- Specified by:
removeUserin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findEmail
public org.kie.api.task.model.Email findEmail(String emailId)
- Specified by:
findEmailin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistEmail
public org.kie.api.task.model.Email persistEmail(org.kie.api.task.model.Email email)
- Specified by:
persistEmailin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateEmail
public org.kie.api.task.model.Email updateEmail(org.kie.api.task.model.Email email)
- Specified by:
updateEmailin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeEmail
public org.kie.api.task.model.Email removeEmail(org.kie.api.task.model.Email email)
- Specified by:
removeEmailin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findOrgEntity
public org.kie.api.task.model.OrganizationalEntity findOrgEntity(String orgEntityId)
- Specified by:
findOrgEntityin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistOrgEntity
public org.kie.api.task.model.OrganizationalEntity persistOrgEntity(org.kie.api.task.model.OrganizationalEntity orgEntity)
- Specified by:
persistOrgEntityin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateOrgEntity
public org.kie.api.task.model.OrganizationalEntity updateOrgEntity(org.kie.api.task.model.OrganizationalEntity orgEntity)
- Specified by:
updateOrgEntityin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeOrgEntity
public org.kie.api.task.model.OrganizationalEntity removeOrgEntity(org.kie.api.task.model.OrganizationalEntity orgEntity)
- Specified by:
removeOrgEntityin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findContent
public org.kie.api.task.model.Content findContent(Long contentId)
- Specified by:
findContentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistContent
public org.kie.api.task.model.Content persistContent(org.kie.api.task.model.Content content)
- Specified by:
persistContentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateContent
public org.kie.api.task.model.Content updateContent(org.kie.api.task.model.Content content)
- Specified by:
updateContentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeContent
public org.kie.api.task.model.Content removeContent(org.kie.api.task.model.Content content)
- Specified by:
removeContentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
setDocumentToTask
public org.kie.api.task.model.Task setDocumentToTask(org.kie.api.task.model.Content content, org.kie.internal.task.api.model.ContentData contentData, org.kie.api.task.model.Task task)- Specified by:
setDocumentToTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
setFaultToTask
public org.kie.api.task.model.Task setFaultToTask(org.kie.api.task.model.Content content, org.kie.internal.task.api.model.FaultData faultData, org.kie.api.task.model.Task task)- Specified by:
setFaultToTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
setOutputToTask
public org.kie.api.task.model.Task setOutputToTask(org.kie.api.task.model.Content content, org.kie.internal.task.api.model.ContentData contentData, org.kie.api.task.model.Task task)- Specified by:
setOutputToTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findAttachment
public org.kie.api.task.model.Attachment findAttachment(Long attachmentId)
- Specified by:
findAttachmentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistAttachment
public org.kie.api.task.model.Attachment persistAttachment(org.kie.api.task.model.Attachment attachment)
- Specified by:
persistAttachmentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateAttachment
public org.kie.api.task.model.Attachment updateAttachment(org.kie.api.task.model.Attachment attachment)
- Specified by:
updateAttachmentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeAttachment
public org.kie.api.task.model.Attachment removeAttachment(org.kie.api.task.model.Attachment attachment)
- Specified by:
removeAttachmentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeAttachmentFromTask
public org.kie.api.task.model.Attachment removeAttachmentFromTask(org.kie.api.task.model.Task task, long attachmentId)- Specified by:
removeAttachmentFromTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
addAttachmentToTask
public org.kie.api.task.model.Attachment addAttachmentToTask(org.kie.api.task.model.Attachment attachment, org.kie.api.task.model.Task task)- Specified by:
addAttachmentToTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findComment
public org.kie.api.task.model.Comment findComment(Long commentId)
- Specified by:
findCommentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistComment
public org.kie.api.task.model.Comment persistComment(org.kie.api.task.model.Comment comment)
- Specified by:
persistCommentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateComment
public org.kie.api.task.model.Comment updateComment(org.kie.api.task.model.Comment comment)
- Specified by:
updateCommentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeComment
public org.kie.api.task.model.Comment removeComment(org.kie.api.task.model.Comment comment)
- Specified by:
removeCommentin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeCommentFromTask
public org.kie.api.task.model.Comment removeCommentFromTask(org.kie.api.task.model.Comment comment, org.kie.api.task.model.Task task)- Specified by:
removeCommentFromTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
addCommentToTask
public org.kie.api.task.model.Comment addCommentToTask(org.kie.api.task.model.Comment comment, org.kie.api.task.model.Task task)- Specified by:
addCommentToTaskin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
findDeadline
public org.kie.internal.task.api.model.Deadline findDeadline(Long deadlineId)
- Specified by:
findDeadlinein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persistDeadline
public org.kie.internal.task.api.model.Deadline persistDeadline(org.kie.internal.task.api.model.Deadline deadline)
- Specified by:
persistDeadlinein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
updateDeadline
public org.kie.internal.task.api.model.Deadline updateDeadline(org.kie.internal.task.api.model.Deadline deadline)
- Specified by:
updateDeadlinein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
removeDeadline
public org.kie.internal.task.api.model.Deadline removeDeadline(org.kie.internal.task.api.model.Deadline deadline)
- Specified by:
removeDeadlinein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryWithParametersInTransaction
public <T> T queryWithParametersInTransaction(String queryName, Map<String,Object> params, Class<T> clazz)
- Specified by:
queryWithParametersInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryWithParametersInTransaction
public <T> T queryWithParametersInTransaction(String queryName, boolean singleResult, Map<String,Object> params, Class<T> clazz)
- Specified by:
queryWithParametersInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryAndLockWithParametersInTransaction
public <T> T queryAndLockWithParametersInTransaction(String queryName, Map<String,Object> params, boolean singleResult, Class<T> clazz)
- Specified by:
queryAndLockWithParametersInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryInTransaction
public <T> T queryInTransaction(String queryName, Class<T> clazz)
- Specified by:
queryInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryStringInTransaction
public <T> T queryStringInTransaction(String queryString, Class<T> clazz)
- Specified by:
queryStringInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryStringWithParametersInTransaction
public <T> T queryStringWithParametersInTransaction(String queryString, Map<String,Object> params, Class<T> clazz)
- Specified by:
queryStringWithParametersInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryStringWithParametersInTransaction
public <T> T queryStringWithParametersInTransaction(String queryString, boolean singleResult, Map<String,Object> params, Class<T> clazz)
- Specified by:
queryStringWithParametersInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
queryAndLockStringWithParametersInTransaction
public <T> T queryAndLockStringWithParametersInTransaction(String queryName, Map<String,Object> params, boolean singleResult, Class<T> clazz)
- Specified by:
queryAndLockStringWithParametersInTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
executeUpdateString
public int executeUpdateString(String updateString)
- Specified by:
executeUpdateStringin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
executeUpdate
public int executeUpdate(String queryName, Map<String,Object> params)
- Specified by:
executeUpdatein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
addParametersToMap
public HashMap<String,Object> addParametersToMap(Object... parameterValues)
- Specified by:
addParametersToMapin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
persist
public <T> T persist(T object)
- Specified by:
persistin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
find
public <T> T find(Class<T> entityClass, Object primaryKey)
- Specified by:
findin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
remove
public <T> T remove(T entity)
- Specified by:
removein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
merge
public <T> T merge(T entity)
- Specified by:
mergein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
isOpen
public boolean isOpen()
- Specified by:
isOpenin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
joinTransaction
public void joinTransaction()
- Specified by:
joinTransactionin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
close
public void close()
- Specified by:
closein interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
check
protected void check()
-
getQueryByName
protected javax.persistence.Query getQueryByName(String queryName, Map<String,Object> params)
-
findTaskIdByContentId
public Long findTaskIdByContentId(Long contentId)
- Specified by:
findTaskIdByContentIdin interfaceorg.kie.internal.task.api.TaskPersistenceContext
-
-