Examples of javax.jdo.Query.execute()

javax.jdo.Query.execute()
Execute the query and return the filtered Collection. @return the filtered Collection. @see #executeWithArray(Object[] parameters)

    List<BlogEntry> list = new ArrayList<BlogEntry>(15);


    Blog blog = pm.getObjectById(Blog.class, blogId);


    @SuppressWarnings("unchecked")
    Collection<BlogEntry> col = (Collection<BlogEntry>) q.execute(blog
        .getKey());


    for (BlogEntry be : col) {
      list.add(be);
    }

View Full Code Here

    q.setOrdering("nextUpdate");
    
    Date now = Calendar.getInstance().getTime();
    
    @SuppressWarnings("unchecked")
    List<Blog> blogs = (List<Blog>) q.execute(now);
    
    for(Blog blog : blogs){
      //add treatment to queue
      QueuedTask task = new QueuedTask();
      task.setType(TaskType.updateblog);

View Full Code Here

    
    Query q = pm.newQuery(Blog.class);
    
    //fetch ALL blogs
    @SuppressWarnings("unchecked")
    List<Blog> allBlogs = (List<Blog>) q.execute();
    
    for(Blog b : allBlogs){
      //fetch sub
      Query sq = pm.newQuery(Subscription.class);
      sq.setFilter("blogKey == bk");

View Full Code Here

      sq.setFilter("blogKey == bk");
      sq.declareParameters("com.google.appengine.api.datastore.Key bk");
      sq.setRange(0, 1);
      
      @SuppressWarnings("unchecked")
      List<Subscription> ls = (List<Subscription>) sq.execute(b.getKey());
      
      if (ls.size() == 0){
        //delete blog without subscription
        pm.currentTransaction().begin();
        pm.deletePersistent(b);

View Full Code Here

    Calendar cdat = Calendar.getInstance();
    cdat.add(Calendar.DATE , -nbdays);
    
    //fetch ALL blogs
    @SuppressWarnings("unchecked")
    List<BlogEntry> oldest = (List<BlogEntry>) q.execute(cdat.getTime());
    
    for(BlogEntry be : oldest){
      pm.currentTransaction().begin();
      pm.deletePersistent(be);
      pm.currentTransaction().commit();

View Full Code Here

      if (pubDate == null) pubDate = Calendar.getInstance().getTime();
      
      //date
      if(recentDate.after(pubDate)) continue;


      BlogEntry entry = (BlogEntry) queryBlogEntry.execute(item.getGuid());
      
      if (entry == null){
        //new item
        entry = new BlogEntry();
        entry.setBlogKey(blog.getKey());

View Full Code Here

    q.setOrdering("nextUpdate");
    q.declareParameters("java.util.Date next");
    q.setRange(0, nbMax);


    // list user
    List<User> list = (List<User>) q.execute(now);


    for (User user : list) {
      //build task for queuing
      QueuedTask task = new QueuedTask();
      task.setType(TaskType.updateuser);

View Full Code Here

      q.setRange(0, NB_SUBSCRIPTIONS_MAX);
      q.setFilter("userKey == uk");
      q.declareParameters("com.google.appengine.api.datastore.Key uk");


      @SuppressWarnings("unchecked")
      List<Subscription> subs = (List<Subscription>) q.execute(user
          .getKey());


      // update
      for (Subscription sub : subs) {
        // update is done ?

View Full Code Here

    qUser.setFilter("id == email");
    qUser.declareParameters("String email");
    qUser.setRange(0, 1);
    qUser.setUnique(true);


    User user = (User) qUser.execute(email);


    if (user == null) {
      qUser.closeAll();
      return false;
    }

View Full Code Here

    q.setFilter("userKey == uid && blogKey == bid");
    q.declareParameters("com.google.appengine.api.datastore.Key uid, com.google.appengine.api.datastore.Key bid");
    q.setRange(0, 1);


    @SuppressWarnings("unchecked")
    List<Subscription> list = (List<Subscription>) q.execute(user.getKey(),
        blog.getKey());


    if (list.size() > 0) {
      pm.currentTransaction().begin();
      pm.deletePersistent(list.get(0));

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.