Package javax.jdo

Examples of javax.jdo.Query.execute()


    Query q = pm.newQuery(Subscription.class);
    q.setFilter("userKey == uk");
    q.declareParameters("com.google.appengine.api.datastore.Key uk");
   
    @SuppressWarnings("unchecked")
    List<Subscription> list = (List<Subscription>) q.execute(user.getKey());
   
    for(Subscription s : list){
      pm.currentTransaction().begin();
      s.setLatestEntryNotifiedDate(lastPubDate);
      s.setLastProcessDate(lastProcess);
View Full Code Here


      Query quser = pm.newQuery(User.class);
      quser.setFilter("id == jid");
      quser.declareParameters("java.lang.String jid");
      quser.setUnique(true);
     
      User user = (User) quser.execute(jid);
     
      if (user != null){
        //fetch all subscriptions
        Query q = pm.newQuery(Subscription.class);
        q.setFilter("userKey == key");
View Full Code Here

        Query q = pm.newQuery(Subscription.class);
        q.setFilter("userKey == key");
        q.declareParameters("com.google.appengine.api.datastore.Key key");
       
        @SuppressWarnings("unchecked")
        List<Subscription> list = (List<Subscription>) q.execute(user.getKey());
       
        //mark all user's subscription as read (by recent date)
        for(Subscription s : list){
          pm.currentTransaction().begin();
          s.setLatestEntryNotifiedDate(now);
View Full Code Here

    Query q = pm.newQuery(Subscription.class);
    q.setFilter("userKey == k");
    q.declareParameters("com.google.appengine.api.datastore.Key k");
   
    @SuppressWarnings("unchecked")
    List<Subscription> subs = (List<Subscription>) q.execute(u.getKey());
   
    int n = 0;
    StringBuilder sb = new StringBuilder();
    for(Subscription s : subs){
      Blog b = pm.getObjectById(Blog.class, s.getBlogKey());
View Full Code Here

  public <T> List<T> findByAttribute(Class<T> clazz, String attribute, Key value) {
    Query q = pm.newQuery(clazz);
    q.setFilter(attribute + " == value");
    q.declareParameters(Key.class.getName() + " value");
   
    List<T> list = (List<T>) q.execute(value);
   
    return list;
  }
 
  @SuppressWarnings("unchecked")
View Full Code Here

        PersistenceManager pm = PMF.get().getPersistenceManager();
        try {
            String queryStr = String.format("select from %s where user_email==currentUser order by modification desc", Photo.class.getName());
            Query query = pm.newQuery(queryStr);
            query.declareParameters("String currentUser");
            List<Photo> photos = (List<Photo>) query.execute(getUserEmail());
            if (photos.size() == 0) {
                photos.size();
            }
            return photos;
        } finally {
View Full Code Here

            Query query = pm.newQuery(AuthenticationToken.class);
            query.setFilter("activity < activityParam");
            query.setRange(0, 1000);
            query.declareImports("import java.util.Date");
            query.declareParameters("Date activityParam");
            List<AuthenticationToken> objs = (List<AuthenticationToken>) query.execute(cal.getTime());
              long c = objs.size();
              for (AuthenticationToken obj : objs) {
              pm.deletePersistent(obj);
              }
              String msg = user + " - Flushed " + c + " tokens.";
View Full Code Here

          }
        } else if (action.equalsIgnoreCase("countTokens")) {
          PersistenceManager pm = PMF.get().getPersistenceManager();
          try {
            Query query = pm.newQuery(AuthenticationToken.class);
              List<AuthenticationToken> objs = (List<AuthenticationToken>) query.execute();
              int c = objs.size();
              String msg = user + " - There are " + c + " tokens.";
              log.log(Level.INFO, msg);
              resp.getWriter().write(msg);
          } finally {
View Full Code Here

            cal.add(Calendar.HOUR, -6);
            Query query = pm.newQuery(AuthenticationToken.class);
            query.setFilter("activity < activityParam");
            query.declareImports("import java.util.Date");
            query.declareParameters("Date activityParam");
            List<AuthenticationToken> objs = (List<AuthenticationToken>) query.execute(cal.getTime());
            int c = objs.size();
            String msg = user + " - There are " + c + " tokens to flush.";
          log.log(Level.INFO, msg);
            resp.getWriter().write(msg);
          } finally {
View Full Code Here

          query.setOrdering("name desc");
          query.setOrdering("dateCommunityAccount desc");
          query.setRange(0, range); //only 6 results
          //query.setOrdering("hireDate desc");
          query.declareParameters("String nameParam");
          List<DaoCommunityAccount2> resultsTmp = (List<DaoCommunityAccount2>) query.execute(user);
         
          if(resultsTmp.size() != 0 )
          {
            DaoCommunityAccount2 daoComAcc = resultsTmp.get(0);
            CommunityAccount comAcc=  TransformDtoObject.TransformDaoCommunityAccountToCommunityAccount(daoComAcc);
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.