java类javax.persistence.NoResultException的实例源码

@Override
public String getTotalCreditLiraPostingsForOneDay(String date) {
    String totalCredit = null;
    try {
        session = dataSourceFactory.getSessionFactory().openSession();
        beginTransactionIfAllowed(session);
        Query<String> query = session.createQuery("select sum(price) from Posting where "
                + "currency = 'CREDIT CARD' and currency = 'TURKISH LIRA' and dateTime >= :date", String.class);
        query.setParameter("date", date);
        totalCredit = query.getSingleResult();

        logging.setMessage("PostingDaoImpl -> fetching total credit card lira posting for one day...");

    } catch (NoResultException e) {
        logging.setMessage("PostingDaoImpl Error -> " + e.getLocalizedMessage());
    } finally {
        session.close();
    }
    return totalCredit;
}

public static Conversations getByClientAndCandidateID(int clientID, int candidateID) throws NoResultException {
    if (clientID > 0 && candidateID > 0) {
        EntityManager em = EMFUtil.getEMFactory().createEntityManager();
        String query = "SELECT c FROM Conversations c WHERE c.clientID = :clientID AND c.candidateID = :candidateID";
        try {
            TypedQuery<Conversations> q = em.createQuery(query, Conversations.class);
            q.setParameter("clientID", clientID);
            q.setParameter("candidateID", candidateID);
            Conversations conversation = q.getSingleResult();
            em.close();
            return conversation;
        } finally {
            if (em.isOpen()) {
                em.close();
            }
        }
    }
    return null;
}

public List<Reservation> getGaranteedReservs(String reservDate) {
    List<Reservation> reservationsList = null;
    try {
        session = dataSourceFactory.getSessionFactory().openSession();
        beginTransactionIfAllowed(session);
        Query<Reservation> query = session.createQuery("from Reservation "
                + "where bookStatus = 'GUARANTEE' and checkinDate=:today", Reservation.class);
        query.setParameter("today", reservDate);
        reservationsList = query.getResultList();

        logging.setMessage("ReservationDaoImpl -> fetching all garanteed reservations...");

    } catch (NoResultException e) {
        logging.setMessage("ReservationDaoImpl Error -> " + e.getLocalizedMessage());
    } finally {
        session.close();
    }
    return reservationsList;
}

@Override
public BigDecimal loadOperatorRevenueSharePercentage(long serviceKey,
        long endPeriod) {
    Query query = dm
            .createNamedQuery("RevenueShareModelHistory.findOperatorRevenueSharePercentage");
    query.setParameter("productObjKey", Long.valueOf(serviceKey));
    query.setParameter("modDate", new Date(endPeriod));
    query.setMaxResults(1);

    BigDecimal percentage;
    try {
        RevenueShareModelHistory revenueShareModelHistory = (RevenueShareModelHistory) query
                .getSingleResult();
        percentage = revenueShareModelHistory.getDataContainer()
                .getRevenueShare();
    } catch (NoResultException e) {
        logger.logError(
                Log4jLogger.SYSTEM_LOG,
                e,
                LogMessageIdentifier.ERROR_OPERATOR_REVENUE_SHARE_OF_SERVICE_NOT_FOUND,
                Long.toString(serviceKey));
        throw e;
    }
    return percentage;
}

public List<Payment> getAllPaymentsForToday(String today) {
    List<Payment> paymentsList = null;
    try {

        session = dataSourceFactory.getSessionFactory().openSession();
        beginTransactionIfAllowed(session);
        Query<Payment> query = session.createQuery("from Payment where dateTime >= :today", Payment.class);
        query.setParameter("today", today);
        paymentsList = query.getResultList();

        logging.setMessage("PaymentDaoImpl -> fetching all payments for today...");

    } catch (NoResultException e) {
        logging.setMessage("PaymentDaoImpl Error ->" + e.getLocalizedMessage());
    } finally {
        session.close();
    }
    return paymentsList;
}

@Test (expected = FileUtilityException.class)
public void testCreateWithExistingBinaryFailsForNonExistentFile() throws IOException {
    final Map<String, String> dataMap = new HashMap<>();
    dataMap.put("name", "tomcat");
    dataMap.put("type", "TOMCAT");
    dataMap.put("remoteDir", "c:/tomcat");

    final Map<String, Object> mediaFileDataMap = new HashMap<>();
    mediaFileDataMap.put("filename", "apache-tomcat-test.zip");
    mediaFileDataMap.put("content", new BufferedInputStream(new FileInputStream(new File("./src/test/resources/binaries/apache-tomcat-test.zip"))));

    when(Config.mockMediaRepositoryService.upload(anyString(), any(InputStream.class)))
            .thenReturn("/does/not.exist");
    when(Config.mockMediaRepositoryService.getBinariesByBasename(anyString())).thenReturn(Collections.singletonList("./src/test/resources/binaries/apache-tomcat-test.zip"));
    when(Config.mockMediaDao.findByNameAndType(anyString(), any(MediaType.class))).thenThrow(NoResultException.class);
    mediaService.create(dataMap, mediaFileDataMap);
}

public static SecurityGroup listSecurityGroupsByVcIdAndMgrId(EntityManager em, Long vcId, String mgrId) {
    CriteriaBuilder cb = em.getCriteriaBuilder();

    CriteriaQuery<SecurityGroup> query = cb.createQuery(SecurityGroup.class);

    Root<SecurityGroup> root = query.from(SecurityGroup.class);
    query = query.select(root)
            .where(cb.equal(root.join("virtualizationConnector").get("id"), vcId),
                    cb.equal(root.join("securityGroupInterfaces").get("mgrSecurityGroupId"), mgrId))
            .orderBy(cb.asc(root.get("name")));

    try {
        return em.createQuery(query).getSingleResult();
    } catch (NoResultException nre) {
        return null;
    }
}

public List<Posting> getAllPostingsForToday(String today) {
    List<Posting> postingsList = null;
    try {
        session = dataSourceFactory.getSessionFactory().openSession();
        beginTransactionIfAllowed(session);
        Query<Posting> query = session.createQuery("from Posting where dateTime >= :today", Posting.class);
        query.setParameter("today", today);
        postingsList = query.getResultList();

        logging.setMessage("PostingDaoImpl -> fetching all postings for today...");

    } catch (NoResultException e) {
        logging.setMessage("PostingDaoImpl Error -> " + e.getLocalizedMessage());
    } finally {
        session.close();
    }
    return postingsList;
}

public List<Reservation> getReservationBetweenTwoDates(String checkinDate, String checkoutDate) {
    List<Reservation> reservationsList = null;

    try {

        session = dataSourceFactory.getSessionFactory().openSession();
          beginTransactionIfAllowed(session);
          Query<Reservation> query = session.createQuery("from Reservation AS r WHERE r.checkinDate BETWEEN :checkinDate AND :checkoutDate", Reservation.class);
          query.setParameter("checkinDate", checkinDate);
          query.setParameter("checkoutDate", checkoutDate);
          reservationsList = query.getResultList();

          if(reservationsList == null)
             reservationsList = session.createQuery("from Reservation", Reservation.class).getResultList();

          logging.setMessage("ReservationDaoImpl -> fetching reservation that between two dates...");

} catch (NoResultException e) {
     logging.setMessage("ReservationDaoImpl Error -> " + e.getLocalizedMessage());
}

    return reservationsList;
  }

public static Network findByOpenstackId(EntityManager em, String id) {

        CriteriaBuilder cb = em.getCriteriaBuilder();

        CriteriaQuery<Network> query = cb.createQuery(Network.class);

        Root<Network> root = query.from(Network.class);

        query = query.select(root)
            .where(cb.equal(root.get("openstackId"), id));

        try {
            return em.createQuery(query).getSingleResult();
        } catch (NoResultException nre) {
            return null;
        }
    }