com.psddev.dari.db.Query.iterable()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(175)

本文整理了Java中com.psddev.dari.db.Query.iterable方法的一些代码示例,展示了Query.iterable的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.iterable方法的具体详情如下:
包路径:com.psddev.dari.db.Query
类名称:Query
方法名:iterable

Query.iterable介绍

[英]Returns an iterable of all objects matching this query in a #getDatabase.
[中]返回#getDatabase中与此查询匹配的所有对象的iterable。

代码示例

代码示例来源:origin: perfectsense/brightspot-cms

  1. public DirectoryQueryIterator(Query<Directory> directoryQuery) {
  2. this.directoryIterator = directoryQuery.iterable(0).iterator();
  3. }

代码示例来源:origin: perfectsense/dari

  1. /**
  2. * Creates a new instance that runs in the given {@code executor},
  3. * and produces items that match the given {@code query} from the
  4. * given {@code database} into the given {@code output} queue.
  5. *
  6. * @param executor If {@code null}, uses the default executor.
  7. * @param output If {@code null}, creates a new queue.
  8. * @param database Can't be {@code null}.
  9. * @param query Can't be {@code null}.
  10. * @throws IllegalArgumentException If the given {@code database}
  11. * or {@code query} is {@code null}.
  12. */
  13. public AsyncDatabaseReader(
  14. String executor,
  15. AsyncQueue<E> output,
  16. Database database,
  17. Query<E> query) {
  18. super(executor, output);
  19. if (database == null) {
  20. throw new IllegalArgumentException("Database can't be null!");
  21. }
  22. if (query == null) {
  23. throw new IllegalArgumentException("Query can't be null!");
  24. }
  25. this.iterator = query.using(database).iterable(0).iterator();
  26. }

代码示例来源:origin: perfectsense/brightspot-cms

  1. @Override
  2. public Iterable<? extends ToolUser> getUsers() {
  3. return Query.from(ToolUser.class).where("role = ?", this).iterable(0);
  4. }

代码示例来源:origin: perfectsense/dari

  1. Iterator<E> iterator = iterable(0).iterator();
  2. List<E> items = new ArrayList<E>();

代码示例来源:origin: perfectsense/brightspot-cms

  1. .noCache()
  2. .resolveInvisible()
  3. .iterable(0)) {

代码示例来源:origin: perfectsense/brightspot-cms

  1. private void writeCsvResponse(Context page) throws IOException {
  2. HttpServletResponse response = page.getResponse();
  3. response.setContentType("text/csv");
  4. response.setHeader("Content-Disposition", "attachment; filename=search-result-" + new DateTime(null, page.getUserDateTimeZone()).toString("yyyy-MM-dd-hh-mm-ss") + ".csv");
  5. page.writeHeaderRow();
  6. Query searchQuery = page.getSearch().toQuery(page.getSite());
  7. if (page.getSelection() != null) {
  8. searchQuery.where(page.getSelection().createItemsQuery().getPredicate());
  9. }
  10. addLegacyDatabaseSupport(searchQuery);
  11. int count = 0;
  12. for (Object item : searchQuery.iterable(0)) {
  13. page.writeDataRow(item);
  14. count++;
  15. if (count % 10000 == 0) {
  16. try {
  17. Thread.sleep(THROTTLE_INTERVAL);
  18. } catch (InterruptedException e) {
  19. LOGGER.error(e.getMessage(), e);
  20. }
  21. }
  22. }
  23. }

代码示例来源:origin: perfectsense/brightspot-cms

  1. Map<String, ContentEditBulkSubmissionError> errors = getErrors();
  2. for (Iterator<?> i = getQuery().iterable(0).iterator(); shouldContinue() && i.hasNext();) {
  3. Object item = i.next();
  4. State itemState = State.getInstance(item);

代码示例来源:origin: perfectsense/brightspot-cms

  1. from(ToolUser.class).
  2. where("notifications = ?", this).
  3. iterable(0)) {
  4. try {
  5. for (NotificationMethod method : receiver.getNotifyVia()) {

代码示例来源:origin: perfectsense/dari

  1. if (deleteFirst) {
  2. LOGGER.info("Deleting all records in database to load " + filename);
  3. for (Object obj : Query.fromAll().where("_type != ?", localObjTypeId).and("_id != ?", globalsId).noCache().using(database).resolveToReferenceOnly().iterable(100)) {
  4. if (!shouldContinue()) {
  5. break;
  6. for (Object obj : Query.fromAll().where("_type = ?", typeIds).and("_type != ?", localObjTypeId).and("_id != ?", globalsId).noCache().using(database).resolveToReferenceOnly().iterable(100)) {
  7. if (!shouldContinue()) {
  8. break;

代码示例来源:origin: perfectsense/dari

  1. for (Object r : Query.fromType(objType).using(database).noCache().resolveToReferenceOnly().iterable(100)) {
  2. writer.write(ObjectUtils.toJson(((Recordable) r).getState().getSimpleValues(true)));
  3. writer.write('\n');
  4. for (Object r : Query.fromType(typeMapType).using(database).noCache().resolveToReferenceOnly().iterable(100)) {
  5. writer.write(ObjectUtils.toJson(((Recordable) r).getState().getSimpleValues(true)));
  6. writer.write('\n');
  7. concreteQuery.where("_type = ?", typeId);
  8. for (Object o : concreteQuery.noCache().resolveToReferenceOnly().iterable(100)) {
  9. if (o instanceof Recordable) {
  10. Recordable r = (Recordable) o;

代码示例来源:origin: perfectsense/dari

  1. iterator = query.iterable(QUERY_ITERABLE_SIZE).iterator();

代码示例来源:origin: perfectsense/brightspot-cms

  1. .where("triggerDate >= ? and triggerDate < ?", begin, end)
  2. .sortAscending("triggerDate")
  3. .iterable(0)) {

代码示例来源:origin: perfectsense/brightspot-cms

  1. .and("com.psddev.cms.db.Draft/objectId = ?", object)
  2. .resolveInvisible()
  3. .iterable(0)) {
  4. if (!(dObject instanceof Draft)) {
  5. continue;

代码示例来源:origin: perfectsense/brightspot-cms

  1. Iterator queryIterator = page.itemsQuery().noCache().iterable(0).iterator();

代码示例来源:origin: perfectsense/brightspot-cms

  1. .where("triggerDate >= ? and triggerDate < ?", begin, end)
  2. .sortAscending("triggerDate")
  3. .iterable(0)) {

代码示例来源:origin: perfectsense/brightspot-cms

  1. for (Workflow w : workflowQuery.iterable(0)) {
  2. for (WorkflowState s : w.getStates()) {
  3. workflowStateLabels.put("ws." + s.getName(), s.getDisplayName());

代码示例来源:origin: perfectsense/brightspot-cms

  1. for (Object item : query.noCache().iterable(0)) {
  2. State itemState = State.getInstance(item);
  3. Iterator<Object> queryIterator = query.noCache().iterable(0).iterator();

代码示例来源:origin: perfectsense/dari

  1. long matched = 0;
  2. for (Object item : query.iterable(0)) {
  3. ++ total;
  4. if (total % 1000 == 0) {

相关文章