public class JpaCustomizedRoleRepository<D extends JpaUserRole> extends Object implements CustomizedRoleRepository<D>
JpaRoleRepository
.Constructor and Description |
---|
JpaCustomizedRoleRepository(com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> resourceLockRepository) |
Modifier and Type | Method and Description |
---|---|
protected javax.persistence.criteria.Predicate |
buildIdFilter(String entityId,
javax.persistence.criteria.Root<D> roleEntity,
javax.persistence.criteria.CriteriaBuilder criteriaBuilder,
Map<String,Object> parameterValues) |
D |
createOnlyIfDoesNotExist(D role,
@NonNull Instant lastUpdated)
Since we have a pre-defined id we want to create the entity with, we cannot simply call
EntityManager.persist(Object) , since it will reject it as a "detached" entity. |
Class<D> |
getDomainType() |
protected com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> |
getResourceLockRepository() |
protected RoleRepository<D> |
getRoleRepository() |
D |
replaceOnlyIfLastUpdatedBefore(@NonNull String entityId,
D role,
@NonNull Instant lastUpdated)
A specialized replace operation that does not invoke the "save" create-or-update behavior.
|
void |
setRepository(RoleRepository<D> repository) |
public JpaCustomizedRoleRepository(com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> resourceLockRepository)
@Autowired public void setRepository(RoleRepository<D> repository)
public Class<D> getDomainType()
getDomainType
in interface com.broadleafcommerce.common.extension.DomainTypeAware
@Nullable @Transactional public D createOnlyIfDoesNotExist(@NonNull D role, @NonNull @NonNull Instant lastUpdated)
EntityManager.persist(Object)
, since it will reject it as a "detached" entity.
Thus, we will rely on ResourceLockRepository
to lock the requested ID and ensure
competing concurrent invocations of this method will not overwrite each other when
EntityManager.merge(Object)
is called.
createOnlyIfDoesNotExist
in interface CustomizedRoleRepository<D extends JpaUserRole>
role
- the role to createlastUpdated
- the UserRole.lastUpdated
to set on the rolenull
otherwise@Nullable @Transactional public D replaceOnlyIfLastUpdatedBefore(@NonNull @NonNull String entityId, @NonNull D role, @NonNull @NonNull Instant lastUpdated)
CustomizedRoleRepository
This is intended to be used in concurrent scenarios where only one operation should succeed.
Note that this update should succeed even if the existing record is
UserRole.archived
.
Note that this method should also set the provided UserRole.archived
value,
even if it is true
.
replaceOnlyIfLastUpdatedBefore
in interface CustomizedRoleRepository<D extends JpaUserRole>
entityId
- the id of the entity to replacerole
- the replacement entitylastUpdated
- the timestamp of the current change. This will be compared to the
lastUpdated on the existing entity for determination of whether the replacement should
occur. Furthermore, the replacement will have its UserRole.lastUpdated
set to
this value.null
if the entity
was not found or could not be updated due to its lastUpdated value.protected javax.persistence.criteria.Predicate buildIdFilter(String entityId, javax.persistence.criteria.Root<D> roleEntity, javax.persistence.criteria.CriteriaBuilder criteriaBuilder, Map<String,Object> parameterValues)
protected com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> getResourceLockRepository()
protected RoleRepository<D> getRoleRepository()
Copyright © 2021. All rights reserved.