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

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

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

公開メンバ関数
	JPAPolicyStore (EntityManager entityManager, AuthorizationProvider provider)
Policy	create (AbstractPolicyRepresentation representation, ResourceServer resourceServer)
void	delete (String id)
Policy	findById (String id, String resourceServerId)
Policy	findByName (String name, String resourceServerId)
List< Policy >	findByResourceServer (final String resourceServerId)
List< Policy >	findByResourceServer (Map< String, String[]> attributes, String resourceServerId, int firstResult, int maxResult)
List< Policy >	findByResource (final String resourceId, String resourceServerId)
void	findByResource (String resourceId, String resourceServerId, Consumer< Policy > consumer)
List< Policy >	findByResourceType (final String resourceType, String resourceServerId)
void	findByResourceType (String resourceType, String resourceServerId, Consumer< Policy > consumer)
List< Policy >	findByScopeIds (List< String > scopeIds, String resourceServerId)
List< Policy >	findByScopeIds (List< String > scopeIds, String resourceId, String resourceServerId)
void	findByScopeIds (List< String > scopeIds, String resourceId, String resourceServerId, Consumer< Policy > consumer)
List< Policy >	findByType (String type, String resourceServerId)
List< Policy >	findDependentPolicies (String policyId, String resourceServerId)

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

詳解

著者

Pedro Igor

構築子と解体子

JPAPolicyStore()

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

inline

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

関数詳解

create()

Policy org.keycloak.authorization.jpa.store.JPAPolicyStore.create ( AbstractPolicyRepresentation  representation, ResourceServer  resourceServer  )

inline

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

                                                                                                     {
        PolicyEntity entity = new PolicyEntity();

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

        entity.setType(representation.getType());
        entity.setName(representation.getName());
        entity.setResourceServer(ResourceServerAdapter.toEntity(entityManager, resourceServer));

        this.entityManager.persist(entity);
        this.entityManager.flush();
        Policy model = new PolicyAdapter(entity, entityManager, provider.getStoreFactory());
        return model;
    }

delete()

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

inline

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

                                  {
        PolicyEntity policy = entityManager.find(PolicyEntity.class, id);
        if (policy != null) {
            this.entityManager.remove(policy);
        }
    }

findById()

Policy org.keycloak.authorization.jpa.store.JPAPolicyStore.findById ( String  id, String  resourceServerId  )

inline

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

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

        PolicyEntity entity = entityManager.find(PolicyEntity.class, id);
        if (entity == null) return null;

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

findByName()

Policy org.keycloak.authorization.jpa.store.JPAPolicyStore.findByName ( String  name, String  resourceServerId  )

inline

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

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

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

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

findByResource() [1/2]

List<Policy> org.keycloak.authorization.jpa.store.JPAPolicyStore.findByResource ( final String  resourceId, String  resourceServerId  )

inline

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

                                                                                         {
        List<Policy> result = new LinkedList<>();

        findByResource(resourceId, resourceServerId, result::add);

        return result;
    }

findByResource() [2/2]

void org.keycloak.authorization.jpa.store.JPAPolicyStore.findByResource ( String  resourceId, String  resourceServerId, Consumer< Policy >  consumer  )

inline

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

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

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

        PolicyStore policyStore = provider.getStoreFactory().getPolicyStore();

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

findByResourceServer() [1/2]

List<Policy> org.keycloak.authorization.jpa.store.JPAPolicyStore.findByResourceServer ( final String  resourceServerId )

inline

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

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

        query.setParameter("serverId", resourceServerId);

        List<String> result = query.getResultList();
        List<Policy> list = new LinkedList<>();
        for (String id : result) {
            Policy policy = provider.getStoreFactory().getPolicyStore().findById(id, resourceServerId);
            if (Objects.nonNull(policy)) {
                list.add(policy);
            }
        }
        return list;
    }

findByResourceServer() [2/2]

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

inline

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

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

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

        attributes.forEach((name, value) -> {
            if ("permission".equals(name)) {
                if (Boolean.valueOf(value[0])) {
                    predicates.add(root.get("type").in("resource", "scope", "uma"));
                } else {
                    predicates.add(builder.not(root.get("type").in("resource", "scope", "uma")));
                }
            } else if ("id".equals(name)) {
                predicates.add(root.get(name).in(value));
            } else if ("owner".equals(name)) {
                predicates.add(root.get(name).in(value));
            } else if ("owner_is_not_null".equals(name)) {
                predicates.add(builder.isNotNull(root.get("owner")));
            } else if ("resource".equals(name)) {
                predicates.add(root.join("resources").get("id").in(value));
            } else if ("scope".equals(name)) {
                predicates.add(root.join("scopes").get("id").in(value));
            } else if (name.startsWith("config:")) {
                predicates.add(root.joinMap("config").key().in(name.substring("config:".length())));
                predicates.add(builder.like(root.joinMap("config").value().as(String.class), "%" + value[0] + "%"));
            } else {
                predicates.add(builder.like(builder.lower(root.get(name)), "%" + value[0].toLowerCase() + "%"));
            }
        });

        if (!attributes.containsKey("owner") && !attributes.containsKey("owner_is_not_null")) {
            predicates.add(builder.isNull(root.get("owner")));
        }

        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<Policy> list = new LinkedList<>();
        for (String id : result) {
            Policy policy = provider.getStoreFactory().getPolicyStore().findById(id, resourceServerId);
            if (Objects.nonNull(policy)) {
                list.add(policy);
            }
        }
        return list;
    }

findByResourceType() [1/2]

List<Policy> org.keycloak.authorization.jpa.store.JPAPolicyStore.findByResourceType ( final String  resourceType, String  resourceServerId  )

inline

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

                                                                                               {
        List<Policy> result = new LinkedList<>();

        findByResourceType(resourceType, resourceServerId, result::add);

        return result;
    }

findByResourceType() [2/2]

void org.keycloak.authorization.jpa.store.JPAPolicyStore.findByResourceType ( String  resourceType, String  resourceServerId, Consumer< Policy >  consumer  )

inline

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

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

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

        PolicyStore policyStore = provider.getStoreFactory().getPolicyStore();

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

findByScopeIds() [1/3]

List<Policy> org.keycloak.authorization.jpa.store.JPAPolicyStore.findByScopeIds ( List< String >  scopeIds, String  resourceServerId  )

inline

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

                                                                                       {
        if (scopeIds==null || scopeIds.isEmpty()) {
            return Collections.emptyList();
        }

        // Use separate subquery to handle DB2 and MSSSQL
        TypedQuery<String> query = entityManager.createNamedQuery("findPolicyIdByScope", String.class);

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

        List<String> result = query.getResultList();
        List<Policy> list = new LinkedList<>();
        for (String id : result) {
            Policy policy = provider.getStoreFactory().getPolicyStore().findById(id, resourceServerId);
            if (Objects.nonNull(policy)) {
                list.add(policy);
            }
        }
        return list;
    }

findByScopeIds() [2/3]

List<Policy> org.keycloak.authorization.jpa.store.JPAPolicyStore.findByScopeIds ( List< String >  scopeIds, String  resourceId, String  resourceServerId  )

inline

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

                                                                                                          {
        List<Policy> result = new LinkedList<>();

        findByScopeIds(scopeIds, resourceId, resourceServerId, result::add);

        return result;
    }

findByScopeIds() [3/3]

void org.keycloak.authorization.jpa.store.JPAPolicyStore.findByScopeIds ( List< String >  scopeIds, String  resourceId, String  resourceServerId, Consumer< Policy >  consumer  )

inline

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

                                                                                                                             {
        // Use separate subquery to handle DB2 and MSSSQL
        TypedQuery<String> query;

        if (resourceId == null) {
            query = entityManager.createNamedQuery("findPolicyIdByNullResourceScope", String.class);
        } else {
            query = entityManager.createNamedQuery("findPolicyIdByResourceScope", String.class);
            query.setParameter("resourceId", resourceId);
        }

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

        PolicyStore policyStore = provider.getStoreFactory().getPolicyStore();

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

findByType()

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

inline

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

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

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

        List<String> result = query.getResultList();
        List<Policy> list = new LinkedList<>();
        for (String id : result) {
            Policy policy = provider.getStoreFactory().getPolicyStore().findById(id, resourceServerId);
            if (Objects.nonNull(policy)) {
                list.add(policy);
            }
        }
        return list;
    }

findDependentPolicies()

List<Policy> org.keycloak.authorization.jpa.store.JPAPolicyStore.findDependentPolicies ( String  policyId, String  resourceServerId  )

inline

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

                                                                                        {

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

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

        List<String> result = query.getResultList();
        List<Policy> list = new LinkedList<>();
        for (String id : result) {
            Policy policy = provider.getStoreFactory().getPolicyStore().findById(id, resourceServerId);
            if (Objects.nonNull(policy)) {
                list.add(policy);
            }
        }
        return list;
    }

メンバ詳解

entityManager

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

private

provider

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

private

---

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

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