Package org.keycloak.models.map.storage.jpa

Class JpaMapStorage<RE extends JpaRootEntity,E extends AbstractEntity,M>

java.lang.Object

org.keycloak.models.map.storage.jpa.JpaMapStorage<RE,E,M>

All Implemented Interfaces:

MapStorage<E,M>

Direct Known Subclasses:

JpaAdminEventMapStorage, JpaAuthEventMapStorage, JpaClientMapStorage, JpaClientScopeMapStorage, JpaGroupMapStorage, JpaLockMapStorage, JpaPermissionMapStorage, JpaPolicyMapStorage, JpaRealmMapStorage, JpaResourceMapStorage, JpaResourceServerMapStorage, JpaRoleMapStorage, JpaRootAuthenticationSessionMapStorage, JpaScopeMapStorage, JpaSingleUseObjectMapStorage, JpaUserLoginFailureMapStorage, JpaUserMapStorage, JpaUserSessionMapStorage

public abstract class JpaMapStorage<RE extends JpaRootEntity,E extends AbstractEntity,M>
extends Object
implements MapStorage<E,M>

Field Summary

Fields

Modifier and Type	Field	Description
protected javax.persistence.EntityManager	em

Constructor Summary

Constructors

Constructor	Description
JpaMapStorage(org.keycloak.models.KeycloakSession session, Class<RE> entityType, Class<M> modelType, javax.persistence.EntityManager em)

Method Summary

Modifier and Type	Method	Description
static void	clearQueryCache(org.hibernate.Session session)
E	create(E mapEntity)
protected abstract JpaModelCriteriaBuilder	createJpaModelCriteriaBuilder()
boolean	delete(String key)
long	delete(QueryParameters<M> queryParameters)
long	getCount(QueryParameters<M> queryParameters)
protected abstract E	mapToEntityDelegate(RE original)
protected E	mapToEntityDelegateUnique(RE original)	Use the cache within the session to ensure that there is only one instance per entity within the current session.
E	read(String key)
Stream<E>	read(QueryParameters<M> queryParameters)
protected void	removeFromCache(String key)
protected abstract javax.persistence.criteria.Selection<? extends RE>	selectCbConstruct(javax.persistence.criteria.CriteriaBuilder cb, javax.persistence.criteria.Root<RE> root)
protected abstract void	setEntityVersion(JpaRootEntity entity)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.keycloak.models.map.storage.MapStorage

exists, exists

Field Detail

em

protected javax.persistence.EntityManager em

Constructor Detail

JpaMapStorage

public JpaMapStorage(org.keycloak.models.KeycloakSession session,
                     Class<RE> entityType,
                     Class<M> modelType,
                     javax.persistence.EntityManager em)

Method Detail

selectCbConstruct

protected abstract javax.persistence.criteria.Selection<? extends RE> selectCbConstruct(javax.persistence.criteria.CriteriaBuilder cb,
                                                                                        javax.persistence.criteria.Root<RE> root)

setEntityVersion

protected abstract void setEntityVersion(JpaRootEntity entity)

createJpaModelCriteriaBuilder

protected abstract JpaModelCriteriaBuilder createJpaModelCriteriaBuilder()

mapToEntityDelegate

protected abstract E mapToEntityDelegate(RE original)

mapToEntityDelegateUnique

protected E mapToEntityDelegateUnique(RE original)

Use the cache within the session to ensure that there is only one instance per entity within the current session.

create

public E create(E mapEntity)

Specified by:

create in interface MapStorage<RE extends JpaRootEntity,E extends AbstractEntity>

read

public E read(String key)

Specified by:

read in interface MapStorage<RE extends JpaRootEntity,E extends AbstractEntity>

read

public Stream<E> read(QueryParameters<M> queryParameters)

Specified by:

read in interface MapStorage<RE extends JpaRootEntity,E extends AbstractEntity>

clearQueryCache

public static void clearQueryCache(org.hibernate.Session session)

getCount

public long getCount(QueryParameters<M> queryParameters)

Specified by:

getCount in interface MapStorage<RE extends JpaRootEntity,E extends AbstractEntity>

delete

public boolean delete(String key)

Specified by:

delete in interface MapStorage<RE extends JpaRootEntity,E extends AbstractEntity>

removeFromCache

protected void removeFromCache(String key)

delete

public long delete(QueryParameters<M> queryParameters)

Specified by:

delete in interface MapStorage<RE extends JpaRootEntity,E extends AbstractEntity>