import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
private void validateRequest(Long timehash, String cert) throws ForbiddenException {
    if (timehash != null && cert != null) {
        try {
            QueryResultIterable<PrivateInfo> allPrivate = ObjectifyService.ofy().load().type(PrivateInfo.class).iterable();
            for (PrivateInfo info : allPrivate) {
                String key = doSHA1(String.format("%s;%s;%d", info.getFingerprint().toLowerCase(), info.getPackageName().toLowerCase(), timehash));
                if (cert.equalsIgnoreCase(key)) {
                    return;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    throw new ForbiddenException("Cannot access by: " + cert + " at: " + timehash);
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
/**
 * Deletes a package
 *
 * @param ofy Objectify
 * @param name package name
 */
public static void deletePackage(Objectify ofy, String name) {
    Package p = ofy.get(new Key<Package>(Package.class, name));
    ofy.delete(p);
    QueryResultIterable<Key<PackageVersion>> k =
            ofy.query(PackageVersion.class).filter("package_ =", name)
            .fetchKeys();
    ofy.delete(k);
    NWUtils.decrementPackageNumber();
    Index index = NWUtils.getIndex();
    index.delete(p.name);
    NWUtils.incDataVersion();
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
/**
 * Deletes all device subscription entities continuously using task push queue.
 *
 * @param time Threshold time before which entities created will be deleted. If time is null,
 *             current time is used and set as Threshold time.
 * @param cursor Query cursor indicates last query result set position
 */
protected void deleteAllContinuously(Date time, String cursor) {
  if (time == null) {
    time = Calendar.getInstance(TimeZone.getTimeZone("UTC")).getTime();
  }

  Query.FilterPredicate timeFilter = new Query.FilterPredicate(PROPERTY_TIMESTAMP,
      FilterOperator.LESS_THAN_OR_EQUAL, time);
  QueryResultIterable<Entity> entities;
  List<Key> keys = new ArrayList<Key> ();
  List<String> subIds = new ArrayList<String> ();
  Query queryAll;

  queryAll = new Query(DeviceSubscription.SUBSCRIPTION_KIND).setFilter(timeFilter);
  FetchOptions options = FetchOptions.Builder.withLimit(BATCH_DELETE_SIZE);
  if (!StringUtility.isNullOrEmpty(cursor)) {
    options.startCursor(Cursor.fromWebSafeString(cursor));
  }

  entities = this.datastoreService.prepare(queryAll).asQueryResultIterable(options);
  if (entities != null && entities.iterator() != null) {
    for (Entity entity : entities) {
      keys.add(entity.getKey());
      String[] ids = new Gson().fromJson((String) entity.getProperty(PROPERTY_SUBSCRIPTION_IDS),
          String[].class);
      subIds.addAll(Arrays.asList(ids));
    }
  }

  if (keys.size() > 0) {
    deleteInBatch(keys);
    enqueueDeleteDeviceSubscription(time, entities.iterator().getCursor().toWebSafeString());
  }
  if (subIds.size() > 0) {
    deletePsiSubscriptions(subIds);
  }
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
@Test
public void testAsQueryResultIterable() throws Exception {
    QueryResultIterable<Entity> iterable = preparedQuery.asQueryResultIterable();
    assertNotNull(iterable);
    assertNotNull(iterable.iterator());
    assertTrue(iterable.iterator().hasNext());
    assertEquals(john, iterable.iterator().next());
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
@Test
public void testAsQueryResultIterableWithOptions() throws Exception {
    QueryResultIterable<Entity> iterable = preparedQuery.asQueryResultIterable(withDefaults());
    assertNotNull(iterable);
    assertNotNull(iterable.iterator());
    assertTrue(iterable.iterator().hasNext());
    assertEquals(john, iterable.iterator().next());
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
@Override
public final Iterator<? extends Person> iterator(long start, long end) {
    // TODO: use start + end
    QueryResultIterable<Person> personIterable = getLoadType().iterable();
    QueryResultIterator<Person> personIt = personIterable.iterator();
    return personIt;
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
private QueryResultIterable<Entity> executeQueryForIterable(FetchOptions fetchOptions) {
    Query query = new Query("Foo").addSort("bar");
    return service.prepare(query).asQueryResultIterable(fetchOptions);
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
public static QueryResultIterable<RideRecord> getExportableRecords() {
    return OfyService.ofy().query(RideRecord.class)
            .filter("isExportable", true)
            .fetch();
}
 

import com.google.appengine.api.datastore.QueryResultIterable; //导入依赖的package包/类
public static QueryResultIterable<UserProfile> listAll() {
    return OfyService.ofy().query(UserProfile.class).fetch();
}