com.datastax.driver.core.querybuilder.Select.limit()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(333)

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

Select.limit介绍

[英]Adds a LIMIT clause to this statement.
[中]在此语句中添加限制子句。

代码示例

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

  1. /**
  2.  * Adds a bind marker for the {@code LIMIT} clause to the {@code SELECT} statement this {@code
  3.  * WHERE} clause is part of.
  4.  *
  5.  * @param limit the bind marker to use as limit.
  6.  * @return the {@code SELECT} statement this {@code WHERE} clause is part of.
  7.  * @throws IllegalStateException if a {@code LIMIT} clause has already been provided.
  8.  */
  9. public Select limit(BindMarker limit) {
  10.  return statement.limit(limit);
  11. }

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

  1. /**
  2.  * Adds a {@code LIMIT} clause to the {@code SELECT} statement this {@code WHERE} clause is part
  3.  * of.
  4.  *
  5.  * @param limit the limit to set.
  6.  * @return the {@code SELECT} statement this {@code WHERE} clause is part of.
  7.  * @throws IllegalArgumentException if {@code limit <= 0}.
  8.  * @throws IllegalStateException if a {@code LIMIT} clause has already been provided.
  9.  */
  10. public Select limit(int limit) {
  11.  return statement.limit(limit);
  12. }

代码示例来源：origin: hugegraph/hugegraph

  1. String page = query.page();
  2. if (page == null) {
  3.   select.limit((int) total);
  4. } else {
  5.   select.setFetchSize((int) total);

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

  1. /**
  2.  * Adds a bind marker for the {@code LIMIT} clause to the {@code SELECT} statement this
  3.  * {@code WHERE} clause if part of.
  4.  *
  5.  * @param limit the bind marker to use as limit.
  6.  * @return the {@code SELECT} statement this {@code WHERE} clause if part of.
  7.  * @throws IllegalStateException if a {@code LIMIT} clause has already been
  8.  *                               provided.
  9.  */
  10. public Select limit(BindMarker limit) {
  11.   return statement.limit(limit);
  12. }

代码示例来源：origin: com.yugabyte/cassandra-driver-core

  1. /**
  2.  * Adds a bind marker for the {@code LIMIT} clause to the {@code SELECT} statement this
  3.  * {@code WHERE} clause if part of.
  4.  *
  5.  * @param limit the bind marker to use as limit.
  6.  * @return the {@code SELECT} statement this {@code WHERE} clause if part of.
  7.  * @throws IllegalStateException if a {@code LIMIT} clause has already been
  8.  *                               provided.
  9.  */
  10. public Select limit(BindMarker limit) {
  11.   return statement.limit(limit);
  12. }

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

  1. /**
  2.  * Adds a bind marker for the {@code LIMIT} clause to the {@code SELECT} statement this
  3.  * {@code WHERE} clause if part of.
  4.  *
  5.  * @param limit the bind marker to use as limit.
  6.  * @return the {@code SELECT} statement this {@code WHERE} clause if part of.
  7.  * @throws IllegalStateException if a {@code LIMIT} clause has already been
  8.  *                               provided.
  9.  */
  10. public Select limit(BindMarker limit) {
  11.   return statement.limit(limit);
  12. }

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

  1. assertThat(select().all().from("foo").perPartitionLimit(bindMarker("limit")).toString())
  2.   .isEqualTo("SELECT * FROM foo PER PARTITION LIMIT :limit;");
  3. assertThat(select().all().from("foo").perPartitionLimit(2).limit(bindMarker()).toString())
  4.   .isEqualTo("SELECT * FROM foo PER PARTITION LIMIT 2 LIMIT ?;");
  5. assertThat(
  6.       .where(in("a", 2, 4))
  7.       .perPartitionLimit(2)
  8.       .limit(3)
  9.       .toString())
  10.   .isEqualTo("SELECT * FROM foo WHERE a IN (2,4) PER PARTITION LIMIT 2 LIMIT 3;");
  11.       .where(eq("a", bindMarker()))
  12.       .perPartitionLimit(bindMarker())
  13.       .limit(3)
  14.       .toString())
  15.   .isEqualTo("SELECT * FROM foo WHERE a=? PER PARTITION LIMIT ? LIMIT 3;");
  16.       .orderBy(desc("b"))
  17.       .perPartitionLimit(2)
  18.       .limit(3)
  19.       .toString())
  20.   .isEqualTo("SELECT * FROM foo WHERE a=? ORDER BY b DESC PER PARTITION LIMIT 2 LIMIT 3;");
  21.       .orderBy(desc("b"))
  22.       .perPartitionLimit(bindMarker())
  23.       .limit(3)
  24.       .allowFiltering()
  25.       .toString())

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

  1. .and(eq(quote("C"), "foo"))
  2.     .orderBy(asc("a"), desc("b"))
  3.     .limit(42);
  4. assertEquals(select.toString(), query);
  5.     .as("ttla")
  6.     .from("foo")
  7.     .limit(bindMarker("limit"));
  8. assertEquals(select.toString(), query);
  9.     .cast(fcall("writetime", column("country")), DataType.text())
  10.     .from("artists")
  11.     .limit(2);
  12. assertEquals(select.toString(), query);
  13. select = select().raw("CAST(writetime(country) AS text)").from("artists").limit(2);
  14. assertEquals(select.toString(), query);
  15.  select().all().from("foo").limit(-42);
  16.  fail("Expected an IllegalArgumentException");
  17. } catch (IllegalArgumentException e) {
  18.  select().all().from("foo").limit(42).limit(42);
  19.  fail("Expected an IllegalStateException");
  20. } catch (IllegalStateException e) {

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

  1. @Override
  2. public CheckResult check() {
  3.  if (closeCalled) throw new IllegalStateException("closed");
  4.  CassandraSpanConsumer maybeConsumer = spanConsumer;
  5.  if (maybeConsumer != null) maybeConsumer.clear();
  6.  try {
  7.   session.get().execute(QueryBuilder.select("trace_id").from("traces").limit(1));
  8.  } catch (RuntimeException e) {
  9.   return CheckResult.failed(e);
  10.  }
  11.  return CheckResult.OK;
  12. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-cassandra

  1. @Override public CheckResult check() {
  2.  try {
  3.   session.get().execute(QueryBuilder.select("trace_id").from("traces").limit(1));
  4.  } catch (RuntimeException e) {
  5.   return CheckResult.failed(e);
  6.  }
  7.  return CheckResult.OK;
  8. }

代码示例来源：origin: scalar-labs/scalardb

  1. private Select prepare(Scan scan) {
  2.  Select select = getSelect(scan);
  3.  createStatement(select.where(), scan);
  4.  List<Ordering> orderings = getOrderings(scan.getOrderings());
  5.  if (!orderings.isEmpty()) {
  6.   select.orderBy(orderings.toArray(new Ordering[orderings.size()]));
  7.  }
  8.  if (scan.getLimit() > 0) {
  9.   select.limit(scan.getLimit());
  10.  }
  11.  return select;
  12. }

代码示例来源：origin: tech.aroma.banana/banana-data-operations

  1. private Statement createQueryForRecentlyCreatedApps()
  2. {
  3.   return queryBuilder
  4.     .select()
  5.     .all()
  6.     .from(TABLE_NAME_RECENTLY_CREATED)
  7.     .limit(200)
  8.     .allowFiltering();
  9. }

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

  1. .from(table)
  2.         .groupBy("a", "b")
  3.         .limit(2)))
  4. .containsExactly(row(1, 2, 6, 2L, 12), row(1, 4, 12, 2L, 24));
  5.         .groupBy("a", "b")
  6.         .perPartitionLimit(1)
  7.         .limit(2)))
  8. .containsExactly(row(1, 2, 6, 2L, 12), row(2, 2, 6, 1L, 6));
  9.   session().execute(select("a", count("a")).distinct().from(table).groupBy("a").limit(2)))
  10. .containsExactly(row(1, 1L), row(2, 1L));
  11.         .where(eq("a", 1))
  12.         .groupBy("a", "b", "c")
  13.         .limit(2)))
  14. .containsExactly(row(1, 2, 6, 1L, 6), row(1, 2, 12, 1L, 12));
  15.         .groupBy("a", "b", "c")
  16.         .orderBy(desc("b"), desc("c"))
  17.         .limit(2)))
  18. .containsExactly(row(1, 4, 24, 2L, 24), row(1, 2, 12, 1L, 12));
  19.         .where(in("a", 1, 2, 4))
  20.         .groupBy("a")
  21.         .limit(2)))
  22. .containsExactly(row(1, 1L), row(2, 1L));
  23.         .groupBy("a", "b")

代码示例来源：origin: tech.aroma/aroma-data-operations

  1. private Statement createQueryToFindMessagesByApplication(String applicationId)
  2. {
  3.   UUID appId = UUID.fromString(applicationId);
  4.   return QueryBuilder
  5.       .select()
  6.       .all()
  7.       .from(Messages.TABLE_NAME)
  8.       .where(eq(APP_ID, appId))
  9.       .orderBy(desc(MESSAGE_ID))
  10.       .limit(3000);
  11. }

代码示例来源：origin: tech.aroma.banana/banana-data-operations

  1. private Statement createQueryToFindMessagesByApplication(String applicationId)
  2. {
  3.   UUID appId = UUID.fromString(applicationId);
  4.   
  5.   return queryBuilder
  6.     .select()
  7.     .all()
  8.     .from(Messages.TABLE_NAME)
  9.     .where(eq(APP_ID, appId))
  10.     .orderBy(desc(MESSAGE_ID))
  11.     .limit(3000);
  12. }

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

  1. row(4, 1, 1));
  2. assertThat(session().execute(select().all().from("test_ppl").perPartitionLimit(2).limit(6)))
  3.   .hasSize(6);
  4. assertThat(session().execute(select().all().from("test_ppl").perPartitionLimit(2).limit(5)))
  5.   .contains(row(0, 0, 0), row(0, 1, 1), row(1, 0, 0), row(1, 1, 1), row(2, 0, 0));
  6.           .where(in("a", 2, 3))
  7.           .perPartitionLimit(bindMarker())
  8.           .limit(3)
  9.           .getQueryString(),
  10.         2))
  11.           .where(in("a", 1, 2, 3))
  12.           .perPartitionLimit(bindMarker())
  13.           .limit(3)
  14.           .getQueryString(),
  15.         2))

代码示例来源：origin: org.apache.metamodel/MetaModel-cassandra

  1. @Override
  2. protected DataSet materializeMainSchemaTable(Table table, List<Column> columns, int maxRows) {
  3.   final Select query = QueryBuilder.select().all().from(keySpaceName, table.getName());
  4.   if (limitMaxRowsIsSet(maxRows)) {
  5.     query.limit(maxRows);
  6.   }
  7.   final ResultSet resultSet = cassandraCluster.connect().execute(query);
  8.   final Iterator<Row> response = resultSet.iterator();
  9.   return new CassandraDataSet(response, columns);
  10. }

代码示例来源：origin: apache/metamodel

  1. @Override
  2. protected DataSet materializeMainSchemaTable(Table table, List<Column> columns, int maxRows) {
  3.   final Select query = QueryBuilder.select().all().from(keySpaceName, table.getName());
  4.   if (limitMaxRowsIsSet(maxRows)) {
  5.     query.limit(maxRows);
  6.   }
  7.   final ResultSet resultSet = cassandraCluster.connect().execute(query);
  8.   final Iterator<Row> response = resultSet.iterator();
  9.   return new CassandraDataSet(response, columns);
  10. }

代码示例来源：origin: apache/james-project

  1. private Mono<?> truncate(CassandraAsyncExecutor executor, String name) {
  2.     return Mono.fromFuture(executor.execute(
  3.         QueryBuilder.select()
  4.             .from(name)
  5.             .limit(1)
  6.             .setFetchSize(1)))
  7.         .filter(resultSet -> !resultSet.isExhausted())
  8.         .flatMap(ignored -> Mono.fromFuture(executor.execute(QueryBuilder.truncate(name))));
  9.   }
  10. }

代码示例来源：origin: org.apache.james/apache-james-mailbox-cassandra

  1. private PreparedStatement prepareReadStatement(Session session) {
  2.   return session.prepare(select(UID)
  3.     .from(TABLE_NAME)
  4.     .where(eq(MAILBOX_ID, bindMarker(MAILBOX_ID)))
  5.     .orderBy(asc(UID))
  6.     .limit(1));
  7. }

内容来源于网络，如有侵权，请联系作者删除！

select

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com