org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository クラス

org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository の継承関係図

org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository 連携図

公開メンバ関数
Set< OAuth2AccessTokenEntity >	getAllAccessTokens ()
Set< OAuth2RefreshTokenEntity >	getAllRefreshTokens ()
OAuth2AccessTokenEntity	getAccessTokenByValue (String accessTokenValue)
OAuth2AccessTokenEntity	getAccessTokenById (Long id)
OAuth2AccessTokenEntity	saveAccessToken (OAuth2AccessTokenEntity token)
void	removeAccessToken (OAuth2AccessTokenEntity accessToken)
void	clearAccessTokensForRefreshToken (OAuth2RefreshTokenEntity refreshToken)
OAuth2RefreshTokenEntity	getRefreshTokenByValue (String refreshTokenValue)
OAuth2RefreshTokenEntity	getRefreshTokenById (Long id)
OAuth2RefreshTokenEntity	saveRefreshToken (OAuth2RefreshTokenEntity refreshToken)
void	removeRefreshToken (OAuth2RefreshTokenEntity refreshToken)
void	clearTokensForClient (ClientDetailsEntity client)
List< OAuth2AccessTokenEntity >	getAccessTokensForClient (ClientDetailsEntity client)
List< OAuth2RefreshTokenEntity >	getRefreshTokensForClient (ClientDetailsEntity client)
Set< OAuth2AccessTokenEntity >	getAllExpiredAccessTokens ()
Set< OAuth2AccessTokenEntity >	getAllExpiredAccessTokens (PageCriteria pageCriteria)
Set< OAuth2RefreshTokenEntity >	getAllExpiredRefreshTokens ()
Set< OAuth2RefreshTokenEntity >	getAllExpiredRefreshTokens (PageCriteria pageCriteria)
Set< OAuth2AccessTokenEntity >	getAccessTokensForResourceSet (ResourceSet rs)
void	clearDuplicateAccessTokens ()
void	clearDuplicateRefreshTokens ()
List< OAuth2AccessTokenEntity >	getAccessTokensForApprovedSite (ApprovedSite approvedSite)

非公開変数類
EntityManager	manager

静的非公開変数類
static final int	MAXEXPIREDRESULTS = 1000
static final Logger	logger = LoggerFactory.getLogger(JpaOAuth2TokenRepository.class)

詳解

関数詳解

clearAccessTokensForRefreshToken()

void org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.clearAccessTokensForRefreshToken ( OAuth2RefreshTokenEntity  refreshToken )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                            {
                TypedQuery<OAuth2AccessTokenEntity> query = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_BY_REFRESH_TOKEN, OAuth2AccessTokenEntity.class);
                query.setParameter(OAuth2AccessTokenEntity.PARAM_REFERSH_TOKEN, refreshToken);
                List<OAuth2AccessTokenEntity> accessTokens = query.getResultList();
                for (OAuth2AccessTokenEntity accessToken : accessTokens) {
                        removeAccessToken(accessToken);
                }
        }

clearDuplicateAccessTokens()

void org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.clearDuplicateAccessTokens ( )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                 {

                Query query = manager.createQuery("select a.jwt, count(1) as c from OAuth2AccessTokenEntity a GROUP BY a.jwt HAVING count(1) > 1");
                @SuppressWarnings("unchecked")
                List<Object[]> resultList = query.getResultList();
                List<JWT> values = new ArrayList<>();
                for (Object[] r : resultList) {
                        logger.warn("Found duplicate access tokens: {}, {}", ((JWT)r[0]).serialize(), r[1]);
                        values.add((JWT) r[0]);
                }
                if (values.size() > 0) {
                        CriteriaBuilder cb = manager.getCriteriaBuilder();
                        CriteriaDelete<OAuth2AccessTokenEntity> criteriaDelete = cb.createCriteriaDelete(OAuth2AccessTokenEntity.class);
                        Root<OAuth2AccessTokenEntity> root = criteriaDelete.from(OAuth2AccessTokenEntity.class);
                        criteriaDelete.where(root.get("jwt").in(values));
                        int result = manager.createQuery(criteriaDelete).executeUpdate();
                        logger.warn("Deleted {} duplicate access tokens", result);
                }
        }

clearDuplicateRefreshTokens()

void org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.clearDuplicateRefreshTokens ( )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                  {
                Query query = manager.createQuery("select a.jwt, count(1) as c from OAuth2RefreshTokenEntity a GROUP BY a.jwt HAVING count(1) > 1");
                @SuppressWarnings("unchecked")
                List<Object[]> resultList = query.getResultList();
                List<JWT> values = new ArrayList<>();
                for (Object[] r : resultList) {
                        logger.warn("Found duplicate refresh tokens: {}, {}", ((JWT)r[0]).serialize(), r[1]);
                        values.add((JWT) r[0]);
                }
                if (values.size() > 0) {
                        CriteriaBuilder cb = manager.getCriteriaBuilder();
                        CriteriaDelete<OAuth2RefreshTokenEntity> criteriaDelete = cb.createCriteriaDelete(OAuth2RefreshTokenEntity.class);
                        Root<OAuth2RefreshTokenEntity> root = criteriaDelete.from(OAuth2RefreshTokenEntity.class);
                        criteriaDelete.where(root.get("jwt").in(values));
                        int result = manager.createQuery(criteriaDelete).executeUpdate();
                        logger.warn("Deleted {} duplicate refresh tokens", result);
                }

        }

clearTokensForClient()

void org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.clearTokensForClient ( ClientDetailsEntity  client )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                     {
                TypedQuery<OAuth2AccessTokenEntity> queryA = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_BY_CLIENT, OAuth2AccessTokenEntity.class);
                queryA.setParameter(OAuth2AccessTokenEntity.PARAM_CLIENT, client);
                List<OAuth2AccessTokenEntity> accessTokens = queryA.getResultList();
                for (OAuth2AccessTokenEntity accessToken : accessTokens) {
                        removeAccessToken(accessToken);
                }
                TypedQuery<OAuth2RefreshTokenEntity> queryR = manager.createNamedQuery(OAuth2RefreshTokenEntity.QUERY_BY_CLIENT, OAuth2RefreshTokenEntity.class);
                queryR.setParameter(OAuth2RefreshTokenEntity.PARAM_CLIENT, client);
                List<OAuth2RefreshTokenEntity> refreshTokens = queryR.getResultList();
                for (OAuth2RefreshTokenEntity refreshToken : refreshTokens) {
                        removeRefreshToken(refreshToken);
                }
        }

getAccessTokenById()

OAuth2AccessTokenEntity org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAccessTokenById ( Long  id )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                   {
                return manager.find(OAuth2AccessTokenEntity.class, id);
        }

getAccessTokenByValue()

OAuth2AccessTokenEntity org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAccessTokenByValue ( String  accessTokenValue )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                      {
                try {
                        JWT jwt = JWTParser.parse(accessTokenValue);
                        TypedQuery<OAuth2AccessTokenEntity> query = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_BY_TOKEN_VALUE, OAuth2AccessTokenEntity.class);
                        query.setParameter(OAuth2AccessTokenEntity.PARAM_TOKEN_VALUE, jwt);
                        return JpaUtil.getSingleResult(query.getResultList());
                } catch (ParseException e) {
                        return null;
                }
        }

getAccessTokensForApprovedSite()

List<OAuth2AccessTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAccessTokensForApprovedSite ( ApprovedSite  approvedSite )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                                       {
                TypedQuery<OAuth2AccessTokenEntity> queryA = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_BY_APPROVED_SITE, OAuth2AccessTokenEntity.class);
                queryA.setParameter(OAuth2AccessTokenEntity.PARAM_APPROVED_SITE, approvedSite);
                List<OAuth2AccessTokenEntity> accessTokens = queryA.getResultList();
                return accessTokens;
        }

getAccessTokensForClient()

List<OAuth2AccessTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAccessTokensForClient ( ClientDetailsEntity  client )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                                  {
                TypedQuery<OAuth2AccessTokenEntity> queryA = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_BY_CLIENT, OAuth2AccessTokenEntity.class);
                queryA.setParameter(OAuth2AccessTokenEntity.PARAM_CLIENT, client);
                List<OAuth2AccessTokenEntity> accessTokens = queryA.getResultList();
                return accessTokens;
        }

getAccessTokensForResourceSet()

Set<OAuth2AccessTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAccessTokensForResourceSet ( ResourceSet  rs )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                          {
                TypedQuery<OAuth2AccessTokenEntity> query = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_BY_RESOURCE_SET, OAuth2AccessTokenEntity.class);
                query.setParameter(OAuth2AccessTokenEntity.PARAM_RESOURCE_SET_ID, rs.getId());
                return new LinkedHashSet<>(query.getResultList());
        }

getAllAccessTokens()

Set<OAuth2AccessTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAllAccessTokens ( )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                 {
                TypedQuery<OAuth2AccessTokenEntity> query = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_ALL, OAuth2AccessTokenEntity.class);
                return new LinkedHashSet<>(query.getResultList());
        }

getAllExpiredAccessTokens() [1/2]

Set<OAuth2AccessTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAllExpiredAccessTokens ( )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                        {
                DefaultPageCriteria pageCriteria = new DefaultPageCriteria(0, MAXEXPIREDRESULTS);
                return getAllExpiredAccessTokens(pageCriteria);
        }

getAllExpiredAccessTokens() [2/2]

Set<OAuth2AccessTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAllExpiredAccessTokens ( PageCriteria  pageCriteria )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                                 {
                TypedQuery<OAuth2AccessTokenEntity> query = manager.createNamedQuery(OAuth2AccessTokenEntity.QUERY_EXPIRED_BY_DATE, OAuth2AccessTokenEntity.class);
                query.setParameter(OAuth2AccessTokenEntity.PARAM_DATE, new Date());
                return new LinkedHashSet<>(JpaUtil.getResultPage(query, pageCriteria));
        }

getAllExpiredRefreshTokens() [1/2]

Set<OAuth2RefreshTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAllExpiredRefreshTokens ( )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                          {
                DefaultPageCriteria pageCriteria = new DefaultPageCriteria(0, MAXEXPIREDRESULTS);
                return getAllExpiredRefreshTokens(pageCriteria);
        }

getAllExpiredRefreshTokens() [2/2]

Set<OAuth2RefreshTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAllExpiredRefreshTokens ( PageCriteria  pageCriteria )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                                   {
                TypedQuery<OAuth2RefreshTokenEntity> query = manager.createNamedQuery(OAuth2RefreshTokenEntity.QUERY_EXPIRED_BY_DATE, OAuth2RefreshTokenEntity.class);
                query.setParameter(OAuth2AccessTokenEntity.PARAM_DATE, new Date());
                return new LinkedHashSet<>(JpaUtil.getResultPage(query,pageCriteria));
        }

getAllRefreshTokens()

Set<OAuth2RefreshTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getAllRefreshTokens ( )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                   {
                TypedQuery<OAuth2RefreshTokenEntity> query = manager.createNamedQuery(OAuth2RefreshTokenEntity.QUERY_ALL, OAuth2RefreshTokenEntity.class);
                return new LinkedHashSet<>(query.getResultList());
        }

getRefreshTokenById()

OAuth2RefreshTokenEntity org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getRefreshTokenById ( Long  id )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                     {
                return manager.find(OAuth2RefreshTokenEntity.class, id);
        }

getRefreshTokenByValue()

OAuth2RefreshTokenEntity org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getRefreshTokenByValue ( String  refreshTokenValue )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                         {
                try {
                        JWT jwt = JWTParser.parse(refreshTokenValue);
                        TypedQuery<OAuth2RefreshTokenEntity> query = manager.createNamedQuery(OAuth2RefreshTokenEntity.QUERY_BY_TOKEN_VALUE, OAuth2RefreshTokenEntity.class);
                        query.setParameter(OAuth2RefreshTokenEntity.PARAM_TOKEN_VALUE, jwt);
                        return JpaUtil.getSingleResult(query.getResultList());
                } catch (ParseException e) {
                        return null;
                }
        }

getRefreshTokensForClient()

List<OAuth2RefreshTokenEntity> org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.getRefreshTokensForClient ( ClientDetailsEntity  client )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                                    {
                TypedQuery<OAuth2RefreshTokenEntity> queryR = manager.createNamedQuery(OAuth2RefreshTokenEntity.QUERY_BY_CLIENT, OAuth2RefreshTokenEntity.class);
                queryR.setParameter(OAuth2RefreshTokenEntity.PARAM_CLIENT, client);
                List<OAuth2RefreshTokenEntity> refreshTokens = queryR.getResultList();
                return refreshTokens;
        }

removeAccessToken()

void org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.removeAccessToken ( OAuth2AccessTokenEntity  accessToken )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                           {
                OAuth2AccessTokenEntity found = getAccessTokenById(accessToken.getId());
                if (found != null) {
                        manager.remove(found);
                } else {
                        throw new IllegalArgumentException("Access token not found: " + accessToken);
                }
        }

removeRefreshToken()

void org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.removeRefreshToken ( OAuth2RefreshTokenEntity  refreshToken )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                              {
                OAuth2RefreshTokenEntity found = getRefreshTokenById(refreshToken.getId());
                if (found != null) {
                        manager.remove(found);
                } else {
                        throw new IllegalArgumentException("Refresh token not found: " + refreshToken);
                }
        }

saveAccessToken()

OAuth2AccessTokenEntity org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.saveAccessToken ( OAuth2AccessTokenEntity  token )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                      {
                return JpaUtil.saveOrUpdate(token.getId(), manager, token);
        }

saveRefreshToken()

OAuth2RefreshTokenEntity org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.saveRefreshToken ( OAuth2RefreshTokenEntity  refreshToken )

inline

org.mitre.oauth2.repository.OAuth2TokenRepositoryを実装しています。

                                                                                                {
                return JpaUtil.saveOrUpdate(refreshToken.getId(), manager, refreshToken);
        }

メンバ詳解

logger

final Logger org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.logger = LoggerFactory.getLogger(JpaOAuth2TokenRepository.class)

staticprivate

manager

EntityManager org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.manager

private

MAXEXPIREDRESULTS

final int org.mitre.oauth2.repository.impl.JpaOAuth2TokenRepository.MAXEXPIREDRESULTS = 1000

staticprivate

---

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

• D:/AppData/OpenId/mitreid-connect/src/openid-connect-server/src/main/java/org/mitre/oauth2/repository/impl/JpaOAuth2TokenRepository.java