Java 类org.jooq.Cursor 实例源码

项目：tiny-rxjava-jdbc 文件：Select.java

private Select(
  Connection connection,
  QueryBuilder<ResultQuery<? extends R>> queryBuilder,
  RecordMapper<? super R, ? extends T> recordMapper
) {
  super(
    subscriber -> {
      try (ResultQuery<? extends R> query = queryBuilder.build(connection)) {
        Cursor<? extends R> cursor = query.fetchLazy();
        setupUnsubscription(subscriber, query, cursor);
        log.debug("Select setProducer for  {}", query);
        subscriber.setProducer(new SelectProducer<>(
          subscriber,
          query,
          cursor,
          recordMapper
        ));
      } catch (Throwable t) {
        handleException(t, subscriber);
      }
    }
  );
}

项目：cloud-cattle 文件：SimpleAllocatorDaoImpl.java

protected Iterator<AllocationCandidate> iteratorHosts(List<Long> volumes, QueryOptions options, boolean hosts,
        AllocationCandidateCallback callback) {
    final Cursor<Record2<Long,Long>> cursor = create()
            .select(HOST.ID, STORAGE_POOL.ID)
            .from(HOST)
            .leftOuterJoin(STORAGE_POOL_HOST_MAP)
                .on(STORAGE_POOL_HOST_MAP.HOST_ID.eq(HOST.ID)
                    .and(STORAGE_POOL_HOST_MAP.REMOVED.isNull()))
            .join(STORAGE_POOL)
                .on(STORAGE_POOL.ID.eq(STORAGE_POOL_HOST_MAP.STORAGE_POOL_ID))
            .leftOuterJoin(AGENT)
                .on(AGENT.ID.eq(HOST.AGENT_ID))
            .where(
                AGENT.ID.isNull().or(AGENT.STATE.eq(CommonStatesConstants.ACTIVE))
                .and(HOST.STATE.eq(CommonStatesConstants.ACTIVE))
                .and(STORAGE_POOL.STATE.eq(CommonStatesConstants.ACTIVE))
                .and(getQueryOptionCondition(options)))
            .orderBy(SPREAD.get() ? HOST.COMPUTE_FREE.desc() : HOST.COMPUTE_FREE.asc())
            .fetchLazy();

    return new AllocationCandidateIterator(objectManager, cursor, volumes, hosts, callback);
}

项目：dstack 文件：SimpleAllocatorDaoImpl.java

protected Iterator<AllocationCandidate> iteratorHosts(List<Long> volumes, QueryOptions options, boolean hosts) {
    final Cursor<Record2<Long,Long>> cursor = create()
            .select(HOST.ID, STORAGE_POOL.ID)
            .from(HOST)
            .leftOuterJoin(STORAGE_POOL_HOST_MAP)
                .on(STORAGE_POOL_HOST_MAP.HOST_ID.eq(HOST.ID)
                    .and(STORAGE_POOL_HOST_MAP.REMOVED.isNull()))
            .join(STORAGE_POOL)
                .on(STORAGE_POOL.ID.eq(STORAGE_POOL_HOST_MAP.STORAGE_POOL_ID))
            .leftOuterJoin(AGENT)
                .on(AGENT.ID.eq(HOST.AGENT_ID))
            .where(
                AGENT.ID.isNull().or(AGENT.STATE.eq(CommonStatesConstants.ACTIVE))
                .and(HOST.STATE.eq(CommonStatesConstants.ACTIVE))
                .and(STORAGE_POOL.STATE.eq(CommonStatesConstants.ACTIVE))
                .and(getQueryOptionCondition(options)))
            .orderBy(SPREAD.get() ? HOST.COMPUTE_FREE.asc() : HOST.COMPUTE_FREE.desc())
            .fetchLazy();

    return new AllocationCandidateIterator(objectManager, cursor, volumes, hosts);
}

项目：mev 文件：TestJooqCursorLUSCLevel2.java

private List<String> fetchList (ResultQuery<Record1<String>> query, String columnField) {
  Cursor<Record1<String>> cursor = null;
  List<String> result = new ArrayList<String> (1000);
  try {
    cursor = query.fetchLazy ();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext ()) {
      Record record = cursor.fetchOne ();
      String sValue = (String) record.getValue (columnField);
      result.add (sValue);
    }
  } finally {
    if (cursor != null) {
      cursor.close ();
    }
  }
  return result;
}

项目：mev 文件：TestJooqCursorGBMLevel2.java

private List<String> fetchList (ResultQuery<Record1<String>> query, String columnField) {
  Cursor<Record1<String>> cursor = null;
  List<String> result = new ArrayList<String> (1000);
  try {
    cursor = query.fetchLazy ();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext ()) {
      Record record = cursor.fetchOne ();
      String sValue = (String) record.getValue (columnField);
      result.add (sValue);
    }
  } finally {
    if (cursor != null) {
      cursor.close ();
    }
  }
  return result;
}

项目：zipkin 文件：MySQLSpanStore.java

List<DependencyLink> aggregateDependencies(long endTs, @Nullable Long lookback, Connection conn) {
  endTs = endTs * 1000;
  // Lazy fetching the cursor prevents us from buffering the whole dataset in memory.
  Cursor<Record> cursor = context.get(conn)
      .selectDistinct(hasTraceIdHigh.get() ? LINK_FIELDS : LINK_FIELDS_WITHOUT_TRACE_ID_HIGH)
      // left joining allows us to keep a mapping of all span ids, not just ones that have
      // special annotations. We need all span ids to reconstruct the trace tree. We need
      // the whole trace tree so that we can accurately skip local spans.
      .from(ZIPKIN_SPANS.leftJoin(ZIPKIN_ANNOTATIONS)
          // NOTE: we are intentionally grouping only on the low-bits of trace id. This buys time
          // for applications to upgrade to 128-bit instrumentation.
          .on(ZIPKIN_SPANS.TRACE_ID.eq(ZIPKIN_ANNOTATIONS.TRACE_ID).and(
              ZIPKIN_SPANS.ID.eq(ZIPKIN_ANNOTATIONS.SPAN_ID)))
          .and(ZIPKIN_ANNOTATIONS.A_KEY.in(CLIENT_SEND, CLIENT_ADDR, SERVER_RECV, SERVER_ADDR)))
      .where(lookback == null ?
          ZIPKIN_SPANS.START_TS.lessOrEqual(endTs) :
          ZIPKIN_SPANS.START_TS.between(endTs - lookback * 1000, endTs))
      // Grouping so that later code knows when a span or trace is finished.
      .groupBy(hasTraceIdHigh.get()
          ? LINK_GROUP_FIELDS
          : LINK_GROUP_FIELDS_WITHOUT_TRACE_ID_HIGH).fetchLazy();

  Iterator<Iterator<DependencyLinkSpan>> traces =
      new DependencyLinkSpanIterator.ByTraceId(cursor.iterator(), hasTraceIdHigh.get());

  if (!traces.hasNext()) return Collections.emptyList();

  DependencyLinker linker = new DependencyLinker();

  while (traces.hasNext()) {
    linker.putTrace(traces.next());
  }

  return linker.link();
}

项目：tiny-rxjava-jdbc 文件：Util.java

/**
 * Close the cursor quietly
 */
public static <R extends Record> void closeQuietly(Cursor<R> cursor) {
  try {
    if (cursor != null && !cursor.isClosed()) {
      cursor.close();
      log.debug("closed {}", cursor);
    }
  } catch (Exception e) {
    log.debug(e.getMessage(), e);
  }
}

项目：tiny-rxjava-jdbc 文件：SelectProducer.java

public SelectProducer(
  Subscriber<? super T> subscriber,
  ResultQuery<? extends R> query,
  Cursor<? extends R> cursor,
  RecordMapper<? super R, ? extends T> recordMapper
) {
  this.subscriber = subscriber;
  this.query = query;
  this.cursor = cursor;
  this.recordMapper = recordMapper;
}

项目：tiny-rxjava-jdbc 文件：Select.java

private static <R extends Record, T> void setupUnsubscription(
  Subscriber<? super T> subscriber,
  ResultQuery<? extends R> query,
  Cursor<? extends R> cursor
) {
  subscriber.add(
    Subscriptions.create(
      () -> {
        closeQuietly(cursor);
        closeQuietly(query);
      }
    )
  );
}

项目：sandbox-query-benchmark-jooq-hibernate-jdbc 文件：AuthorQueries.java

@Transactional(readOnly = true)
public Collection<AuthorWithBooks> findAuthorsWithBooksJooqFetchLazyOldFashionGroupBy() {

    try (Cursor<Record> records = dslContext.select()
            .from(AUTHOR.leftOuterJoin(BOOK).on(BOOK.AUTHOR_ID.equal(AUTHOR.ID)))
            .fetchLazy()) {

        Map<Long, AuthorWithBooks> booksMap = new HashMap<>();

        for (Record r : records) {

            Long authorId = r.getValue(TAuthor.AUTHOR.ID);

            AuthorWithBooks authorWithBooks = booksMap.get(authorId);

            if (authorWithBooks == null) {
                authorWithBooks = new AuthorWithBooks();
                authorWithBooks.setAuthor(new Author(authorId, r.getValue(TAuthor.AUTHOR.NAME)));
                authorWithBooks.setBooks(new ArrayList<>());
                booksMap.put(authorId, authorWithBooks);
            }

            Book book = new Book(r.getValue(TBook.BOOK.ID), r.getValue(TBook.BOOK.TITLE), authorId);
            authorWithBooks.getBooks().add(book);
        }

        return booksMap.values();
    }
}

项目：cloud-cattle 文件：AllocationCandidateIterator.java

public AllocationCandidateIterator(ObjectManager objectManager, Cursor<Record2<Long,Long>> cursor, List<Long> volumeIds, boolean hosts,
        AllocationCandidateCallback callback) {
    super();
    this.objectManager = objectManager;
    this.volumeIds = volumeIds;
    this.cursor = cursor;
    this.hosts = hosts;
    this.callback = callback;
}

项目：dstack 文件：AllocationCandidateIterator.java

public AllocationCandidateIterator(ObjectManager objectManager, Cursor<Record2<Long,Long>> cursor, List<Long> volumeIds, boolean hosts) {
    super();
    this.objectManager = objectManager;
    this.volumeIds = volumeIds;
    this.cursor = cursor;
    this.hosts = hosts;
}

项目：sem-tag 文件：TagSqlDao.java

@Override
public Iterable<Tag> get(DaoFilter filter) throws DaoException {
    Collection<Condition> conditions = new ArrayList<Condition>();
    if (filter.getTags() != null) {
        conditions.add(Tables.TAGS.RAW_TAG.in(filter.getTags()));
    }
    if (filter.getConcepts() != null) {
        conditions.add(Tables.TAGS.CONCEPT_ID.in(filter.getConceptIds()));
    }
    Cursor<Record> cursor = fetchLazy(conditions);
    return buildTagIterable(cursor);
}

项目：sem-tag 文件：TagSqlDao.java

private Iterable<Tag> buildTagIterable(Cursor<Record> cursor) {
    return new SqlDaoIterable<Tag>(cursor) {
        @Override
        public Tag transform(Record record) throws DaoException {
            return buildTag(record);
        }
    };
}

项目：sem-tag 文件：ConceptSqlDao.java

@Override
public Iterable<Concept> get(DaoFilter filter) throws DaoException {
    Collection<Condition> conditions = new ArrayList<Condition>();
    if (filter.getConceptIds() != null) {
        conditions.add(Tables.CONCEPTS.CONCEPT_ID.in(filter.getConceptIds()));
    }
    Cursor<Record> cursor = fetchLazy(conditions);
    return buildConceptIterable(cursor);
}

项目：sem-tag 文件：ConceptSqlDao.java

private Iterable<Concept> buildConceptIterable(Cursor<Record> cursor) {
    return new SqlDaoIterable<Concept>(cursor) {
        @Override
        public Concept transform(Record record) throws DaoException {
            return buildConcept(record);
        }
    };
}

项目：sem-tag 文件：UserSqLDao.java

@Override
public Iterable<User> get(DaoFilter filter) throws DaoException {
    Collection<Condition> conditions = new ArrayList<Condition>();
    if (filter.getUserIds() != null) {
        conditions.add(Tables.USERS.USER_ID.in(filter.getUserIds()));
    }
    Cursor<Record> cursor = fetchLazy(conditions);
    return buildUserIterable(cursor);
}

项目：sem-tag 文件：UserSqLDao.java

private Iterable<User> buildUserIterable(Cursor<Record> cursor) {
    return new SqlDaoIterable<User>(cursor) {
        @Override
        public User transform(Record record) throws DaoException {
            return buildUser(record);
        }
    };
}

项目：sem-tag 文件：ItemSqlDao.java

@Override
public Iterable<Item> get(DaoFilter filter) throws DaoException {
    Collection<Condition> conditions = new ArrayList<Condition>();
    if (filter.getUserIds() != null) {
        conditions.add(Tables.ITEMS.ITEM_ID.in(filter.getUserIds()));
    }
    Cursor<Record> cursor = fetchLazy(conditions);
    return buildItemIterable(cursor);
}

项目：sem-tag 文件：ItemSqlDao.java

private Iterable<Item> buildItemIterable(Cursor<Record> cursor) {
    return new SqlDaoIterable<Item>(cursor) {
        @Override
        public Item transform(Record record) throws DaoException {
            return buildItem(record);
        }
    };
}

项目：mev 文件：TestJooqCursorLUSCLevel2.java

@Test
@Ignore @SuppressWarnings("unused")
public void testSimpleSelectAll () {
  Table<Record> table = tableByName (tsvFileName);

  long startTime = System.nanoTime ();
  int count = 0;
  ResultQuery<Record> query = context.selectFrom (table);
  // log.debug ("PresetValuesFlatTable sql:"+query.getSQL ());
  Cursor<Record> cursor = null;
  try {
    cursor = query.fetchLazy ();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext ()) {
      Record record = cursor.fetchOne ();
      for (Field<?> columnField : record.fields ()) {
        String value = (String) record.getValue (columnField);
        count++;
      }
    }
  } finally {
    if (cursor != null) {
      cursor.close ();
    }
  }

  long endTime = System.nanoTime ();
  long duration = endTime - startTime;
  log.debug ("flat-count:" + count + ", duration: " + duration);
}

项目：mev 文件：TestJooqCursorLUSCLevel2.java

private int read (ResultQuery<Record> query) {
  Cursor<Record> cursor = null;
  int count = 0;
  try {
    cursor = query.fetchLazy ();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext ()) {
      Record record = cursor.fetchOne ();
      for (Field<?> columnField : record.fields ()) {
        String sValue = (String) record.getValue (columnField);
        @SuppressWarnings("unused") double value = NaN;
        if ("Inf".equalsIgnoreCase (sValue))
          value = POSITIVE_INFINITY;
        else if ("-Inf".equalsIgnoreCase (sValue))
          value = NEGATIVE_INFINITY;
        else if ("NA".equalsIgnoreCase (sValue))
          value = NaN;
        else if ("null".equalsIgnoreCase (sValue))
          value = NaN;
        else if (sValue == null)
          value = NaN;
        else
          value = Double.parseDouble (sValue);
        count++;
      }
    }
  } finally {
    if (cursor != null) {
      cursor.close ();
    }
  }
  return count;
}

项目：mev 文件：TestJooqCursorLGGLevel2.java

@Test @Ignore @SuppressWarnings("unused")
public void testSimpleSelectAll () {
  String tsvFileName="LGG.AgilentG4502A_07_3.Level_2.tsv";
  Table<Record> table = tableByName (tsvFileName);

  long startTime = System.nanoTime();
  int count=0;
  ResultQuery<Record> query =context.selectFrom (table);            
//  log.debug ("PresetValuesFlatTable sql:"+query.getSQL ());      
  Cursor<Record> cursor = null;
  try {
    cursor = query.fetchLazy();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext()) {
        Record record = cursor.fetchOne();
        for(Field<?> columnField: record.fields()){
          String value = (String)record.getValue (columnField);
          count++;
        }
    }
  }finally {
    if (cursor != null) {cursor.close();}
  }

  long endTime = System.nanoTime();
  long duration = endTime - startTime;
  log.debug ("flat-count:"+count+", duration: "+duration);
}

项目：mev 文件：TestJooqCursorLGGLevel2.java

private int read(ResultQuery<Record> query){
  Cursor<Record> cursor = null;
  int count=0;
  try {
    cursor = query.fetchLazy();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext()) {
        Record record = cursor.fetchOne();
        for(Field<?> columnField: record.fields()){
          String sValue = (String)record.getValue (columnField);
          @SuppressWarnings("unused") double value=NaN;
          if ("Inf".equalsIgnoreCase (sValue))
            value = POSITIVE_INFINITY;
          else if ("-Inf".equalsIgnoreCase (sValue))
            value = NEGATIVE_INFINITY;
          else if ("NA".equalsIgnoreCase (sValue))
            value = NaN;
          else if ("null".equalsIgnoreCase (sValue))
            value = NaN;
          else if (sValue==null)
            value = NaN;
          else
            value = Double.parseDouble (sValue);            
          count++;
        }
    }
  }finally {
    if (cursor != null) {cursor.close();}
  }
  return count;
}

项目：mev 文件：TestJooqCursorGBMLevel2.java

@Test
@Ignore @SuppressWarnings("unused")
public void testSimpleSelectAll () {
  Table<Record> table = tableByName (tsvFileName);    

  long startTime = System.nanoTime ();
  int count = 0;
  ResultQuery<Record> query = context.selectFrom (table);
  // log.debug ("PresetValuesFlatTable sql:"+query.getSQL ());
  Cursor<Record> cursor = null;
  try {
    cursor = query.fetchLazy ();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext ()) {
      Record record = cursor.fetchOne ();
      for (Field<?> columnField : record.fields ()) {
        String value = (String) record.getValue (columnField);
        count++;
      }
    }
  } finally {
    if (cursor != null) {
      cursor.close ();
    }
  }

  long endTime = System.nanoTime ();
  long duration = endTime - startTime;
  log.debug ("flat-count:" + count + ", duration: " + duration);
}

项目：mev 文件：TestJooqCursorGBMLevel2.java

@SuppressWarnings("unused")
private int read (ResultQuery<Record> query) {
  Cursor<Record> cursor = null;
  int count = 0;
  try {
    cursor = query.fetchLazy ();
    // Cursor has similar methods as Iterator<R>
    while (cursor.hasNext ()) {
      Record record = cursor.fetchOne ();
      for (Field<?> columnField : record.fields ()) {
        String sValue = (String) record.getValue (columnField);
        double value = NaN;
        if ("Inf".equalsIgnoreCase (sValue))
          value = POSITIVE_INFINITY;
        else if ("-Inf".equalsIgnoreCase (sValue))
          value = NEGATIVE_INFINITY;
        else if ("NA".equalsIgnoreCase (sValue))
          value = NaN;
        else if ("null".equalsIgnoreCase (sValue))
          value = NaN;
        else if (sValue == null)
          value = NaN;
        else
          value = Double.parseDouble (sValue);
        count++;
      }
    }
  } finally {
    if (cursor != null) {
      cursor.close ();
    }
  }
  return count;
}

项目：mev 文件：PresetValuesFlatTableIterable.java

private Cursor<Record> openCursor(){
      Timer timer = Timer.start ("open-cursor");
      Cursor<Record> cursor;
      ResultQuery<Record> query=null;
      try{
//        query = queryHelper.queryAllRows (fieldList, table);
        query = queryHelper.queryINRows (fieldList, rows.keys (), table);
        cursor = query.fetchLazy ();
      }finally{
        if(query!=null) query.close();            
      }
      timer.read ();
      return cursor;
    }

项目：sem-tag 文件：SqlDaoIterable.java

/**
 * Constructs a SqlDaoIterable that generates E objects from result.
 * @param result a collection of Records to be converted into outputs
 */
public SqlDaoIterable(Cursor<Record> result){
    this.result = result;
    this.iterator = result.iterator();
}