IsmPolicyApi.java 文件源码

@Override
public PolicyEntity getPolicy(String policyId, String domainId) throws Exception {

    return this.txControl.supports(new Callable<PolicyEntity>() {

        @Override
        public PolicyEntity call() throws Exception {

            CriteriaBuilder criteriaBuilder = IsmPolicyApi.this.em.getCriteriaBuilder();
            CriteriaQuery<PolicyEntity> query = criteriaBuilder.createQuery(PolicyEntity.class);
            Root<PolicyEntity> r = query.from(PolicyEntity.class);
            query.select(r)
                    .where(criteriaBuilder.and(
                            criteriaBuilder.equal(r.get("domain").get("id"), Long.parseLong(domainId)),
                            criteriaBuilder.equal(r.get("id"), Long.parseLong(policyId))));
            List<PolicyEntity> result = IsmPolicyApi.this.em.createQuery(query).getResultList();
            if (result.isEmpty()) {
                throw new Exception("Policy or Domain Entity does not exists...");
                //TODO - Add 404 error response - Sudhir
            }
            return result.get(0);
        }
    });
}