类javax.persistence.TypedQuery源码实例Demo

下面列出了怎么用javax.persistence.TypedQuery的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: zstack   文件: SecurityGroupManagerImpl.java
@Transactional
private List<SecurityGroupFailureHostVO> takeFailureHosts() {
    String sql = "select sgf from SecurityGroupFailureHostVO sgf, HostVO host where host.uuid = sgf.hostUuid and host.status = :hostConnectionState and sgf.managementNodeId is NULL group by sgf.hostUuid order by sgf.lastOpDate ASC";
    TypedQuery<SecurityGroupFailureHostVO> q = dbf.getEntityManager().createQuery(sql, SecurityGroupFailureHostVO.class);
    q.setLockMode(LockModeType.PESSIMISTIC_READ);
    q.setParameter("hostConnectionState", HostStatus.Connected);
    q.setMaxResults(failureHostEachTimeTake);
    List<SecurityGroupFailureHostVO> lst = q.getResultList();
    if (lst.isEmpty()) {
        return lst;
    }

    List<Long> ids = CollectionUtils.transformToList(lst, new Function<Long, SecurityGroupFailureHostVO>() {
        @Override
        public Long call(SecurityGroupFailureHostVO arg) {
            return arg.getId();
        }
    });

    sql = "update SecurityGroupFailureHostVO f set f.managementNodeId = :mgmtId where f.id in (:ids)";
    Query uq = dbf.getEntityManager().createQuery(sql);
    uq.setParameter("mgmtId", Platform.getManagementServerId());
    uq.setParameter("ids", ids);
    uq.executeUpdate();
    return lst;
}
 
源代码2 项目: monolith   文件: TicketPriceEndpoint.java
@GET
@Produces("application/json")
public List<TicketPriceDTO> listAll(@QueryParam("start") Integer startPosition, @QueryParam("max") Integer maxResult)
{
   TypedQuery<TicketPrice> findAllQuery = em.createQuery("SELECT DISTINCT t FROM TicketPrice t LEFT JOIN FETCH t.show LEFT JOIN FETCH t.section LEFT JOIN FETCH t.ticketCategory ORDER BY t.id", TicketPrice.class);
   if (startPosition != null)
   {
      findAllQuery.setFirstResult(startPosition);
   }
   if (maxResult != null)
   {
      findAllQuery.setMaxResults(maxResult);
   }
   final List<TicketPrice> searchResults = findAllQuery.getResultList();
   final List<TicketPriceDTO> results = new ArrayList<TicketPriceDTO>();
   for (TicketPrice searchResult : searchResults)
   {
      TicketPriceDTO dto = new TicketPriceDTO(searchResult);
      results.add(dto);
   }
   return results;
}
 
源代码3 项目: TeaStore   文件: OrderItemRepository.java
/**
 * Gets all order items for the given productId.
 * @param productId The id of the product ordered.
 * @param start The index of the first orderItem to return. Negative value to start at the beginning.
 * @param limit The maximum number of orderItem to return. Negative value to return all.
 * @return List of order items with the specified product.
 */
public List<PersistenceOrderItem> getAllEntitiesWithProduct(long productId, int start, int limit) {
	List<PersistenceOrderItem> entities = null;
	EntityManager em = getEM();
    try {
        em.getTransaction().begin();
        PersistenceProduct prod = em.find(PersistenceProduct.class, productId);
        if (prod != null) {
        	TypedQuery<PersistenceOrderItem> allMatchesQuery =
        			em.createQuery("SELECT u FROM " + getEntityClass().getName()
        					+ " u WHERE u.product = :prod", getEntityClass());
        	allMatchesQuery.setParameter("prod", prod);
    		entities = resultsWithStartAndLimit(em, allMatchesQuery, start, limit);
        }
        em.getTransaction().commit();
    } finally {
        em.close();
    }
	if (entities == null) {
		return new ArrayList<PersistenceOrderItem>();
	}
	return entities;
}
 
源代码4 项目: monolith   文件: ShowEndpoint.java
@GET
@Produces("application/json")
public List<ShowDTO> listAll(@QueryParam("start") Integer startPosition, @QueryParam("max") Integer maxResult)
{
   TypedQuery<Show> findAllQuery = em.createQuery("SELECT DISTINCT s FROM Show s LEFT JOIN FETCH s.event LEFT JOIN FETCH s.venue LEFT JOIN FETCH s.performances LEFT JOIN FETCH s.ticketPrices ORDER BY s.id", Show.class);
   if (startPosition != null)
   {
      findAllQuery.setFirstResult(startPosition);
   }
   if (maxResult != null)
   {
      findAllQuery.setMaxResults(maxResult);
   }
   final List<Show> searchResults = findAllQuery.getResultList();
   final List<ShowDTO> results = new ArrayList<ShowDTO>();
   for (Show searchResult : searchResults)
   {
      ShowDTO dto = new ShowDTO(searchResult);
      results.add(dto);
   }
   return results;
}
 
源代码5 项目: cloud-espm-v2   文件: DataLoader.java
/**
 * This method is used to the parse the contents of the
 * "com/sap/espm/model/data/Products.xml" file and populate a list of
 * {@link Product} that will eventually be persisted in the Data Source.
 * 
 * @param suppliers
 *            - The List of {@link Supplier}.
 * @return - The list of {@link Product} that will be persisted in the
 *         Database.
 */
public List<Product> loadProducts(List<Supplier> suppliers) {
	EntityManager em = emf.createEntityManager();
	TypedQuery<Product> queryProd;
	List<Product> resProd = null;
	try {
		em.getTransaction().begin();
		queryProd = em.createNamedQuery("Product.getAllProducts", Product.class);
		resProd = queryProd.getResultList();
		if (resProd.size() > 5) {
			logger.info(resProd.size() + " Products already available in the db");
		} else {
			new XMLParser().readProduct(em, "com/sap/espm/model/data/Products.xml", suppliers);
			em.getTransaction().commit();
			queryProd = em.createNamedQuery("Product.getAllProducts", Product.class);
			resProd = queryProd.getResultList();
			logger.info(resProd.size() + " Products loaded into the db");
		}
	} catch (Exception e) {
		logger.error("Exception occured", e);
	} finally {
		em.close();
	}
	return resProd;
}
 
源代码6 项目: monolith   文件: EventEndpoint.java
@GET
@Produces("application/json")
public List<EventDTO> listAll(@QueryParam("start") Integer startPosition, @QueryParam("max") Integer maxResult)
{
   TypedQuery<Event> findAllQuery = em.createQuery("SELECT DISTINCT e FROM Event e LEFT JOIN FETCH e.mediaItem LEFT JOIN FETCH e.category ORDER BY e.id", Event.class);
   if (startPosition != null)
   {
      findAllQuery.setFirstResult(startPosition);
   }
   if (maxResult != null)
   {
      findAllQuery.setMaxResults(maxResult);
   }
   final List<Event> searchResults = findAllQuery.getResultList();
   final List<EventDTO> results = new ArrayList<EventDTO>();
   for (Event searchResult : searchResults)
   {
      EventDTO dto = new EventDTO(searchResult);
      results.add(dto);
   }
   return results;
}
 
@Transactional(readOnly = true)
private VirtualRouterVmInventory findRunningVirtualRouterForRule(String ruleUuid) {
    List<String> vrUuids = proxy.getVrUuidsByNetworkService(PortForwardingRuleVO.class.getSimpleName(), ruleUuid);
    if (vrUuids == null || vrUuids.isEmpty()) {
        return null;
    }

    String sql = "select vr from VirtualRouterVmVO vr where vr.uuid in (:vrUuids) and vr.state = :vrState";
    TypedQuery<VirtualRouterVmVO> q = dbf.getEntityManager().createQuery(sql, VirtualRouterVmVO.class);
    q.setParameter("vrUuids", vrUuids);
    q.setParameter("vrState", VmInstanceState.Running);
    q.setMaxResults(1);
    List<VirtualRouterVmVO> vrs = q.getResultList();
    if (vrs.isEmpty()) {
        return null;
    } else {
        return VirtualRouterVmInventory.valueOf(vrs.get(0));
    }
}
 
源代码8 项目: zstack   文件: ImageCascadeExtension.java
@Transactional(readOnly = true)
private List<ImageDeletionStruct> getImageOnBackupStorage(List<String> bsUuids) {
    String sql = "select ref.backupStorageUuid, img from ImageVO img, ImageBackupStorageRefVO ref where img.uuid = ref.imageUuid and ref.backupStorageUuid in (:bsUuids) group by img.uuid";
    TypedQuery<Tuple> q = dbf.getEntityManager().createQuery(sql, Tuple.class);
    q.setParameter("bsUuids", bsUuids);
    List<Tuple> ts = q.getResultList();

    Map<String, ImageDeletionStruct> tmp = new HashMap<String, ImageDeletionStruct>();
    for (Tuple t : ts) {
        String bsUuid = t.get(0, String.class);
        ImageVO img = t.get(1, ImageVO.class);
        ImageDeletionStruct struct = tmp.get(img.getUuid());
        if (struct == null) {
            struct = new ImageDeletionStruct();
            struct.setImage(ImageInventory.valueOf(img));
            struct.setBackupStorageUuids(new ArrayList<String>());
            tmp.put(img.getUuid(), struct);
        }
        struct.getBackupStorageUuids().add(bsUuid);
    }

    List<ImageDeletionStruct> structs = new ArrayList<ImageDeletionStruct>();
    structs.addAll(tmp.values());
    return structs;
}
 
源代码9 项目: monolith   文件: SectionAllocationEndpoint.java
@GET
@Path("/{id:[0-9][0-9]*}")
@Produces("application/json")
public Response findById(@PathParam("id") Long id)
{
   TypedQuery<SectionAllocation> findByIdQuery = em.createQuery("SELECT DISTINCT s FROM SectionAllocation s LEFT JOIN FETCH s.performance LEFT JOIN FETCH s.section WHERE s.id = :entityId ORDER BY s.id", SectionAllocation.class);
   findByIdQuery.setParameter("entityId", id);
   SectionAllocation entity;
   try
   {
      entity = findByIdQuery.getSingleResult();
   }
   catch (NoResultException nre)
   {
      entity = null;
   }
   if (entity == null)
   {
      return Response.status(Status.NOT_FOUND).build();
   }
   SectionAllocationDTO dto = new SectionAllocationDTO(entity);
   return Response.ok(dto).build();
}
 
源代码10 项目: SeaCloudsPlatform   文件: EnforcementJobDAOJpa.java
@Override
public EnforcementJob getByAgreementId(String agreementId) {

    TypedQuery<EnforcementJob> query = entityManager.createNamedQuery(EnforcementJob.QUERY_FIND_BY_AGREEMENT_ID,EnforcementJob.class);
    query.setParameter("agreementId", agreementId);

    EnforcementJob result;
    try {
        result = query.getSingleResult();

    } catch (NoResultException e) {
        logger.debug("Null will returned due to no Result found: " + e);
        return null;
    }

    return result;
}
 
源代码11 项目: container   文件: CoreEndpointServiceImpl.java
@Override
public WSDLEndpoint getWSDLEndpointForIa(final CsarId csarId, final QName nodeTypeImpl, final String iaName) {
    WSDLEndpoint endpoint = null;
    final TypedQuery<WSDLEndpoint> queryWSDLEndpoint = em.createQuery(
        "SELECT e FROM WSDLEndpoint e where e.csarId= :csarId and e.IaName = :IaName and e.TypeImplementation = :nodeTypeImpl", WSDLEndpoint.class);
    queryWSDLEndpoint.setParameter("csarId", csarId);
    queryWSDLEndpoint.setParameter("IaName", iaName);
    queryWSDLEndpoint.setParameter("nodeTypeImpl", nodeTypeImpl);

    try {
        endpoint = (WSDLEndpoint) queryWSDLEndpoint.getSingleResult();
    } catch (final NoResultException e) {
        LOG.info("No endpoint stored for requested IA.");
    }
    return endpoint;
}
 
源代码12 项目: keycloak   文件: JpaRealmProvider.java
@Override
public List<GroupModel> searchForGroupByName(RealmModel realm, String search, Integer first, Integer max) {
    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);
}
 
源代码13 项目: container   文件: PlanInstanceRepository.java
public PlanInstance findByCorrelationId(final String correlationId) {
    try (AutoCloseableEntityManager em = EntityManagerProvider.createEntityManager()) {
        final CriteriaBuilder cb = em.getCriteriaBuilder();
        // Parameters
        final ParameterExpression<String> correlationIdParameter = cb.parameter(String.class);
        // Build the Criteria Query
        final CriteriaQuery<PlanInstance> cq = cb.createQuery(PlanInstance.class);
        final Root<PlanInstance> sti = cq.from(PlanInstance.class);
        cq.select(sti).where(cb.equal(sti.get("correlationId"), correlationIdParameter));
        // Create a TypedQuery
        final TypedQuery<PlanInstance> q = em.createQuery(cq);
        q.setParameter(correlationIdParameter, correlationId);
        // Execute
        PlanInstance result = q.getSingleResult();
        initializeInstance(result);
        return result;
    }
}
 
源代码14 项目: zstack   文件: PortForwardingApiInterceptor.java
@Transactional(readOnly = true)
private void checkIfAnotherVip(String vipUuid, String vmNicUuid) {
    String sql = "select nic.uuid from VmNicVO nic where nic.vmInstanceUuid = (select n.vmInstanceUuid from VmNicVO n where" +
            " n.uuid = :nicUuid)";
    TypedQuery<String> q = dbf.getEntityManager().createQuery(sql, String.class);
    q.setParameter("nicUuid", vmNicUuid);
    List<String> nicUuids = q.getResultList();

    sql = "select count(*) from VmNicVO nic, PortForwardingRuleVO pf where nic.uuid = pf.vmNicUuid and pf.vipUuid != :vipUuid and nic.uuid in (:nicUuids)";
    TypedQuery<Long> lq = dbf.getEntityManager().createQuery(sql, Long.class);
    lq.setParameter("vipUuid", vipUuid);
    lq.setParameter("nicUuids", nicUuids);
    long count = lq.getSingleResult();

    if (count > 0) {
        sql = "select vm from VmInstanceVO vm, VmNicVO nic where vm.uuid = nic.vmInstanceUuid and nic.uuid = :nicUuid";
        TypedQuery<VmInstanceVO> vq = dbf.getEntityManager().createQuery(sql, VmInstanceVO.class);
        vq.setParameter("nicUuid", vmNicUuid);
        VmInstanceVO vm = vq.getSingleResult();

        throw new ApiMessageInterceptionException(operr("the VM[name:%s uuid:%s] already has port forwarding rules that have different VIPs than the one[uuid:%s]",
                        vm.getName(), vm.getUuid(), vipUuid));
    }
}
 
源代码15 项目: quarkus   文件: JPAFunctionalityTestEndpoint.java
private static void verifyJPANamedQuery(final EntityManagerFactory emf) {
    EntityManager em = emf.createEntityManager();
    EntityTransaction transaction = em.getTransaction();
    transaction.begin();
    TypedQuery<Person> typedQuery = em.createNamedQuery(
            "get_person_by_name", Person.class);
    typedQuery.setParameter("name", "Quarkus");
    final Person singleResult = typedQuery.getSingleResult();

    if (!singleResult.getName().equals("Quarkus")) {
        throw new RuntimeException("Wrong result from named JPA query");
    }

    transaction.commit();
    em.close();
}
 
源代码16 项目: keycloak   文件: JPAPermissionTicketStore.java
@Override
public List<PermissionTicket> findByScope(String scopeId, String resourceServerId) {
    if (scopeId==null) {
        return Collections.emptyList();
    }

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

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

    List<String> result = query.getResultList();
    List<PermissionTicket> list = new LinkedList<>();
    PermissionTicketStore ticketStore = provider.getStoreFactory().getPermissionTicketStore();

    for (String id : result) {
        PermissionTicket ticket = ticketStore.findById(id, resourceServerId);
        if (Objects.nonNull(ticket)) {
            list.add(ticket);
        }
    }

    return list;
}
 
源代码17 项目: zstack   文件: SecurityGroupManagerImpl.java
@Transactional(readOnly = true)
private List<HostRuleTO> calculateByHost() {
    String sql = "select nic.uuid from VmNicVO nic, VmInstanceVO vm, VmNicSecurityGroupRefVO ref, SecurityGroupVO sg" +
            " where nic.uuid = ref.vmNicUuid and nic.vmInstanceUuid = vm.uuid"+
            " and ref.securityGroupUuid = sg.uuid and sg.state in (:sgState)" +
            " and vm.hostUuid in (:hostUuids) and vm.state in (:vmStates)";
    TypedQuery<String> insgQuery = dbf.getEntityManager().createQuery(sql, String.class);
    insgQuery.setParameter("hostUuids", hostUuids);
    insgQuery.setParameter("vmStates", vmStates);
    insgQuery.setParameter("sgState", sgStates);
    List<String> nicsInSg = insgQuery.getResultList();

    sql = "select nic.uuid from VmNicVO nic, VmInstanceVO vm where nic.vmInstanceUuid = vm.uuid" +
            " and vm.hostUuid in (:hostUuids) and vm.state in (:vmStates)";
    TypedQuery<String> allq = dbf.getEntityManager().createQuery(sql, String.class);
    allq.setParameter("hostUuids", hostUuids);
    allq.setParameter("vmStates", vmStates);
    List<String> allNics = allq.getResultList();
    allNics.removeAll(nicsInSg);
    List<String> nicsOutSg = allNics;

    List<HostRuleTO> ret = new ArrayList<HostRuleTO>();
    if (!nicsInSg.isEmpty()) {
        vmNicUuids = nicsInSg.stream().distinct().collect(Collectors.toList());
        ret.addAll(calculateByVmNic());
    }
    if (!nicsOutSg.isEmpty()) {
        Collection<HostRuleTO> toRemove = createRulePlaceHolder(nicsOutSg, null);
        for (HostRuleTO hto : toRemove) {
            hto.setActionCodeForAllSecurityGroupRuleTOs(SecurityGroupRuleTO.ACTION_CODE_DELETE_CHAIN);
        }
        //ret.addAll(toRemove);
        ret = mergeMultiHostRuleTO(ret, toRemove);
    }

    return ret;
}
 
源代码18 项目: syncope   文件: JPAReportDAO.java
@Transactional(readOnly = true)
@Override
public List<Report> findByTemplate(final ReportTemplate template) {
    TypedQuery<Report> query = entityManager().createQuery(
            "SELECT e FROM " + JPAReport.class.getSimpleName() + " e "
            + "WHERE e.template=:template", Report.class);
    query.setParameter("template", template);
    return query.getResultList();
}
 
源代码19 项目: monolith   文件: EventEndpoint.java
@PUT
@Path("/{id:[0-9][0-9]*}")
@Consumes("application/json")
public Response update(@PathParam("id") Long id, EventDTO dto)
{
   TypedQuery<Event> findByIdQuery = em.createQuery("SELECT DISTINCT e FROM Event e LEFT JOIN FETCH e.mediaItem LEFT JOIN FETCH e.category WHERE e.id = :entityId ORDER BY e.id", Event.class);
   findByIdQuery.setParameter("entityId", id);
   Event entity;
   try
   {
      entity = findByIdQuery.getSingleResult();
   }
   catch (NoResultException nre)
   {
      entity = null;
   }
   entity = dto.fromDTO(entity, em);
   try
   {
      entity = em.merge(entity);
   }
   catch (OptimisticLockException e)
   {
      return Response.status(Response.Status.CONFLICT).entity(e.getEntity()).build();
   }
   return Response.noContent().build();
}
 
源代码20 项目: monolith   文件: NestedMediaItemDTO.java
public MediaItem fromDTO(MediaItem entity, EntityManager em)
{
   if (entity == null)
   {
      entity = new MediaItem();
   }
   if (this.id != null)
   {
      TypedQuery<MediaItem> findByIdQuery = em
            .createQuery(
                  "SELECT DISTINCT m FROM MediaItem m WHERE m.id = :entityId",
                  MediaItem.class);
      findByIdQuery.setParameter("entityId", this.id);
      try
      {
         entity = findByIdQuery.getSingleResult();
      }
      catch (javax.persistence.NoResultException nre)
      {
         entity = null;
      }
      return entity;
   }
   entity.setMediaType(this.mediaType);
   entity.setUrl(this.url);
   entity = em.merge(entity);
   return entity;
}
 
public List<Quiz> getRandomQuizzes(int n, long categoryId){

        TypedQuery<Long> sizeQuery= em.createQuery(
                "select count(q) from Quiz q where q.subCategory.parent.id=?1", Long.class);
        sizeQuery.setParameter(1, categoryId);
        long size = sizeQuery.getSingleResult();

        if(n > size){
            throw new IllegalArgumentException("Cannot choose " + n + " unique quizzes out of the " + size + " existing");
        }

        Random random = new Random();

        List<Quiz> quizzes = new ArrayList<>();
        Set<Integer> chosen = new HashSet<>();

        while(chosen.size() < n) {

            int k = random.nextInt((int)size);
            if(chosen.contains(k)){
                continue;
            }
            chosen.add(k);

            TypedQuery<Quiz> query = em.createQuery(
                    "select q from Quiz q where q.subCategory.parent.id=?1", Quiz.class);
            query.setParameter(1, categoryId);
            query.setMaxResults(1);
            query.setFirstResult(k);

            quizzes.add(query.getSingleResult());
        }


        return  quizzes;
    }
 
源代码22 项目: keycloak   文件: JPAPolicyStore.java
@Override
public void findByResource(String resourceId, String resourceServerId, Consumer<Policy> consumer) {
    TypedQuery<PolicyEntity> query = entityManager.createNamedQuery("findPolicyIdByResource", PolicyEntity.class);

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

    StoreFactory storeFactory = provider.getStoreFactory();

    query.getResultList().stream()
            .map(entity -> new PolicyAdapter(entity, entityManager, storeFactory))
            .forEach(consumer::accept);
}
 
源代码23 项目: syncope   文件: JPAPlainSchemaDAO.java
@Override
public <T extends PlainAttr<?>> List<T> findAttrs(final PlainSchema schema, final Class<T> reference) {
    TypedQuery<T> query = entityManager().createQuery(
            "SELECT e FROM " + JPAPlainAttrDAO.getEntityReference(reference).getSimpleName()
            + " e WHERE e.schema=:schema", reference);
    query.setParameter("schema", schema);

    return query.getResultList();
}
 
源代码24 项目: syncope   文件: JPAPolicyDAO.java
@Override
public List<AccountPolicy> findByResource(final ExternalResource resource) {
    TypedQuery<AccountPolicy> query = entityManager().createQuery(
            "SELECT e FROM " + JPAAccountPolicy.class.getSimpleName() + " e "
            + "WHERE :resource MEMBER OF e.resources", AccountPolicy.class);
    query.setParameter("resource", resource);

    return query.getResultList();
}
 
源代码25 项目: keycloak   文件: JpaUserFederatedStorageProvider.java
@Override
public Set<GroupModel> getGroups(RealmModel realm, String userId) {
    Set<GroupModel> set = new HashSet<>();
    TypedQuery<FederatedUserGroupMembershipEntity> query = em.createNamedQuery("feduserGroupMembership", FederatedUserGroupMembershipEntity.class);
    query.setParameter("userId", userId);
    List<FederatedUserGroupMembershipEntity> results = query.getResultList();
    if (results.size() == 0) return set;
    for (FederatedUserGroupMembershipEntity entity : results) {
        GroupModel group = realm.getGroupById(entity.getGroupId());
        set.add(group);
    }
    return set;
}
 
源代码26 项目: zstack   文件: EipApiInterceptor.java
@Transactional(readOnly = true)
private void checkIfVmAlreadyHasVipNetwork(String vmUuid, VipVO vip) {
    String sql = "select count(*) from VmNicVO nic, VmInstanceVO vm where nic.vmInstanceUuid = vm.uuid" +
            " and vm.uuid = :vmUuid and nic.l3NetworkUuid = :vipL3Uuid";
    TypedQuery<Long> q = dbf.getEntityManager().createQuery(sql, Long.class);
    q.setParameter("vmUuid", vmUuid);
    q.setParameter("vipL3Uuid", vip.getL3NetworkUuid());
    Long c = q.getSingleResult();
    if (c > 0) {
        throw new ApiMessageInterceptionException(argerr("the vm[uuid:%s] that the EIP is about to attach is already on the public network[uuid:%s] from which" +
                        " the vip[uuid:%s, name:%s, ip:%s] comes", vmUuid, vip.getL3NetworkUuid(), vip.getUuid(), vip.getName(), vip.getIp()));
    }
}
 
源代码27 项目: container   文件: CoreEndpointServiceImpl.java
@Override
/**
 * {@Inheritdoc}
 */
public List<RESTEndpoint> getRestEndpoints(final URI anyURI, String triggeringContainer, final CsarId csarId) {
    final ArrayList<RESTEndpoint> results = new ArrayList<>();

    /**
     * Create Query to retrieve RESTEndpoints identified by a URI and thorID
     *
     * @see RESTEndpoint#getEndpointForPath
     **/
    final TypedQuery<RESTEndpoint> getRestEndpointsQuery = this.em.createNamedQuery(RESTEndpoint.getEndpointForPath, RESTEndpoint.class);

    // Set Parameters
    getRestEndpointsQuery.setParameter("path", anyURI.getPath());
    getRestEndpointsQuery.setParameter("triggeringContainer", triggeringContainer);
    getRestEndpointsQuery.setParameter("csarId", csarId);

    // Get Query-Results and add them to the result list
    final
    // Result can only be a RESTEndpoint
        List<RESTEndpoint> queryResults = getRestEndpointsQuery.getResultList();
    for (final RESTEndpoint endpoint : queryResults) {
        results.add(endpoint);
    }
    return results;
}
 
源代码28 项目: joynr   文件: GlobalCapabilitiesDirectoryEjb.java
@Override
public void touch(String clusterControllerId) {
    logger.debug("Touch called. Updating discovery entries from cluster controller with id {}",
                 clusterControllerId);
    String queryString = "FROM GlobalDiscoveryEntryPersisted gdep WHERE gdep.clusterControllerId = :clusterControllerId";
    long now = System.currentTimeMillis();
    TypedQuery<GlobalDiscoveryEntryPersisted> query = entityManager.createQuery(queryString,
                                                                                GlobalDiscoveryEntryPersisted.class);
    query.setParameter("clusterControllerId", clusterControllerId);
    for (GlobalDiscoveryEntryPersisted globalDiscoveryEntryPersisted : query.getResultList()) {
        globalDiscoveryEntryPersisted.setLastSeenDateMs(now);
        globalDiscoveryEntryPersisted.setExpiryDateMs(now + defaultExpiryTimeMs);
    }
}
 
源代码29 项目: SeaCloudsPlatform   文件: EnforcementJobDAOJpa.java
@Override
public List<IEnforcementJob> getAll() {
    TypedQuery<IEnforcementJob> query = entityManager.createNamedQuery(    "EnforcementJob.findAll", IEnforcementJob.class);

    List<IEnforcementJob> enforcementJob = new ArrayList<IEnforcementJob>();
    enforcementJob = query.getResultList();

    if (enforcementJob != null) {
        logger.debug("Number of enforcementJob:" + enforcementJob.size());
    } else {
        logger.debug("No Result found.");
    }

    return enforcementJob;
}
 
源代码30 项目: sample.daytrader7   文件: TradeSLSBBean.java
@Override
public QuoteDataBean updateQuotePriceVolume(String symbol, BigDecimal changeFactor, double sharesTraded) {
    if (!TradeConfig.getUpdateQuotePrices()) {
        return new QuoteDataBean();
    }

    if (Log.doTrace()) {
        Log.trace("TradeSLSBBean:updateQuote", symbol, changeFactor);
    }

    TypedQuery<QuoteDataBean> q = entityManager.createNamedQuery("quoteejb.quoteForUpdate",QuoteDataBean.class);
    q.setParameter(1, symbol);
    QuoteDataBean quote = q.getSingleResult();

    BigDecimal oldPrice = quote.getPrice();
    BigDecimal openPrice = quote.getOpen();

    if (oldPrice.equals(TradeConfig.PENNY_STOCK_PRICE)) {
        changeFactor = TradeConfig.PENNY_STOCK_RECOVERY_MIRACLE_MULTIPLIER;
    } else if (oldPrice.compareTo(TradeConfig.MAXIMUM_STOCK_PRICE) > 0) {
        changeFactor = TradeConfig.MAXIMUM_STOCK_SPLIT_MULTIPLIER;
    }

    BigDecimal newPrice = changeFactor.multiply(oldPrice).setScale(2, BigDecimal.ROUND_HALF_UP);

    quote.setPrice(newPrice);
    quote.setChange(newPrice.subtract(openPrice).doubleValue());
    quote.setVolume(quote.getVolume() + sharesTraded);
    entityManager.merge(quote);

    context.getBusinessObject(TradeSLSBLocal.class).publishQuotePriceChange(quote, oldPrice, changeFactor, sharesTraded);
   
    return quote;
}
 
 类所在包
 同包方法