org.skife.jdbi.v2.Query.setMaxRows()方法的使用及代码示例

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

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

Query.setMaxRows介绍

[英]Specify the maimum number of rows the query is to return. This uses the underlying JDBC Statement#setMaxRows(int)}.
[中]指定查询要返回的最大行数。它使用底层JDBC语句#setMaxRows(int)}。

代码示例

代码示例来源:origin: apache/incubator-druid

  1. @Override
  2. public List<AuditEntry> withHandle(Handle handle)
  3. {
  4. Query<Map<String, Object>> query = handle.createQuery(theQueryString);
  5. if (key != null) {
  6. query.bind("audit_key", key);
  7. }
  8. return query.bind("type", type)
  9. .setMaxRows(theLimit)
  10. .map(
  11. new ResultSetMapper<AuditEntry>()
  12. {
  13. @Override
  14. public AuditEntry map(int index, ResultSet r, StatementContext ctx)
  15. throws SQLException
  16. {
  17. try {
  18. return jsonMapper.readValue(r.getBytes("payload"), AuditEntry.class);
  19. }
  20. catch (IOException e) {
  21. throw new SQLException(e);
  22. }
  23. }
  24. }
  25. )
  26. .list();
  27. }
  28. }

代码示例来源:origin: org.kill-bill.commons/killbill-jdbi

  1. @Override
  2. public void apply(SQLStatement q) throws SQLException
  3. {
  4. assert q instanceof Query;
  5. ((Query)q).setMaxRows(va);
  6. }
  7. };

代码示例来源:origin: com.ning.billing/killbill-osgi-bundles-analytics

  1. public void apply(SQLStatement q) throws SQLException
  2. {
  3. assert q instanceof Query;
  4. ((Query)q).setMaxRows(va);
  5. }
  6. };

代码示例来源:origin: org.kill-bill.commons/killbill-jdbi

  1. @Override
  2. public void apply(SQLStatement q) throws SQLException
  3. {
  4. assert q instanceof Query;
  5. ((Query)q).setMaxRows(va);
  6. }
  7. };

代码示例来源:origin: org.kill-bill.commons/killbill-jdbi

  1. @Override
  2. public void apply(SQLStatement q) throws SQLException
  3. {
  4. assert q instanceof Query;
  5. ((Query)q).setMaxRows(va);
  6. }
  7. };

代码示例来源:origin: com.ning.billing/killbill-osgi-bundles-analytics

  1. public void apply(SQLStatement q) throws SQLException
  2. {
  3. assert q instanceof Query;
  4. ((Query)q).setMaxRows(va);
  5. }
  6. };

代码示例来源:origin: com.ning.billing/killbill-osgi-bundles-analytics

  1. public void apply(SQLStatement q) throws SQLException
  2. {
  3. assert q instanceof Query;
  4. ((Query)q).setMaxRows(va);
  5. }
  6. };

代码示例来源:origin: com.nesscomputing.migratory/migratory-core

  1. public static int getInteger(final Handle handle, final String query)
  2. {
  3. return handle.createQuery(query)
  4. .map(IntegerMapper.FIRST)
  5. // Work around an *incredibly* obscure bug in hsqldb 1.8.0.x where setMaxRows(1)
  6. // (which first does) will only return 0 (no rows) or 1 (rows) for COUNT(*)
  7. .setMaxRows(0)
  8. .first();
  9. }
  10. }

代码示例来源:origin: org.apache.druid/druid-server

  1. @Override
  2. public List<AuditEntry> withHandle(Handle handle)
  3. {
  4. Query<Map<String, Object>> query = handle.createQuery(theQueryString);
  5. if (key != null) {
  6. query.bind("audit_key", key);
  7. }
  8. return query.bind("type", type)
  9. .setMaxRows(theLimit)
  10. .map(
  11. new ResultSetMapper<AuditEntry>()
  12. {
  13. @Override
  14. public AuditEntry map(int index, ResultSet r, StatementContext ctx)
  15. throws SQLException
  16. {
  17. try {
  18. return jsonMapper.readValue(r.getBytes("payload"), AuditEntry.class);
  19. }
  20. catch (IOException e) {
  21. throw new SQLException(e);
  22. }
  23. }
  24. }
  25. )
  26. .list();
  27. }
  28. }

代码示例来源:origin: io.druid/druid-server

  1. @Override
  2. public List<AuditEntry> withHandle(Handle handle) throws Exception
  3. {
  4. Query<Map<String, Object>> query = handle.createQuery(theQueryString);
  5. if (key != null) {
  6. query.bind("audit_key", key);
  7. }
  8. return query.bind("type", type)
  9. .setMaxRows(theLimit)
  10. .map(
  11. new ResultSetMapper<AuditEntry>()
  12. {
  13. @Override
  14. public AuditEntry map(int index, ResultSet r, StatementContext ctx)
  15. throws SQLException
  16. {
  17. try {
  18. return jsonMapper.readValue(r.getBytes("payload"), AuditEntry.class);
  19. }
  20. catch (IOException e) {
  21. throw new SQLException(e);
  22. }
  23. }
  24. }
  25. )
  26. .list();
  27. }
  28. }

代码示例来源:origin: org.jdbi/jdbi

  1. @Test
  2. public void testStatementCustomizersPersistAfterMap() throws Exception
  3. {
  4. h.insert("insert into something (id, name) values (?, ?)", 1, "hello");
  5. h.insert("insert into something (id, name) values (?, ?)", 2, "world");
  6. List<Something> rs = h.createQuery("select id, name from something")
  7. .setMaxRows(1)
  8. .map(Something.class)
  9. .list();
  10. assertEquals(1, rs.size());
  11. }

代码示例来源:origin: org.kill-bill.commons/killbill-jdbi

  1. @Test
  2. public void testStatementCustomizersPersistAfterMap() throws Exception
  3. {
  4. h.insert("insert into something (id, name) values (?, ?)", 1, "hello");
  5. h.insert("insert into something (id, name) values (?, ?)", 2, "world");
  6. List<Something> rs = h.createQuery("select id, name from something")
  7. .setMaxRows(1)
  8. .map(Something.class)
  9. .list();
  10. assertEquals(1, rs.size());
  11. }

相关文章