Package com.google.appengine.api.datastore

Examples of com.google.appengine.api.datastore.PreparedQuery

22
23
24
25
26
27
28
29
30
  private static final ReadServiceImpl readService = new ReadServiceImpl();
  private ReportMetaData[] metaData;

  @Override
  public Map<Integer, Double> getAnnuallyOfferingVolumes() {
    final PreparedQuery pq = db.prepare(new Query(Offering.class.getSimpleName()));
    final ListQueryResult r = copy.entitiesToDtoArray(Offering.class.getSimpleName(), pq.countEntities(withDefaults()), pq.asIterable(withDefaults()), false);
    return new OfferingReports().getAnnuallyOfferingVolumes(r.getResults());
  }
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
189
  private static Entity findDeviceByRegId(String regId) {
    Filter filter =
        new FilterPredicate(DEVICE_REG_ID_PROPERTY, FilterOperator.EQUAL, regId);
    Query query = new Query(DEVICE_TYPE).setFilter(filter);
    PreparedQuery preparedQuery = datastore.prepare(query);
    List<Entity> entities = preparedQuery.asList(DEFAULT_FETCH_OPTIONS);
    Entity entity = null;
    if (!entities.isEmpty()) {
      entity = entities.get(0);
    }
    int size = entities.size();
View Full Code Here
466
467
468
469
470
471
472
473
474
475
476
477
478
479
  }

  public List<Entity> queryAll(final String kind, final Key rootJobKey) {
    Query query = new Query(kind);
    query.setFilter(new FilterPredicate(ROOT_JOB_KEY_PROPERTY, EQUAL, rootJobKey));
    final PreparedQuery preparedQuery = dataStore.prepare(query);
    final FetchOptions options = FetchOptions.Builder.withChunkSize(500);
    return tryFiveTimes(new Operation<List<Entity>>("queryFullPipeline") {
      @Override
      public List<Entity> call() {
        return preparedQuery.asList(options);
      }
    });
  }
View Full Code Here
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
    Query query = new Query(JobRecord.DATA_STORE_KIND);
    Filter filter = classFilter == null || classFilter.isEmpty() ? new FilterPredicate(
        ROOT_JOB_DISPLAY_NAME, GREATER_THAN, null)
        : new FilterPredicate(ROOT_JOB_DISPLAY_NAME, EQUAL, classFilter);
    query.setFilter(filter);
    final PreparedQuery preparedQuery = dataStore.prepare(query);
    final FetchOptions fetchOptions = FetchOptions.Builder.withDefaults();
    if (limit > 0) {
      fetchOptions.limit(limit + 1);
    }
    if (cursor != null) {
      fetchOptions.startCursor(Cursor.fromWebSafeString(cursor));
    }
    return tryFiveTimes(
        new Operation<Pair<? extends Iterable<JobRecord>, String>>("queryRootPipelines") {
          @Override
          public Pair<? extends Iterable<JobRecord>, String> call() {
            QueryResultIterator<Entity> entities =
                preparedQuery.asQueryResultIterable(fetchOptions).iterator();
            Cursor dsCursor = null;
            List<JobRecord> roots = new LinkedList<>();
            while (entities.hasNext()) {
              if (limit > 0 && roots.size() >= limit) {
                dsCursor = entities.getCursor();
View Full Code Here
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
  public Set<String> getRootPipelinesDisplayName() {
    Query query = new Query(JobRecord.DATA_STORE_KIND);
    query.addProjection(
        new PropertyProjection(JobRecord.ROOT_JOB_DISPLAY_NAME, String.class));
    query.setDistinct(true);
    final PreparedQuery preparedQuery = dataStore.prepare(query);
    return tryFiveTimes(new Operation<Set<String>>("getRootPipelinesDisplayName") {
      @Override
      public Set<String> call() {
        Set<String> pipelines = new LinkedHashSet<>();
        for (Entity entity : preparedQuery.asIterable()) {
          pipelines.add((String) entity.getProperty(JobRecord.ROOT_JOB_DISPLAY_NAME));
        }
        return pipelines;
      }
    });
View Full Code Here
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
  private void deleteAll(final String kind, final Key rootJobKey) {
    logger.info("Deleting all " + kind + " with rootJobKey=" + rootJobKey);
    final int chunkSize = 100;
    final FetchOptions fetchOptions = FetchOptions.Builder.withChunkSize(chunkSize);
    final PreparedQuery preparedQuery = dataStore.prepare(new Query(kind).setKeysOnly().setFilter(
        new FilterPredicate(ROOT_JOB_KEY_PROPERTY, EQUAL, rootJobKey)));
    tryFiveTimes(new Operation<Void>("delete") {
      @Override
      public Void call() {
        Iterator<Entity> iter = preparedQuery.asIterator(fetchOptions);
        while (iter.hasNext()) {
          ArrayList<Key> keys = new ArrayList<>(chunkSize);
          for (int i = 0; i < chunkSize && iter.hasNext(); i++) {
            keys.add(iter.next().getKey());
          }
View Full Code Here
69
70
71
72
73
74
75
76
  }

  private Entity findByUsername(String username) {
    Query query = new Query(userStoreKind);
    query.addFilter("username", Query.FilterOperator.EQUAL, username);
    PreparedQuery preparedQuery = datastoreService.prepare(query);
    return preparedQuery.asSingleEntity();
  }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
95
      if (null != this.lastUpdate) {
        Long now = new Date().getTime();
        query.addFilter("timestamp", FilterOperator.GREATER_THAN_OR_EQUAL, (now - (MAX_CLOCK_SKEW)));
      }
     
      PreparedQuery pq = asyncDatastoreService.prepare(query);
      Iterator<Entity> it = pq.asIterator();
     
      while (it.hasNext()) {
        Entity entity = it.next();
       
        @SuppressWarnings("unchecked")
View Full Code Here
539
540
541
542
543
544
545
546
547
548
549
     * @param qry
     *            the query
     * @return entities as list
     */
    protected List<Entity> asEntityList(DatastoreService ds, Query qry) {
        PreparedQuery pq =
            txSet ? DatastoreUtil.prepare(ds, tx, qry) : DatastoreUtil.prepare(
                ds,
                qry);
        return DatastoreUtil.asList(pq, fetchOptions);
    }
View Full Code Here
553
554
555
556
557
558
559
560
561
562
     *
     * @return entities as query result list
     */
    protected QueryResultList<Entity> asQueryResultEntityList() {
        DatastoreService ds = DatastoreServiceFactory.getDatastoreService();
        PreparedQuery pq =
            txSet ? DatastoreUtil.prepare(ds, tx, query) : DatastoreUtil
                .prepare(ds, query);
        return DatastoreUtil.asQueryResultList(pq, fetchOptions);
    }
View Full Code Here
TOP

Related Classes of com.google.appengine.api.datastore.PreparedQuery

  • cl.loso.melon.server.util.Util
  • com.antonytrupe.server.battledisks.API
  • com.apps.datastore.AccountInformationDatastore
  • com.apps.datastore.NoSignupDatastore
  • com.apps.datastore.NotifierDatastore
  • com.apps.datastore.UBCCourseSpiderDatastore
  • com.divel.online.apps.News
  • com.dooapp.gaedo.google.datastore.DatastoreFinderServiceImpl
  • com.game.cloudymon.dal.EntityDAO
  • com.google.appengine.codelab.SessaoTests
    • Copyright © 2018 www.massapicom. 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.