Java ResultQuery类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.jooq.ResultQuery类的典型用法代码示例。如果您正苦于以下问题：Java ResultQuery类的具体用法？Java ResultQuery怎么用？Java ResultQuery使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ResultQuery类属于org.jooq包，在下文中一共展示了ResultQuery类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: Select

import org.jooq.ResultQuery; //导入依赖的package包/类
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);
      }
    }
  );
}

开发者ID:Trunkplatform，项目名称:tiny-rxjava-jdbc，代码行数:24，代码来源:Select.java

示例2: cleanupServiceEventTable

import org.jooq.ResultQuery; //导入依赖的package包/类
private void cleanupServiceEventTable(Date cutoff) {
    ResultQuery<Record1<Long>> ids = create()
            .select(SERVICE_EVENT.ID)
            .from(SERVICE_EVENT)
            .where(SERVICE_EVENT.CREATED.lt(cutoff))
            .and(SERVICE_EVENT.STATE.eq(CommonStatesConstants.CREATED))
            .limit(QUERY_LIMIT_ROWS.getValue());

    List<Long> toDelete = null;
    int rowsDeleted = 0;
    while ((toDelete = ids.fetch().into(Long.class)).size() > 0) {
        rowsDeleted += create().delete(SERVICE_EVENT)
        .where(SERVICE_EVENT.ID.in(toDelete)).execute();
    }

    if (rowsDeleted > 0) {
        log.info("[Rows Deleted] service_event={}", rowsDeleted);
    }
}

开发者ID:rancher，项目名称:cattle，代码行数:20，代码来源:TableCleanup.java

示例3: select

import org.jooq.ResultQuery; //导入依赖的package包/类
@SuppressWarnings(value={"unused"})
private int select (String tableName, List<String> rows, List<String> columns) {
  Timer timer = Timer.start ("flat-dataset");

  Table<Record> table = tableByName (tableName);    
  List<Field<String>> selectFields = createFieldList (columns);

  ResultQuery<Record> query;
  List<String> rowKeys = getRowKeys (tableName, ID_FIELD_NAME);
  if (rowKeys.size () == rows.size ())
    query = queryAllRows (selectFields, table);
  else {
    query = queryINRows (tableName, selectFields, rows);
  }
  int count = read (query);
  timer.read ();
  return count;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:19，代码来源:TestJooqCursorLUSCLevel2.java

示例4: fetchList

import org.jooq.ResultQuery; //导入依赖的package包/类
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;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:19，代码来源:TestJooqCursorLUSCLevel2.java

示例5: getRowKeys

import org.jooq.ResultQuery; //导入依赖的package包/类
@Synchronized @SuppressWarnings("unused")
private List<String> getRowKeys (String tableName, String fieldRowIdName) {
  Timer timer = Timer.start ("get-row-keys");
  if (this.rowKeys == null) {
    Table<Record> table = tableByName (tableName);
    Field<String> fieldRowId = fieldByName (String.class, fieldRowIdName);
    // get rows
    Timer timer2 = Timer.start ("fetch-array");
    ResultQuery<Record1<String>> queryRowKeys = context.select (fieldRowId).from (table).getQuery ();
    String[] arows = queryRowKeys.fetchArray (fieldRowId);
    timer2.read ();
    // List<String> rows = Arrays.asList (arows);
    timer2 = Timer.start ("copy-array-to-list");
    // this.rowKeys = new ArrayList<String>(arows.length);
    // Collections.addAll (this.rowKeys, arows);
    // this.rowKeys = Arrays.asList (arows);
    this.rowKeys = fetchList (queryRowKeys, ID_FIELD_NAME);
    timer2.read ();

    log.debug ("rows.size(): " + this.rowKeys.size ());
  }
  timer.read ();
  return this.rowKeys;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:25，代码来源:TestJooqCursorLUSCLevel2.java

示例6: select

import org.jooq.ResultQuery; //导入依赖的package包/类
@SuppressWarnings(value={"unused"})
private int select(String tableName, List<String> rows, List<String> columns){
  Timer timer = Timer.start ("flat-dataset");
  
  Table<Record> table = tableByName (tableName);    
  List<Field<String>> selectFields = createFieldList (columns);
  
  ResultQuery<Record> query;    
  List<String> rowKeys = getRowKeys (tableName, ID_FIELD_NAME);    
  if(rowKeys.size ()==rows.size ())
    query = queryAllRows (selectFields, table);
  else{
    query = queryINRows (tableName, selectFields, rows);
  }
  int count = read(query);
  timer.read ();
  return count;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:19，代码来源:TestJooqCursorLGGLevel2.java

示例7: select

import org.jooq.ResultQuery; //导入依赖的package包/类
@SuppressWarnings(value={"unused"})
private int select (String tableName, List<String> rows, List<String> columns) {
  Timer timer = Timer.start ("flat-dataset");

  Table<Record> table = tableByName (tableName);
  Field<String> fieldRowId = fieldByName (String.class, ID_FIELD_NAME);
  List<Field<String>> selectFields = createFieldList (columns);

  ResultQuery<Record> query;
  List<String> rowKeys = getRowKeys (tableName, ID_FIELD_NAME);
  if (rowKeys.size () == rows.size ())
    query = queryAllRows (selectFields, table);
  else {
    query = queryINRows (tableName, selectFields, rows);
  }
  int count = read (query);
  timer.read ();
  return count;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:20，代码来源:TestJooqCursorGBMLevel2.java

示例8: getRowKeys

import org.jooq.ResultQuery; //导入依赖的package包/类
@Synchronized 
private List<String> getRowKeys(String tableName, String fieldRowIdName){
  if(rowCasche.containsKey (tableName)){
    return rowCasche.get (tableName);
  }else{
    
    Table<Record> table = tableByName (tableName);
    Field<String> fieldRowId = fieldByName (String.class, fieldRowIdName);
    //get rows
    Timer timer = Timer.start ("get-row-keys");      
    ResultQuery<Record1<String>> queryRowKeys =context.select(fieldRowId).from(table).orderBy (fieldRowId).getQuery ();      
    String[] arows = queryRowKeys.fetchArray (fieldRowId);
    timer.read ("fetch-array");
//    List<String> rows = Arrays.asList (arows);
    List<String> rows = new ArrayList<String>(arows.length);      
    Collections.addAll (rows, arows);
    timer.read ("collection");      
    if(log.isDebugEnabled ()){
      timer.read();
      log.debug ("rows.size(): " + rows.size ());
    }
    rowCasche.put (tableName, rows);
    return rows;
  }
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:26，代码来源:PresetDimensionBuilderFlatTable.java

示例9: getColumnKeys

import org.jooq.ResultQuery; //导入依赖的package包/类
private List<String> getColumnKeys(String tableName, String fieldRowIdName){
  //get columns
  Table<Record> table = tableByName (tableName);    
  Timer timer = Timer.start ("get-column-keys");
  ResultQuery<Record> queryColumnKeys =context.selectFrom(table).limit (1) .getQuery ();
  Record recordColumnKeys = queryColumnKeys.fetchOne ();
  List<String> columns = new ArrayList<String>();
  for(Field<?> field : recordColumnKeys.fields())
    if(!field.getName ().equals (ID_FIELD_NAME))
      columns.add (field.getName ());
  
  if(log.isDebugEnabled ()){
    timer.read();
    log.debug ("columns.size(): " + columns.size ());
    log.debug ("columns: " + columns);
  }
  return columns;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:19，代码来源:PresetDimensionBuilderFlatTable.java

示例10: getAsStream

import org.jooq.ResultQuery; //导入依赖的package包/类
@Override
  public InputStream getAsStream (Dimension dimension) {
    
//    SelectQuery<Tables> query = context.selectQuery()
    
    Table<?>  table = tableByName (TABLE_NAME_PREFIX+this.platformId ());
    Field<String> probeId = fieldByName (String.class, "PROBESET_ID");
    
    InputStream input=null;    
    ResultQuery<?> query = context.selectFrom(table)
            .where(probeId.in (dimension.keys ()));
     log.debug(query.toString ());
     String csv = query.fetch().formatCSV('\t');
     try {
      input = new ByteArrayInputStream (csv.getBytes ("UTF-8"));
    } catch (UnsupportedEncodingException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    return input;
  }

开发者ID:dfci-cccb，项目名称:mev，代码行数:22，代码来源:JooqProbeAnnotations.java

示例11: SelectProducer

import org.jooq.ResultQuery; //导入依赖的package包/类
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;
}

开发者ID:Trunkplatform，项目名称:tiny-rxjava-jdbc，代码行数:12，代码来源:SelectProducer.java

示例12: setupUnsubscription

import org.jooq.ResultQuery; //导入依赖的package包/类
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);
      }
    )
  );
}

开发者ID:Trunkplatform，项目名称:tiny-rxjava-jdbc，代码行数:15，代码来源:Select.java

示例13: limit

import org.jooq.ResultQuery; //导入依赖的package包/类
private ResultQuery<Record> limit(Integer startPos, Integer maxRows, SelectSeekStep1<Record, Timestamp> selectSeekStep) {
	if (maxRows != null) {
		if (startPos == null) {
			startPos = 0;
		}
		return selectSeekStep.limit(startPos, maxRows);
	} else {
		return selectSeekStep;
	}
}

开发者ID:oglimmer，项目名称:lunchy，代码行数:11，代码来源:UpdatesDao.java

示例14: toQuery

import org.jooq.ResultQuery; //导入依赖的package包/类
protected ResultQuery<?> toQuery(Class<?> clz, Map<Object, Object> values) {
    String type = schemaFactory.getSchemaName(clz);
    if (type == null) {
        throw new IllegalArgumentException("Failed to find type of class [" + clz + "]");
    }
    Class<UpdatableRecord<?>> recordClass = JooqUtils.getRecordClass(schemaFactory, clz);
    Table<?> table = JooqUtils.getTableFromRecordClass(recordClass);
    return create().selectFrom(table).where(JooqUtils.toConditions(metaDataManager, type, values));
}

开发者ID:rancher，项目名称:cattle，代码行数:10，代码来源:JooqObjectManager.java

示例15: toQuery

import org.jooq.ResultQuery; //导入依赖的package包/类
protected ResultQuery<?> toQuery(Class<?> clz, Map<Object, Object> values) {
    String type = schemaFactory.getSchemaName(clz);
    if ( type == null ) {
        throw new IllegalArgumentException("Failed to find type of class [" + clz + "]");
    }
    Class<UpdatableRecord<?>> recordClass = JooqUtils.getRecordClass(schemaFactory, clz);
    Table<?> table = JooqUtils.getTableFromRecordClass(recordClass);
    return create()
            .selectFrom(table)
            .where(JooqUtils.toConditions(metaDataManager, type, values));
}

开发者ID:cloudnautique，项目名称:cloud-cattle，代码行数:12，代码来源:JooqObjectManager.java

示例16: testSimpleSelectAll

import org.jooq.ResultQuery; //导入依赖的package包/类
@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);
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:31，代码来源:TestJooqCursorLUSCLevel2.java

示例17: queryINRows

import org.jooq.ResultQuery; //导入依赖的package包/类
private ResultQuery<Record> queryINRows (String tableName, List<Field<String>> selectFields, List<String> rows) {
  Table<Record> table = tableByName (tableName);
  Field<String> fieldRowId = fieldByName (String.class, ID_FIELD_NAME);
  return context.select (selectFields)
                .from (table).where (fieldRowId.in (rows))
                .getQuery ();
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:8，代码来源:TestJooqCursorLUSCLevel2.java

示例18: queryRowByID

import org.jooq.ResultQuery; //导入依赖的package包/类
private ResultQuery<Record> queryRowByID (String tableName, List<Field<String>> selectFields, String row) {
  Table<Record> table = tableByName (tableName);
  Field<String> fieldRowId = fieldByName (String.class, ID_FIELD_NAME);
  return context.select (selectFields)
                .from (table).where (fieldRowId.eq (row))
                .getQuery ();
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:8，代码来源:TestJooqCursorLUSCLevel2.java

示例19: select2

import org.jooq.ResultQuery; //导入依赖的package包/类
/**
   * @param tableName
   * @param rows
   * @param columns
   * @return
   */
  @SuppressWarnings(value={"all"})
  private int select2 (String tableName, List<String> rows, List<String> columns) {
    Timer timer = Timer.start ("flat-dataset");

    Table<Record> table = tableByName (tableName);
    Field<String> fieldRowId = fieldByName (String.class, ID_FIELD_NAME);
    List<Field<String>> selectFields = createFieldList (columns);

    int totalCellCount = 0;
    ResultQuery<Record> query;
    List<String> rowKeys = getRowKeys (tableName, ID_FIELD_NAME);
    if(rowKeys.size ()==rows.size ()){
    // TODO:hardcoded data size for test only
//    if (90797 == rows.size ()){
      query = queryAllRows (selectFields, table);
      totalCellCount = read (query);
    }else {
      final int FETCH_LIMIT = 1;

      List<String> batchRows = new ArrayList<String> (FETCH_LIMIT);
      for (String row : rows) {
        batchRows.add (row);
        if (batchRows.size () % FETCH_LIMIT == 0) {
          if (FETCH_LIMIT == 1)
            query = queryRowByID (tableName, selectFields, row);
          else
            query = queryINRows (tableName, selectFields, rows);
          totalCellCount += read (query);
          batchRows = new ArrayList<String> (FETCH_LIMIT); // reset
        }
      }
      if (batchRows.size () > 0) {
        query = queryINRows (tableName, selectFields, rows);
        totalCellCount += read (query);
      }
    }
    timer.read ();
    return totalCellCount;
  }

开发者ID:dfci-cccb，项目名称:mev，代码行数:46，代码来源:TestJooqCursorLUSCLevel2.java

示例20: read

import org.jooq.ResultQuery; //导入依赖的package包/类
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;
}

开发者ID:dfci-cccb，项目名称:mev，代码行数:34，代码来源:TestJooqCursorLUSCLevel2.java

注：本文中的org.jooq.ResultQuery类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java IncorrectnessListener类代码示例发布时间：2022-05-23

Java DictValue类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：9278|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：6600|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：5493|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：5981|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：5849|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：6225|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：5805|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：5274|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：5648|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：4997|2022-11-06

客服电话

电子邮件

Java ResultQuery类代码示例

示例1: Select

示例2: cleanupServiceEventTable

示例3: select

示例4: fetchList

示例5: getRowKeys

示例6: select

示例7: select

示例8: getRowKeys

示例9: getColumnKeys

示例10: getAsStream

示例11: SelectProducer

示例12: setupUnsubscription

示例13: limit

示例14: toQuery

示例15: toQuery

示例16: testSimpleSelectAll

示例17: queryINRows

示例18: queryRowByID

示例19: select2

示例20: read

请发表评论

全部评论

上一篇：

下一篇：

rappasoft/laravel-authentication-log: Lo

PacktPublishing/Python-Machine-Learning-

sussillo/hfopt-matlab: A parallel, cpu-b

鲁东大学一米网:Win7系统USB驱动器RAM的操

emersion/go-ostatus: An OStatus library

剪的笔顺,诠释剪的笔画,认识剪的部首

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

六六分期app的软件客服如何联系？(六六分期

doraiso/Mastodon

关于我们

产品与服务

解决方案

139-2527-9053