org.keycloak.models.jpa.JpaRealmProvider クラス

org.keycloak.models.jpa.JpaRealmProvider の継承関係図

org.keycloak.models.jpa.JpaRealmProvider 連携図

公開メンバ関数
	JpaRealmProvider (KeycloakSession session, EntityManager em)
MigrationModel	getMigrationModel ()
RealmModel	createRealm (String name)
RealmModel	createRealm (String id, String name)
RealmModel	getRealm (String id)
List< RealmModel >	getRealms ()
RealmModel	getRealmByName (String name)
boolean	removeRealm (String id)
void	close ()
RoleModel	addRealmRole (RealmModel realm, String name)
RoleModel	addRealmRole (RealmModel realm, String id, String name)
RoleModel	getRealmRole (RealmModel realm, String name)
RoleModel	addClientRole (RealmModel realm, ClientModel client, String name)
RoleModel	addClientRole (RealmModel realm, ClientModel client, String id, String name)
Set< RoleModel >	getRealmRoles (RealmModel realm)
RoleModel	getClientRole (RealmModel realm, ClientModel client, String name)
Set< RoleModel >	getClientRoles (RealmModel realm, ClientModel client)
boolean	removeRole (RealmModel realm, RoleModel role)
RoleModel	getRoleById (String id, RealmModel realm)
GroupModel	getGroupById (String id, RealmModel realm)
void	moveGroup (RealmModel realm, GroupModel group, GroupModel toParent)
List< GroupModel >	getGroups (RealmModel realm)
Long	getGroupsCount (RealmModel realm, Boolean onlyTopGroups)
Long	getGroupsCountByNameContaining (RealmModel realm, String search)
List< GroupModel >	getTopLevelGroups (RealmModel realm)
List< GroupModel >	getTopLevelGroups (RealmModel realm, Integer first, Integer max)
boolean	removeGroup (RealmModel realm, GroupModel group)
GroupModel	createGroup (RealmModel realm, String name)
GroupModel	createGroup (RealmModel realm, String id, String name)
void	addTopLevelGroup (RealmModel realm, GroupModel subGroup)
ClientModel	addClient (RealmModel realm, String clientId)
ClientModel	addClient (RealmModel realm, String id, String clientId)
List< ClientModel >	getClients (RealmModel realm)
ClientModel	getClientById (String id, RealmModel realm)
ClientModel	getClientByClientId (String clientId, RealmModel realm)
boolean	removeClient (String id, RealmModel realm)
ClientScopeModel	getClientScopeById (String id, RealmModel realm)
List< GroupModel >	searchForGroupByName (RealmModel realm, String search, Integer first, Integer max)
ClientInitialAccessModel	createClientInitialAccessModel (RealmModel realm, int expiration, int count)
ClientInitialAccessModel	getClientInitialAccessModel (RealmModel realm, String id)
void	removeClientInitialAccessModel (RealmModel realm, String id)
List< ClientInitialAccessModel >	listClientInitialAccess (RealmModel realm)
void	removeExpiredClientInitialAccess ()
void	decreaseRemainingCount (RealmModel realm, ClientInitialAccessModel clientInitialAccess)

限定公開変数類
EntityManager	em

静的限定公開変数類
static final Logger	logger = Logger.getLogger(JpaRealmProvider.class)

非公開メンバ関数
ClientInitialAccessModel	entityToModel (ClientInitialAccessEntity entity)

非公開変数類
final KeycloakSession	session

詳解

著者

Bill Burke

バージョン

Revision

1

構築子と解体子

JpaRealmProvider()

org.keycloak.models.jpa.JpaRealmProvider.JpaRealmProvider ( KeycloakSession  session, EntityManager  em  )

inline

                                                                       {
        this.session = session;
        this.em = em;
    }

関数詳解

addClient() [1/2]

ClientModel org.keycloak.models.jpa.JpaRealmProvider.addClient ( RealmModel  realm, String  clientId  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                                    {
        return addClient(realm, KeycloakModelUtils.generateId(), clientId);
    }

addClient() [2/2]

ClientModel org.keycloak.models.jpa.JpaRealmProvider.addClient ( RealmModel  realm, String  id, String  clientId  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                                               {
        if (clientId == null) {
            clientId = id;
        }
        ClientEntity entity = new ClientEntity();
        entity.setId(id);
        entity.setClientId(clientId);
        entity.setEnabled(true);
        entity.setStandardFlowEnabled(true);
        RealmEntity realmRef = em.getReference(RealmEntity.class, realm.getId());
        entity.setRealm(realmRef);
        em.persist(entity);
        em.flush();
        final ClientModel resource = new ClientAdapter(realm, em, session, entity);

        em.flush();
        session.getKeycloakSessionFactory().publish(new RealmModel.ClientCreationEvent() {
            @Override
            public ClientModel getCreatedClient() {
                return resource;
            }
        });
        return resource;
    }

addClientRole() [1/2]

RoleModel org.keycloak.models.jpa.JpaRealmProvider.addClientRole ( RealmModel  realm, ClientModel  client, String  name  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                                                      {
        return addClientRole(realm, client, KeycloakModelUtils.generateId(), name);
    }

addClientRole() [2/2]

RoleModel org.keycloak.models.jpa.JpaRealmProvider.addClientRole ( RealmModel  realm, ClientModel  client, String  id, String  name  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                                                                 {
        if (getClientRole(realm, client, name) != null) {
            throw new ModelDuplicateException();
        }
        ClientEntity clientEntity = em.getReference(ClientEntity.class, client.getId());
        RoleEntity roleEntity = new RoleEntity();
        roleEntity.setId(id);
        roleEntity.setName(name);
        roleEntity.setClient(clientEntity);
        roleEntity.setClientRole(true);
        roleEntity.setRealmId(realm.getId());
        em.persist(roleEntity);
        RoleAdapter adapter = new RoleAdapter(session, realm, em, roleEntity);
        return adapter;
    }

addRealmRole() [1/2]

RoleModel org.keycloak.models.jpa.JpaRealmProvider.addRealmRole ( RealmModel  realm, String  name  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                 {
       return addRealmRole(realm, KeycloakModelUtils.generateId(), name);

    }

addRealmRole() [2/2]

RoleModel org.keycloak.models.jpa.JpaRealmProvider.addRealmRole ( RealmModel  realm, String  id, String  name  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                            {
        if (getRealmRole(realm, name) != null) {
            throw new ModelDuplicateException();
        }
        RoleEntity entity = new RoleEntity();
        entity.setId(id);
        entity.setName(name);
        RealmEntity ref = em.getReference(RealmEntity.class, realm.getId());
        entity.setRealm(ref);
        entity.setRealmId(realm.getId());
        em.persist(entity);
        em.flush();
        RoleAdapter adapter = new RoleAdapter(session, realm, em, entity);
        return adapter;

    }

addTopLevelGroup()

void org.keycloak.models.jpa.JpaRealmProvider.addTopLevelGroup ( RealmModel  realm, GroupModel  subGroup  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                        {
        subGroup.setParent(null);
    }

close()

void org.keycloak.models.jpa.JpaRealmProvider.close ( )

inline

org.keycloak.models.RealmProviderを実装しています。

                        {
    }

createClientInitialAccessModel()

ClientInitialAccessModel org.keycloak.models.jpa.JpaRealmProvider.createClientInitialAccessModel ( RealmModel  realm, int  expiration, int  count  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                                                {
        RealmEntity realmEntity = em.find(RealmEntity.class, realm.getId());

        ClientInitialAccessEntity entity = new ClientInitialAccessEntity();
        entity.setId(KeycloakModelUtils.generateId());
        entity.setRealm(realmEntity);

        entity.setCount(count);
        entity.setRemainingCount(count);

        int currentTime = Time.currentTime();
        entity.setTimestamp(currentTime);
        entity.setExpiration(expiration);

        em.persist(entity);

        return entityToModel(entity);
    }

createGroup() [1/2]

GroupModel org.keycloak.models.jpa.JpaRealmProvider.createGroup ( RealmModel  realm, String  name  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                 {
        String id = KeycloakModelUtils.generateId();
        return createGroup(realm, id, name);
    }

createGroup() [2/2]

GroupModel org.keycloak.models.jpa.JpaRealmProvider.createGroup ( RealmModel  realm, String  id, String  name  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                            {
        if (id == null) id = KeycloakModelUtils.generateId();
        GroupEntity groupEntity = new GroupEntity();
        groupEntity.setId(id);
        groupEntity.setName(name);
        RealmEntity realmEntity = em.getReference(RealmEntity.class, realm.getId());
        groupEntity.setRealm(realmEntity);
        em.persist(groupEntity);
        em.flush();
        realmEntity.getGroups().add(groupEntity);

        GroupAdapter adapter = new GroupAdapter(realm, em, groupEntity);
        return adapter;
    }

createRealm() [1/2]

RealmModel org.keycloak.models.jpa.JpaRealmProvider.createRealm ( String  name )

inline

org.keycloak.models.RealmProviderを実装しています。

                                               {
        return createRealm(KeycloakModelUtils.generateId(), name);
    }

createRealm() [2/2]

RealmModel org.keycloak.models.jpa.JpaRealmProvider.createRealm ( String  id, String  name  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                          {
        RealmEntity realm = new RealmEntity();
        realm.setName(name);
        realm.setId(id);
        em.persist(realm);
        em.flush();
        final RealmModel adapter = new RealmAdapter(session, em, realm);
        session.getKeycloakSessionFactory().publish(new RealmModel.RealmCreationEvent() {
            @Override
            public RealmModel getCreatedRealm() {
                return adapter;
            }
        });
        return adapter;
    }

decreaseRemainingCount()

void org.keycloak.models.jpa.JpaRealmProvider.decreaseRemainingCount ( RealmModel  realm, ClientInitialAccessModel  clientInitialAccess  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                                       {
        em.createNamedQuery("decreaseClientInitialAccessRemainingCount")
                .setParameter("id", clientInitialAccess.getId())
                .executeUpdate();
    }

entityToModel()

ClientInitialAccessModel org.keycloak.models.jpa.JpaRealmProvider.entityToModel ( ClientInitialAccessEntity  entity )

inlineprivate

                                                                                     {
        ClientInitialAccessModel model = new ClientInitialAccessModel();
        model.setId(entity.getId());
        model.setCount(entity.getCount());
        model.setRemainingCount(entity.getRemainingCount());
        model.setExpiration(entity.getExpiration());
        model.setTimestamp(entity.getTimestamp());
        return model;
    }

getClientByClientId()

ClientModel org.keycloak.models.jpa.JpaRealmProvider.getClientByClientId ( String  clientId, RealmModel  realm  )

inline

org.keycloak.storage.client.ClientLookupProviderを実装しています。

                                                                              {
        TypedQuery<String> query = em.createNamedQuery("findClientIdByClientId", String.class);
        query.setParameter("clientId", clientId);
        query.setParameter("realm", realm.getId());
        List<String> results = query.getResultList();
        if (results.isEmpty()) return null;
        String id = results.get(0);
        return session.realms().getClientById(id, realm);
    }

getClientById()

ClientModel org.keycloak.models.jpa.JpaRealmProvider.getClientById ( String  id, RealmModel  realm  )

inline

org.keycloak.storage.client.ClientLookupProviderを実装しています。

                                                                  {
        ClientEntity app = em.find(ClientEntity.class, id);
        // Check if application belongs to this realm
        if (app == null || !realm.getId().equals(app.getRealm().getId())) return null;
        ClientAdapter client = new ClientAdapter(realm, em, session, app);
        return client;

    }

getClientInitialAccessModel()

ClientInitialAccessModel org.keycloak.models.jpa.JpaRealmProvider.getClientInitialAccessModel ( RealmModel  realm, String  id  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                             {
        ClientInitialAccessEntity entity = em.find(ClientInitialAccessEntity.class, id);
        if (entity == null) {
            return null;
        } else {
            return entityToModel(entity);
        }
    }

getClientRole()

RoleModel org.keycloak.models.jpa.JpaRealmProvider.getClientRole ( RealmModel  realm, ClientModel  client, String  name  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                                                      {
        TypedQuery<String> query = em.createNamedQuery("getClientRoleIdByName", String.class);
        query.setParameter("name", name);
        query.setParameter("client", client.getId());
        List<String> roles = query.getResultList();
        if (roles.isEmpty()) return null;
        return session.realms().getRoleById(roles.get(0), realm);
    }

getClientRoles()

Set<RoleModel> org.keycloak.models.jpa.JpaRealmProvider.getClientRoles ( RealmModel  realm, ClientModel  client  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                                               {
        Set<RoleModel> list = new HashSet<>();
        TypedQuery<String> query = em.createNamedQuery("getClientRoleIds", String.class);
        query.setParameter("client", client.getId());
        List<String> roles = query.getResultList();
        for (String id : roles) {
            list.add(session.realms().getRoleById(id, realm));
        }
        return list;

    }

getClients()

List<ClientModel> org.keycloak.models.jpa.JpaRealmProvider.getClients ( RealmModel  realm )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                          {
        TypedQuery<String> query = em.createNamedQuery("getClientIdsByRealm", String.class);
        query.setParameter("realm", realm.getId());
        List<String> clients = query.getResultList();
        if (clients.isEmpty()) return Collections.EMPTY_LIST;
        List<ClientModel> list = new LinkedList<>();
        for (String id : clients) {
            ClientModel client = session.realms().getClientById(id, realm);
            if (client != null) list.add(client);
        }
        return Collections.unmodifiableList(list);

    }

getClientScopeById()

ClientScopeModel org.keycloak.models.jpa.JpaRealmProvider.getClientScopeById ( String  id, RealmModel  realm  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                            {
        ClientScopeEntity app = em.find(ClientScopeEntity.class, id);

        // Check if application belongs to this realm
        if (app == null || !realm.getId().equals(app.getRealm().getId())) return null;
        ClientScopeAdapter adapter = new ClientScopeAdapter(realm, em, session, app);
        return adapter;
    }

getGroupById()

GroupModel org.keycloak.models.jpa.JpaRealmProvider.getGroupById ( String  id, RealmModel  realm  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                {
        GroupEntity groupEntity = em.find(GroupEntity.class, id);
        if (groupEntity == null) return null;
        if (!groupEntity.getRealm().getId().equals(realm.getId())) return null;
        GroupAdapter adapter =  new GroupAdapter(realm, em, groupEntity);
        return adapter;
    }

getGroups()

List<GroupModel> org.keycloak.models.jpa.JpaRealmProvider.getGroups ( RealmModel  realm )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                        {
        RealmEntity ref = em.getReference(RealmEntity.class, realm.getId());

        return ref.getGroups().stream()
                .map(g -> session.realms().getGroupById(g.getId(), realm))
                .sorted(Comparator.comparing(GroupModel::getName))
                .collect(Collectors.collectingAndThen(
                        Collectors.toList(), Collections::unmodifiableList));
    }

getGroupsCount()

Long org.keycloak.models.jpa.JpaRealmProvider.getGroupsCount ( RealmModel  realm, Boolean  onlyTopGroups  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                        {
        String query = "getGroupCount";
        if(Objects.equals(onlyTopGroups, Boolean.TRUE)) {
            query = "getTopLevelGroupCount";
        }
        Long count = em.createNamedQuery(query, Long.class)
                .setParameter("realm", realm.getId())
                .getSingleResult();

        return count;
    }

getGroupsCountByNameContaining()

Long org.keycloak.models.jpa.JpaRealmProvider.getGroupsCountByNameContaining ( RealmModel  realm, String  search  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                {
        return (long) searchForGroupByName(realm, search, null, null).size();
    }

getMigrationModel()

MigrationModel org.keycloak.models.jpa.JpaRealmProvider.getMigrationModel ( )

inline

org.keycloak.models.RealmProviderを実装しています。

                                              {
        return new MigrationModelAdapter(em);
    }

getRealm()

RealmModel org.keycloak.models.jpa.JpaRealmProvider.getRealm ( String  id )

inline

org.keycloak.models.RealmProviderを実装しています。

                                          {
        RealmEntity realm = em.find(RealmEntity.class, id);
        if (realm == null) return null;
        RealmAdapter adapter = new RealmAdapter(session, em, realm);
        return adapter;
    }

getRealmByName()

RealmModel org.keycloak.models.jpa.JpaRealmProvider.getRealmByName ( String  name )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                  {
        TypedQuery<String> query = em.createNamedQuery("getRealmIdByName", String.class);
        query.setParameter("name", name);
        List<String> entities = query.getResultList();
        if (entities.isEmpty()) return null;
        if (entities.size() > 1) throw new IllegalStateException("Should not be more than one realm with same name");
        String id = query.getResultList().get(0);

        return session.realms().getRealm(id);
    }

getRealmRole()

RoleModel org.keycloak.models.jpa.JpaRealmProvider.getRealmRole ( RealmModel  realm, String  name  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                 {
        TypedQuery<String> query = em.createNamedQuery("getRealmRoleIdByName", String.class);
        query.setParameter("name", name);
        query.setParameter("realm", realm.getId());
        List<String> roles = query.getResultList();
        if (roles.isEmpty()) return null;
        return session.realms().getRoleById(roles.get(0), realm);
    }

getRealmRoles()

Set<RoleModel> org.keycloak.models.jpa.JpaRealmProvider.getRealmRoles ( RealmModel  realm )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                          {
        TypedQuery<String> query = em.createNamedQuery("getRealmRoleIds", String.class);
        query.setParameter("realm", realm.getId());
        List<String> roles = query.getResultList();

        if (roles.isEmpty()) return Collections.EMPTY_SET;
        Set<RoleModel> list = new HashSet<>();
        for (String id : roles) {
            list.add(session.realms().getRoleById(id, realm));
        }
        return Collections.unmodifiableSet(list);
    }

getRealms()

List<RealmModel> org.keycloak.models.jpa.JpaRealmProvider.getRealms ( )

inline

org.keycloak.models.RealmProviderを実装しています。

                                        {
        TypedQuery<String> query = em.createNamedQuery("getAllRealmIds", String.class);
        List<String> entities = query.getResultList();
        List<RealmModel> realms = new ArrayList<RealmModel>();
        for (String id : entities) {
            RealmModel realm = session.realms().getRealm(id);
            if (realm != null) realms.add(realm);

        }
        return realms;
    }

getRoleById()

RoleModel org.keycloak.models.jpa.JpaRealmProvider.getRoleById ( String  id, RealmModel  realm  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                              {
        RoleEntity entity = em.find(RoleEntity.class, id);
        if (entity == null) return null;
        if (!realm.getId().equals(entity.getRealmId())) return null;
        RoleAdapter adapter = new RoleAdapter(session, realm, em, entity);
        return adapter;
    }

getTopLevelGroups() [1/2]

List<GroupModel> org.keycloak.models.jpa.JpaRealmProvider.getTopLevelGroups ( RealmModel  realm )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                {
        RealmEntity ref = em.getReference(RealmEntity.class, realm.getId());

        return ref.getGroups().stream()
                .filter(g -> g.getParent() == null)
                .map(g -> session.realms().getGroupById(g.getId(), realm))
                .sorted(Comparator.comparing(GroupModel::getName))
                .collect(Collectors.collectingAndThen(
                        Collectors.toList(), Collections::unmodifiableList));
    }

getTopLevelGroups() [2/2]

List<GroupModel> org.keycloak.models.jpa.JpaRealmProvider.getTopLevelGroups ( RealmModel  realm, Integer  first, Integer  max  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                            {
        List<String> groupIds =  em.createNamedQuery("getTopLevelGroupIds", String.class)
                .setParameter("realm", realm.getId())
                .setFirstResult(first)
                    .setMaxResults(max)
                    .getResultList();
        List<GroupModel> list = new ArrayList<>();
        if(Objects.nonNull(groupIds) && !groupIds.isEmpty()) {
            for (String id : groupIds) {
                GroupModel group = getGroupById(id, realm);
                list.add(group);
            }
        }

        list.sort(Comparator.comparing(GroupModel::getName));

        return Collections.unmodifiableList(list);
    }

listClientInitialAccess()

List<ClientInitialAccessModel> org.keycloak.models.jpa.JpaRealmProvider.listClientInitialAccess ( RealmModel  realm )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                    {
        RealmEntity realmEntity = em.find(RealmEntity.class, realm.getId());

        TypedQuery<ClientInitialAccessEntity> query = em.createNamedQuery("findClientInitialAccessByRealm", ClientInitialAccessEntity.class);
        query.setParameter("realm", realmEntity);
        List<ClientInitialAccessEntity> entities = query.getResultList();

        return entities.stream()
                .map(this::entityToModel)
                .collect(Collectors.toList());
    }

moveGroup()

void org.keycloak.models.jpa.JpaRealmProvider.moveGroup ( RealmModel  realm, GroupModel  group, GroupModel  toParent  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                   {
        if (toParent != null && group.getId().equals(toParent.getId())) {
            return;
        }
        if (group.getParentId() != null) {
            group.getParent().removeChild(group);
        }
        group.setParent(toParent);
        if (toParent != null) toParent.addChild(group);
        else session.realms().addTopLevelGroup(realm, group);
    }

removeClient()

boolean org.keycloak.models.jpa.JpaRealmProvider.removeClient ( String  id, RealmModel  realm  )

inline

org.keycloak.models.ClientProviderを実装しています。

                                                             {
        final ClientModel client = getClientById(id, realm);
        if (client == null) return false;

        session.users().preRemove(realm, client);

        for (RoleModel role : client.getRoles()) {
            // No need to go through cache. Roles were already invalidated
            removeRole(realm, role);
        }

        ClientEntity clientEntity = ((ClientAdapter)client).getEntity();

        session.getKeycloakSessionFactory().publish(new RealmModel.ClientRemovedEvent() {
            @Override
            public ClientModel getClient() {
                return client;
            }

            @Override
            public KeycloakSession getKeycloakSession() {
                return session;
            }
        });

        int countRemoved = em.createNamedQuery("deleteClientScopeClientMappingByClient")
                .setParameter("client", clientEntity)
                .executeUpdate();
        em.remove(clientEntity);  // i have no idea why, but this needs to come before deleteScopeMapping

        try {
            em.flush();
        } catch (RuntimeException e) {
            logger.errorv("Unable to delete client entity: {0} from realm {1}", client.getClientId(), realm.getName());
            throw e;
        }

        return true;
    }

removeClientInitialAccessModel()

void org.keycloak.models.jpa.JpaRealmProvider.removeClientInitialAccessModel ( RealmModel  realm, String  id  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                            {
        ClientInitialAccessEntity entity = em.find(ClientInitialAccessEntity.class, id);
        if (entity != null) {
            em.remove(entity);
            em.flush();
        }
    }

removeExpiredClientInitialAccess()

void org.keycloak.models.jpa.JpaRealmProvider.removeExpiredClientInitialAccess ( )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                   {
        int currentTime = Time.currentTime();

        em.createNamedQuery("removeExpiredClientInitialAccess")
                .setParameter("currentTime", currentTime)
                .executeUpdate();
    }

removeGroup()

boolean org.keycloak.models.jpa.JpaRealmProvider.removeGroup ( RealmModel  realm, GroupModel  group  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                   {
        if (group == null) {
            return false;
        }

        GroupModel.GroupRemovedEvent event = new GroupModel.GroupRemovedEvent() {
            @Override
            public RealmModel getRealm() {
                return realm;
            }

            @Override
            public GroupModel getGroup() {
                return group;
            }

            @Override
            public KeycloakSession getKeycloakSession() {
                return session;
            }
        };
        session.getKeycloakSessionFactory().publish(event);

        session.users().preRemove(realm, group);

        realm.removeDefaultGroup(group);
        for (GroupModel subGroup : group.getSubGroups()) {
            session.realms().removeGroup(realm, subGroup);
        }
        GroupEntity groupEntity = em.find(GroupEntity.class, group.getId());
        if ((groupEntity == null) || (!groupEntity.getRealm().getId().equals(realm.getId()))) {
            return false;
        }
        em.createNamedQuery("deleteGroupRoleMappingsByGroup").setParameter("group", groupEntity).executeUpdate();

        RealmEntity realmEntity = em.getReference(RealmEntity.class, realm.getId());
        realmEntity.getGroups().remove(groupEntity);

        em.remove(groupEntity);
        return true;


    }

removeRealm()

boolean org.keycloak.models.jpa.JpaRealmProvider.removeRealm ( String  id )

inline

org.keycloak.models.RealmProviderを実装しています。

                                          {
        RealmEntity realm = em.find(RealmEntity.class, id);
        if (realm == null) {
            return false;
        }
        em.refresh(realm);
        final RealmAdapter adapter = new RealmAdapter(session, em, realm);
        session.users().preRemove(adapter);

        realm.getDefaultGroups().clear();
        em.flush();

        int num = em.createNamedQuery("deleteGroupRoleMappingsByRealm")
                .setParameter("realm", realm).executeUpdate();

        TypedQuery<String> query = em.createNamedQuery("getClientIdsByRealm", String.class);
        query.setParameter("realm", realm.getId());
        List<String> clients = query.getResultList();
        for (String client : clients) {
            // No need to go through cache. Clients were already invalidated
            removeClient(client, adapter);
        }

        num = em.createNamedQuery("deleteDefaultClientScopeRealmMappingByRealm")
                .setParameter("realm", realm).executeUpdate();

        for (ClientScopeEntity a : new LinkedList<>(realm.getClientScopes())) {
            adapter.removeClientScope(a.getId());
        }

        for (RoleModel role : adapter.getRoles()) {
            // No need to go through cache. Roles were already invalidated
            removeRole(adapter, role);
        }

        for (GroupModel group : adapter.getGroups()) {
            session.realms().removeGroup(adapter, group);
        }
        
        num = em.createNamedQuery("removeClientInitialAccessByRealm")
                .setParameter("realm", realm).executeUpdate();

        em.remove(realm);

        em.flush();
        em.clear();

        session.getKeycloakSessionFactory().publish(new RealmModel.RealmRemovedEvent() {
            @Override
            public RealmModel getRealm() {
                return adapter;
            }

            @Override
            public KeycloakSession getKeycloakSession() {
                return session;
            }
        });

        return true;
    }

removeRole()

boolean org.keycloak.models.jpa.JpaRealmProvider.removeRole ( RealmModel  realm, RoleModel  role  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                {
        session.users().preRemove(realm, role);
        RoleContainerModel container = role.getContainer();
        if (container.getDefaultRoles().contains(role.getName())) {
            container.removeDefaultRoles(role.getName());
        }
        RoleEntity roleEntity = em.getReference(RoleEntity.class, role.getId());
        String compositeRoleTable = JpaUtils.getTableNameForNativeQuery("COMPOSITE_ROLE", em);
        em.createNativeQuery("delete from " + compositeRoleTable + " where CHILD_ROLE = :role").setParameter("role", roleEntity).executeUpdate();
        realm.getClients().forEach(c -> c.deleteScopeMapping(role));
        em.createNamedQuery("deleteClientScopeRoleMappingByRole").setParameter("role", roleEntity).executeUpdate();
        int val = em.createNamedQuery("deleteGroupRoleMappingsByRole").setParameter("roleId", roleEntity.getId()).executeUpdate();

        em.flush();
        em.remove(roleEntity);

        session.getKeycloakSessionFactory().publish(new RoleContainerModel.RoleRemovedEvent() {
            @Override
            public RoleModel getRole() {
                return role;
            }

            @Override
            public KeycloakSession getKeycloakSession() {
                return session;
            }
        });

        em.flush();
        return true;

    }

searchForGroupByName()

List<GroupModel> org.keycloak.models.jpa.JpaRealmProvider.searchForGroupByName ( RealmModel  realm, String  search, Integer  first, Integer  max  )

inline

org.keycloak.models.RealmProviderを実装しています。

                                                                                                              {
        TypedQuery<String> query = em.createNamedQuery("getGroupIdsByNameContaining", String.class)
                .setParameter("realm", realm.getId())
                .setParameter("search", search);
        if(Objects.nonNull(first) && Objects.nonNull(max)) {
            query= query.setFirstResult(first).setMaxResults(max);
        }
        List<String> groups =  query.getResultList();
        if (Objects.isNull(groups)) return Collections.EMPTY_LIST;
        List<GroupModel> list = new ArrayList<>();
        for (String id : groups) {
            GroupModel groupById = session.realms().getGroupById(id, realm);
            while(Objects.nonNull(groupById.getParentId())) {
                groupById = session.realms().getGroupById(groupById.getParentId(), realm);
            }
            if(!list.contains(groupById)) {
                list.add(groupById);
            }
        }
        list.sort(Comparator.comparing(GroupModel::getName));

        return Collections.unmodifiableList(list);
    }

メンバ詳解

em

EntityManager org.keycloak.models.jpa.JpaRealmProvider.em

protected

logger

final Logger org.keycloak.models.jpa.JpaRealmProvider.logger = Logger.getLogger(JpaRealmProvider.class)

staticprotected

session

final KeycloakSession org.keycloak.models.jpa.JpaRealmProvider.session

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/jpa/JpaRealmProvider.java