org.keycloak.authorization.jpa.store.JPAResourceStore クラス

org.keycloak.authorization.jpa.store.JPAResourceStore の継承関係図

org.keycloak.authorization.jpa.store.JPAResourceStore 連携図

公開メンバ関数
	JPAResourceStore (EntityManager entityManager, AuthorizationProvider provider)
Resource	create (String name, ResourceServer resourceServer, String owner)
Resource	create (String id, String name, ResourceServer resourceServer, String owner)
void	delete (String id)
Resource	findById (String id, String resourceServerId)
List< Resource >	findByOwner (String ownerId, String resourceServerId)
void	findByOwner (String ownerId, String resourceServerId, Consumer< Resource > consumer)
List< Resource >	findByUri (String uri, String resourceServerId)
List< Resource >	findByResourceServer (String resourceServerId)
List< Resource >	findByResourceServer (Map< String, String[]> attributes, String resourceServerId, int firstResult, int maxResult)
List< Resource >	findByScope (List< String > scopes, String resourceServerId)
void	findByScope (List< String > scopes, String resourceServerId, Consumer< Resource > consumer)
Resource	findByName (String name, String resourceServerId)
Resource	findByName (String name, String ownerId, String resourceServerId)
List< Resource >	findByType (String type, String resourceServerId)
void	findByType (String type, String resourceServerId, Consumer< Resource > consumer)

非公開変数類
final EntityManager	entityManager
final AuthorizationProvider	provider

詳解

著者

Pedro Igor

構築子と解体子

JPAResourceStore()

org.keycloak.authorization.jpa.store.JPAResourceStore.JPAResourceStore ( EntityManager  entityManager, AuthorizationProvider  provider  )

inline

                                                                                         {
        this.entityManager = entityManager;
        this.provider = provider;
    }

関数詳解

create() [1/2]

Resource org.keycloak.authorization.jpa.store.JPAResourceStore.create ( String  name, ResourceServer  resourceServer, String  owner  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                     {
        return create(null, name, resourceServer, owner);
    }

create() [2/2]

Resource org.keycloak.authorization.jpa.store.JPAResourceStore.create ( String  id, String  name, ResourceServer  resourceServer, String  owner  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                {
        ResourceEntity entity = new ResourceEntity();

        if (id == null) {
            entity.setId(KeycloakModelUtils.generateId());
        } else {
            entity.setId(id);
        }

        entity.setName(name);
        entity.setResourceServer(ResourceServerAdapter.toEntity(entityManager, resourceServer));
        entity.setOwner(owner);

        this.entityManager.persist(entity);
        this.entityManager.flush();

        return new ResourceAdapter(entity, entityManager, provider.getStoreFactory());
    }

delete()

void org.keycloak.authorization.jpa.store.JPAResourceStore.delete ( String  id )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                  {
        ResourceEntity resource = entityManager.getReference(ResourceEntity.class, id);
        if (resource == null) return;

        resource.getScopes().clear();
        this.entityManager.remove(resource);
    }

findById()

Resource org.keycloak.authorization.jpa.store.JPAResourceStore.findById ( String  id, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                 {
        if (id == null) {
            return null;
        }

        ResourceEntity entity = entityManager.find(ResourceEntity.class, id);
        if (entity == null) return null;
        return new ResourceAdapter(entity, entityManager, provider.getStoreFactory());
    }

findByName() [1/2]

Resource org.keycloak.authorization.jpa.store.JPAResourceStore.findByName ( String  name, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                     {
        return findByName(name, resourceServerId, resourceServerId);
    }

findByName() [2/2]

Resource org.keycloak.authorization.jpa.store.JPAResourceStore.findByName ( String  name, String  ownerId, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                     {
        TypedQuery<String> query = entityManager.createNamedQuery("findResourceIdByName", String.class);

        query.setFlushMode(FlushModeType.COMMIT);
        query.setParameter("serverId", resourceServerId);
        query.setParameter("name", name);
        query.setParameter("ownerId", ownerId);

        try {
            String id = query.getSingleResult();
            return provider.getStoreFactory().getResourceStore().findById(id, resourceServerId);
        } catch (NoResultException ex) {
            return null;
        }
    }

findByOwner() [1/2]

List<Resource> org.keycloak.authorization.jpa.store.JPAResourceStore.findByOwner ( String  ownerId, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                               {
        List<Resource> list = new LinkedList<>();

        findByOwner(ownerId, resourceServerId, list::add);

        return list;
    }

findByOwner() [2/2]

void org.keycloak.authorization.jpa.store.JPAResourceStore.findByOwner ( String  ownerId, String  resourceServerId, Consumer< Resource >  consumer  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                  {
        String queryName = "findResourceIdByOwner";

        if (resourceServerId == null) {
            queryName = "findAnyResourceIdByOwner";
        }

        TypedQuery<String> query = entityManager.createNamedQuery(queryName, String.class);

        query.setFlushMode(FlushModeType.COMMIT);
        query.setParameter("owner", ownerId);

        if (resourceServerId != null) {
            query.setParameter("serverId", resourceServerId);
        }

        ResourceStore resourceStore = provider.getStoreFactory().getResourceStore();

        query.getResultList().stream()
                .map(id -> resourceStore.findById(id, resourceServerId))
                .filter(Objects::nonNull)
                .forEach(consumer);
    }

findByResourceServer() [1/2]

List<Resource> org.keycloak.authorization.jpa.store.JPAResourceStore.findByResourceServer ( String  resourceServerId )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                        {
        TypedQuery<String> query = entityManager.createNamedQuery("findResourceIdByServerId", String.class);

        query.setParameter("serverId", resourceServerId);

        List<String> result = query.getResultList();
        List<Resource> list = new LinkedList<>();
        ResourceStore resourceStore = provider.getStoreFactory().getResourceStore();

        for (String id : result) {
            Resource resource = resourceStore.findById(id, resourceServerId);

            if (resource != null) {
                list.add(resource);
            }
        }

        return list;
    }

findByResourceServer() [2/2]

List<Resource> org.keycloak.authorization.jpa.store.JPAResourceStore.findByResourceServer ( Map< String, String[]>  attributes, String  resourceServerId, int  firstResult, int  maxResult  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                                                          {
        CriteriaBuilder builder = entityManager.getCriteriaBuilder();
        CriteriaQuery<ResourceEntity> querybuilder = builder.createQuery(ResourceEntity.class);
        Root<ResourceEntity> root = querybuilder.from(ResourceEntity.class);
        querybuilder.select(root.get("id"));
        List<Predicate> predicates = new ArrayList();

        if (resourceServerId != null) {
            predicates.add(builder.equal(root.get("resourceServer").get("id"), resourceServerId));
        }

        attributes.forEach((name, value) -> {
            if ("id".equals(name)) {
                predicates.add(root.get(name).in(value));
            } else if ("scope".equals(name)) {
                predicates.add(root.join("scopes").get("id").in(value));
            } else if ("ownerManagedAccess".equals(name)) {
                predicates.add(builder.equal(root.get(name), Boolean.valueOf(value[0])));
            } else if ("uri".equals(name)) {
                predicates.add(builder.lower(root.join("uris")).in(value[0].toLowerCase()));
            } else if ("uri_not_null".equals(name)) {
                // predicates.add(builder.isNotEmpty(root.get("uris"))); looks like there is a bug in hibernate and this line doesn't work: https://hibernate.atlassian.net/browse/HHH-6686
                // Workaround
                Expression<Integer> urisSize = builder.size(root.get("uris"));
                predicates.add(builder.notEqual(urisSize, 0));
            } else if ("owner".equals(name)) {
                predicates.add(root.get(name).in(value));
            } else {
                predicates.add(builder.like(builder.lower(root.get(name)), "%" + value[0].toLowerCase() + "%"));
            }
        });

        querybuilder.where(predicates.toArray(new Predicate[predicates.size()])).orderBy(builder.asc(root.get("name")));

        Query query = entityManager.createQuery(querybuilder);

        if (firstResult != -1) {
            query.setFirstResult(firstResult);
        }
        if (maxResult != -1) {
            query.setMaxResults(maxResult);
        }

        List<String> result = query.getResultList();
        List<Resource> list = new LinkedList<>();
        ResourceStore resourceStore = provider.getStoreFactory().getResourceStore();

        for (String id : result) {
            Resource resource = resourceStore.findById(id, resourceServerId);

            if (resource != null) {
                list.add(resource);
            }
        }

        return list;
    }

findByScope() [1/2]

List<Resource> org.keycloak.authorization.jpa.store.JPAResourceStore.findByScope ( List< String >  scopes, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                    {
        List<Resource> result = new ArrayList<>();

        findByScope(scopes, resourceServerId, result::add);

        return result;
    }

findByScope() [2/2]

void org.keycloak.authorization.jpa.store.JPAResourceStore.findByScope ( List< String >  scopes, String  resourceServerId, Consumer< Resource >  consumer  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                                       {
        TypedQuery<String> query = entityManager.createNamedQuery("findResourceIdByScope", String.class);

        query.setFlushMode(FlushModeType.COMMIT);
        query.setParameter("scopeIds", scopes);
        query.setParameter("serverId", resourceServerId);

        ResourceStore resourceStore = provider.getStoreFactory().getResourceStore();

        query.getResultList().stream()
                .map(id -> resourceStore.findById(id, resourceServerId))
                .filter(Objects::nonNull)
                .forEach(consumer);
    }

findByType() [1/2]

List<Resource> org.keycloak.authorization.jpa.store.JPAResourceStore.findByType ( String  type, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                           {
        List<Resource> list = new LinkedList<>();

        findByType(type, resourceServerId, list::add);

        return list;
    }

findByType() [2/2]

void org.keycloak.authorization.jpa.store.JPAResourceStore.findByType ( String  type, String  resourceServerId, Consumer< Resource >  consumer  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                                              {
        TypedQuery<String> query = entityManager.createNamedQuery("findResourceIdByType", String.class);

        query.setFlushMode(FlushModeType.COMMIT);
        query.setParameter("type", type);
        query.setParameter("ownerId", resourceServerId);
        query.setParameter("serverId", resourceServerId);

        ResourceStore resourceStore = provider.getStoreFactory().getResourceStore();

        query.getResultList().stream()
                .map(id -> resourceStore.findById(id, resourceServerId))
                .filter(Objects::nonNull)
                .forEach(consumer);
    }

findByUri()

List<Resource> org.keycloak.authorization.jpa.store.JPAResourceStore.findByUri ( String  uri, String  resourceServerId  )

inline

org.keycloak.authorization.store.ResourceStoreを実装しています。

                                                                         {
        TypedQuery<String> query = entityManager.createNamedQuery("findResourceIdByUri", String.class);

        query.setFlushMode(FlushModeType.COMMIT);
        query.setParameter("uri", uri);
        query.setParameter("serverId", resourceServerId);

        List<String> result = query.getResultList();
        List<Resource> list = new LinkedList<>();
        ResourceStore resourceStore = provider.getStoreFactory().getResourceStore();

        for (String id : result) {
            Resource resource = resourceStore.findById(id, resourceServerId);

            if (resource != null) {
                list.add(resource);
            }
        }

        return list;
    }

メンバ詳解

entityManager

final EntityManager org.keycloak.authorization.jpa.store.JPAResourceStore.entityManager

private

provider

final AuthorizationProvider org.keycloak.authorization.jpa.store.JPAResourceStore.provider

private

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/authorization/jpa/store/JPAResourceStore.java