com.broadleafcommerce.auth.security.provider.jpa.repository

Class JpaCustomizedUserPermissionRepository<D extends JpaUserPermission>

java.lang.Object

com.broadleafcommerce.auth.security.provider.jpa.repository.JpaCustomizedUserPermissionRepository<D>

All Implemented Interfaces:

CustomizedUserPermissionRepository<D>, com.broadleafcommerce.common.extension.DomainTypeAware

public class JpaCustomizedUserPermissionRepository<D extends JpaUserPermission>
extends Object
implements CustomizedUserPermissionRepository<D>

Additional functionality necessary for JpaUserPermissionRepository.

Author:

Samarth Dhruva (samarthd)

Constructor Summary

Constructors

Constructor and Description
JpaCustomizedUserPermissionRepository(com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> resourceLockRepository)

Method Summary

Modifier and Type	Method and Description
protected javax.persistence.criteria.Predicate	buildIdFilter(String entityId, javax.persistence.criteria.Root<D> permissionEntity, javax.persistence.criteria.CriteriaBuilder criteriaBuilder, Map<String,Object> parameterValues)
D	createOnlyIfDoesNotExist(D permission, @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 UserPermissionRepository<D>	getPermissionRepository()
protected com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?>	getResourceLockRepository()
D	replaceOnlyIfLastUpdatedBefore(@NonNull String entityId, D permission, @NonNull Instant lastUpdated) A specialized replace operation that does not invoke the "save" create-or-update behavior.
void	setRepository(UserPermissionRepository<D> repository)

Methods inherited from class java.lang.Object

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

Constructor Detail

JpaCustomizedUserPermissionRepository

public JpaCustomizedUserPermissionRepository(com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> resourceLockRepository)

Method Detail

setRepository

@Autowired
public void setRepository(UserPermissionRepository<D> repository)

getDomainType

public Class<D> getDomainType()

Specified by:

getDomainType in interface com.broadleafcommerce.common.extension.DomainTypeAware

createOnlyIfDoesNotExist

@Nullable
 @Transactional
public D createOnlyIfDoesNotExist(@NonNull
                                                            D permission,
                                                            @NonNull
                                                            @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.

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.

Specified by:

createOnlyIfDoesNotExist in interface CustomizedUserPermissionRepository<D extends JpaUserPermission>

Parameters:

permission - the permission to create

lastUpdated - the UserPermission.lastUpdated to set on the permission

Returns:

the entity if successfully created, null otherwise

replaceOnlyIfLastUpdatedBefore

@Nullable
 @Transactional
public D replaceOnlyIfLastUpdatedBefore(@NonNull
                                                                  @NonNull String entityId,
                                                                  @NonNull
                                                                  D permission,
                                                                  @NonNull
                                                                  @NonNull Instant lastUpdated)

Description copied from interface: CustomizedUserPermissionRepository

A specialized replace operation that does not invoke the "save" create-or-update behavior. This operation should directly attempt an atomic update that the data store will reject if the entity is not found or has a lastUpdated ahead of the current change.

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 UserPermission.archived.

Note that this method should also set the provided UserPermission.archived value, even if it is true.

Specified by:

replaceOnlyIfLastUpdatedBefore in interface CustomizedUserPermissionRepository<D extends JpaUserPermission>

Parameters:

entityId - the id of the entity to replace

permission - the replacement entity

lastUpdated - 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 UserPermission.lastUpdated set to this value.

Returns:

the permission after replacement if successfully replaced, or null if the entity was not found or could not be updated due to its lastUpdated value.

buildIdFilter

protected javax.persistence.criteria.Predicate buildIdFilter(String entityId,
                                                             javax.persistence.criteria.Root<D> permissionEntity,
                                                             javax.persistence.criteria.CriteriaBuilder criteriaBuilder,
                                                             Map<String,Object> parameterValues)

getResourceLockRepository

protected com.broadleafcommerce.common.messaging.repository.ResourceLockRepository<?,?> getResourceLockRepository()

getPermissionRepository

protected UserPermissionRepository<D> getPermissionRepository()