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

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

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

Select.toString介绍

暂无

代码示例

代码示例来源：origin: brianfrankcooper/YCSB

  1. String initialStmt = selectStmt.toString();
  2. StringBuilder scanStmt = new StringBuilder();
  3. scanStmt.append(initialStmt.substring(0, initialStmt.length() - 1));

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

  1. /** @test_category queries:builder */
  2.  @Test(groups = "unit")
  3.  public void should_handle_allow_filtering() {
  4.   assertThat(select().all().from("foo").allowFiltering().toString())
  5.     .isEqualTo("SELECT * FROM foo ALLOW FILTERING;");
  6.   assertThat(select().all().from("foo").where(eq("x", 42)).allowFiltering().toString())
  7.     .isEqualTo("SELECT * FROM foo WHERE x=42 ALLOW FILTERING;");
  8.  }
  9. }

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

  1. @Test(groups = "unit")
  2. public void should_handle_to_json() throws Exception {
  3.  assertThat(select().toJson("id").as("id").toJson("age").as("age").from("users").toString())
  4.    .isEqualTo("SELECT toJson(id) AS id,toJson(age) AS age FROM users;");
  5.  assertThat(select().distinct().toJson("id").as("id").from("users").toString())
  6.    .isEqualTo("SELECT DISTINCT toJson(id) AS id FROM users;");
  7.  assertThat(
  8.      select(alias(toJson("id"), "id"), alias(toJson("age"), "age")).from("users").toString())
  9.    .isEqualTo("SELECT toJson(id) AS id,toJson(age) AS age FROM users;");
  10.  assertThat(select(alias(toJson("id"), "id")).distinct().from("users").toString())
  11.    .isEqualTo("SELECT DISTINCT toJson(id) AS id FROM users;");
  12. }

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

  1. @Test(groups = "unit")
  2. public void should_handle_select_json() throws Exception {
  3.  assertThat(select().json().from("users").toString()).isEqualTo("SELECT JSON * FROM users;");
  4.  assertThat(select("id", "age").json().from("users").toString())
  5.    .isEqualTo("SELECT JSON id,age FROM users;");
  6.  assertThat(
  7.      select()
  8.        .json()
  9.        .column("id")
  10.        .writeTime("age")
  11.        .ttl("state")
  12.        .as("ttl")
  13.        .from("users")
  14.        .toString())
  15.    .isEqualTo("SELECT JSON id,writetime(age),ttl(state) AS ttl FROM users;");
  16.  assertThat(select().distinct().json().column("id").from("users").toString())
  17.    .isEqualTo(
  18.      "SELECT JSON DISTINCT id FROM users;"); // note that the correct syntax is JSON DISTINCT
  19. }

代码示例来源：origin: otaviojava/Easy-Cassandra

  1. @Override
  2. public String toString() {
  3.   return select.toString();
  4. }

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

  1. @Test(groups = "unit")
  2. public void quotingTest() {
  3.  assertEquals(select().from("Metrics", "epochs").toString(), "SELECT * FROM Metrics.epochs;");
  4.  assertEquals(
  5.    select().from("Metrics", quote("epochs")).toString(), "SELECT * FROM Metrics.\"epochs\";");
  6.  assertEquals(
  7.    select().from(quote("Metrics"), "epochs").toString(), "SELECT * FROM \"Metrics\".epochs;");
  8.  assertEquals(
  9.    select().from(quote("Metrics"), quote("epochs")).toString(),
  10.    "SELECT * FROM \"Metrics\".\"epochs\";");
  11.  assertEquals(
  12.    insertInto("Metrics", "epochs").toString(), "INSERT INTO Metrics.epochs () VALUES ();");
  13.  assertEquals(
  14.    insertInto("Metrics", quote("epochs")).toString(),
  15.    "INSERT INTO Metrics.\"epochs\" () VALUES ();");
  16.  assertEquals(
  17.    insertInto(quote("Metrics"), "epochs").toString(),
  18.    "INSERT INTO \"Metrics\".epochs () VALUES ();");
  19.  assertEquals(
  20.    insertInto(quote("Metrics"), quote("epochs")).toString(),
  21.    "INSERT INTO \"Metrics\".\"epochs\" () VALUES ();");
  22. }

代码示例来源：origin: stackoverflow.com

  1. String sql ="select * from test where name = '한글왜안됨'";
  2. Select select = (Select) CCJSqlParserUtil.parse(sql);
  3. System.out.println(select.toString());

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

  1. assertThat(select().all().from("foo").groupBy("c1", column("c2"), raw("c3")).toString())
  2.   .isEqualTo("SELECT * FROM foo GROUP BY c1,c2,c3;");
  3. assertThat(
  4.       .groupBy("c1", column("c2"), raw("c3"))
  5.       .orderBy(asc("c1"))
  6.       .toString())
  7.   .isEqualTo("SELECT * FROM foo GROUP BY c1,c2,c3 ORDER BY c1 ASC;");
  8. assertThat(
  9.       .where(eq("x", 42))
  10.       .groupBy("c1", column("c2"), raw("c3"))
  11.       .toString())
  12.   .isEqualTo("SELECT * FROM foo WHERE x=42 GROUP BY c1,c2,c3;");
  13. assertThat(
  14.       .groupBy("c1", column("c2"), raw("c3"))
  15.       .orderBy(asc("c1"))
  16.       .toString())
  17.   .isEqualTo("SELECT * FROM foo WHERE x=42 GROUP BY c1,c2,c3 ORDER BY c1 ASC;");
  18. try {

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

  1. @Test(groups = "unit")
  2. public void should_handle_per_partition_limit_clause() {
  3.  assertThat(select().all().from("foo").perPartitionLimit(2).toString())
  4.    .isEqualTo("SELECT * FROM foo PER PARTITION LIMIT 2;");
  5.  assertThat(select().all().from("foo").perPartitionLimit(bindMarker()).toString())
  6.    .isEqualTo("SELECT * FROM foo PER PARTITION LIMIT ?;");
  7.  assertThat(select().all().from("foo").perPartitionLimit(bindMarker("limit")).toString())
  8.    .isEqualTo("SELECT * FROM foo PER PARTITION LIMIT :limit;");
  9.  assertThat(select().all().from("foo").perPartitionLimit(2).limit(bindMarker()).toString())
  10.    .isEqualTo("SELECT * FROM foo PER PARTITION LIMIT 2 LIMIT ?;");
  11.  assertThat(
  12.        .perPartitionLimit(2)
  13.        .limit(3)
  14.        .toString())
  15.    .isEqualTo("SELECT * FROM foo WHERE a IN (2,4) PER PARTITION LIMIT 2 LIMIT 3;");
  16.  assertThat(
  17.        .perPartitionLimit(bindMarker())
  18.        .limit(3)
  19.        .toString())
  20.    .isEqualTo("SELECT * FROM foo WHERE a=? PER PARTITION LIMIT ? LIMIT 3;");
  21.  assertThat(
  22.        .perPartitionLimit(2)
  23.        .limit(3)
  24.        .toString())
  25.    .isEqualTo("SELECT * FROM foo WHERE a=? ORDER BY b DESC PER PARTITION LIMIT 2 LIMIT 3;");
  26.  assertThat(

代码示例来源：origin: org.opennms.newts/newts-cassandra-search

  1. @Inject
  2. public CassandraCachePrimer(CassandraSession session) {
  3.   m_session = checkNotNull(session);
  4.   Select select = QueryBuilder.select(Constants.Schema.C_METRICS_CONTEXT,
  5.       Constants.Schema.C_METRICS_RESOURCE,
  6.       Constants.Schema.C_METRICS_NAME)
  7.       .from(Constants.Schema.T_METRICS);
  8.   m_selectAllMetricsStatement = session.prepare(select.toString());
  9.   select = QueryBuilder.select(Constants.Schema.C_ATTRS_CONTEXT,
  10.       Constants.Schema.C_ATTRS_RESOURCE,
  11.       Constants.Schema.C_ATTRS_ATTR,
  12.       Constants.Schema.C_ATTRS_VALUE)
  13.       .from(Constants.Schema.T_ATTRS);
  14.   m_selectAllAttributesStatement = session.prepare(select.toString());
  15. }

代码示例来源：origin: OpenNMS/newts

  1. @Inject
  2. public CassandraCachePrimer(CassandraSession session) {
  3.   m_session = checkNotNull(session);
  4.   Select select = QueryBuilder.select(Constants.Schema.C_METRICS_CONTEXT,
  5.       Constants.Schema.C_METRICS_RESOURCE,
  6.       Constants.Schema.C_METRICS_NAME)
  7.       .from(Constants.Schema.T_METRICS);
  8.   m_selectAllMetricsStatement = session.prepare(select.toString());
  9.   select = QueryBuilder.select(Constants.Schema.C_ATTRS_CONTEXT,
  10.       Constants.Schema.C_ATTRS_RESOURCE,
  11.       Constants.Schema.C_ATTRS_ATTR,
  12.       Constants.Schema.C_ATTRS_VALUE)
  13.       .from(Constants.Schema.T_ATTRS);
  14.   m_selectAllAttributesStatement = session.prepare(select.toString());
  15. }

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

  1. /** @test_category queries:builder */
  2. @Test(groups = "unit")
  3. public void should_handle_allow_filtering() {
  4.  assertThat(select().all().from("foo").allowFiltering().toString())
  5.    .isEqualTo("SELECT * FROM foo ALLOW FILTERING;");
  6.  assertThat(select().all().from("foo").where(eq("x", 42)).allowFiltering().toString())
  7.    .isEqualTo("SELECT * FROM foo WHERE x=42 ALLOW FILTERING;");
  8. }

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

  1. @Test(groups = "unit")
  2. public void should_handle_to_json() throws Exception {
  3.  assertThat(select().toJson("id").as("id").toJson("age").as("age").from("users").toString())
  4.    .isEqualTo("SELECT toJson(id) AS id,toJson(age) AS age FROM users;");
  5.  assertThat(select().distinct().toJson("id").as("id").from("users").toString())
  6.    .isEqualTo("SELECT DISTINCT toJson(id) AS id FROM users;");
  7.  assertThat(
  8.      select(alias(toJson("id"), "id"), alias(toJson("age"), "age")).from("users").toString())
  9.    .isEqualTo("SELECT toJson(id) AS id,toJson(age) AS age FROM users;");
  10.  assertThat(select(alias(toJson("id"), "id")).distinct().from("users").toString())
  11.    .isEqualTo("SELECT DISTINCT toJson(id) AS id FROM users;");
  12. }

代码示例来源：origin: OpenNMS/newts

  1. @Inject
  2. public CassandraSearcher(CassandraSession session, MetricRegistry registry, ContextConfigurations contextConfigurations) {
  3.   m_session = checkNotNull(session, "session argument");
  4.   m_searchTimer = registry.timer(name("search", "search"));
  5.   m_contextConfigurations = checkNotNull(contextConfigurations, "contextConfigurations argument");
  6.   Select select = QueryBuilder.select(Schema.C_TERMS_RESOURCE).from(Schema.T_TERMS);
  7.   select.where(eq(Schema.C_TERMS_CONTEXT, bindMarker(Schema.C_TERMS_CONTEXT)))
  8.      .and(  eq(Schema.C_TERMS_FIELD, bindMarker(Schema.C_TERMS_FIELD)))
  9.      .and(  eq(Schema.C_TERMS_VALUE, bindMarker(Schema.C_TERMS_VALUE)));
  10.   m_searchStatement = m_session.prepare(select.toString());
  11.   select = QueryBuilder.select(Schema.C_ATTRS_ATTR, Schema.C_ATTRS_VALUE).from(Schema.T_ATTRS);
  12.   select.where(eq(Schema.C_ATTRS_CONTEXT, bindMarker(Schema.C_ATTRS_CONTEXT)))
  13.      .and(  eq(Schema.C_ATTRS_RESOURCE, bindMarker(Schema.C_ATTRS_RESOURCE)));
  14.   m_selectAttributesStatement = m_session.prepare(select.toString());
  15.   select = QueryBuilder.select(Schema.C_METRICS_NAME).from(Schema.T_METRICS);
  16.   select.where(eq(Schema.C_METRICS_CONTEXT, bindMarker(Schema.C_METRICS_CONTEXT)))
  17.      .and(  eq(Schema.C_METRICS_RESOURCE, bindMarker(Schema.C_METRICS_RESOURCE)));
  18.   m_selectMetricNamesStatement = m_session.prepare(select.toString());
  19. }

代码示例来源：origin: org.opennms.newts/newts-cassandra-search

  1. @Inject
  2. public CassandraSearcher(CassandraSession session, MetricRegistry registry, ContextConfigurations contextConfigurations) {
  3.   m_session = checkNotNull(session, "session argument");
  4.   m_searchTimer = registry.timer(name("search", "search"));
  5.   m_contextConfigurations = checkNotNull(contextConfigurations, "contextConfigurations argument");
  6.   Select select = QueryBuilder.select(Schema.C_TERMS_RESOURCE).from(Schema.T_TERMS);
  7.   select.where(eq(Schema.C_TERMS_CONTEXT, bindMarker(Schema.C_TERMS_CONTEXT)))
  8.      .and(  eq(Schema.C_TERMS_FIELD, bindMarker(Schema.C_TERMS_FIELD)))
  9.      .and(  eq(Schema.C_TERMS_VALUE, bindMarker(Schema.C_TERMS_VALUE)));
  10.   m_searchStatement = m_session.prepare(select.toString());
  11.   select = QueryBuilder.select(Schema.C_ATTRS_ATTR, Schema.C_ATTRS_VALUE).from(Schema.T_ATTRS);
  12.   select.where(eq(Schema.C_ATTRS_CONTEXT, bindMarker(Schema.C_ATTRS_CONTEXT)))
  13.      .and(  eq(Schema.C_ATTRS_RESOURCE, bindMarker(Schema.C_ATTRS_RESOURCE)));
  14.   m_selectAttributesStatement = m_session.prepare(select.toString());
  15.   select = QueryBuilder.select(Schema.C_METRICS_NAME).from(Schema.T_METRICS);
  16.   select.where(eq(Schema.C_METRICS_CONTEXT, bindMarker(Schema.C_METRICS_CONTEXT)))
  17.      .and(  eq(Schema.C_METRICS_RESOURCE, bindMarker(Schema.C_METRICS_RESOURCE)));
  18.   m_selectMetricNamesStatement = m_session.prepare(select.toString());
  19. }

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-cassandra

  1. @Override
  2. public List<BoundedSource<T>> split(CassandraIO.Read<T> spec, long desiredBundleSizeBytes) {
  3.  try (Cluster cluster =
  4.    getCluster(
  5.      spec.hosts(),
  6.      spec.port(),
  7.      spec.username(),
  8.      spec.password(),
  9.      spec.localDc(),
  10.      spec.consistencyLevel())) {
  11.   if (isMurmur3Partitioner(cluster)) {
  12.    LOG.info("Murmur3Partitioner detected, splitting");
  13.    return split(spec, desiredBundleSizeBytes, getEstimatedSizeBytes(spec), cluster);
  14.   } else {
  15.    LOG.warn(
  16.      "Only Murmur3Partitioner is supported for splitting, using an unique source for "
  17.        + "the read");
  18.    String splitQuery = QueryBuilder.select().from(spec.keyspace(), spec.table()).toString();
  19.    return Collections.singletonList(
  20.      new CassandraIO.CassandraSource<>(spec, Collections.singletonList(splitQuery)));
  21.   }
  22.  }
  23. }

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

  1. @Test(groups = "unit")
  2. public void should_handle_select_json() throws Exception {
  3.  assertThat(select().json().from("users").toString()).isEqualTo("SELECT JSON * FROM users;");
  4.  assertThat(select("id", "age").json().from("users").toString())
  5.    .isEqualTo("SELECT JSON id,age FROM users;");
  6.  assertThat(
  7.      select()
  8.        .json()
  9.        .column("id")
  10.        .writeTime("age")
  11.        .ttl("state")
  12.        .as("ttl")
  13.        .from("users")
  14.        .toString())
  15.    .isEqualTo("SELECT JSON id,writetime(age),ttl(state) AS ttl FROM users;");
  16.  assertThat(select().distinct().json().column("id").from("users").toString())
  17.    .isEqualTo(
  18.      "SELECT JSON DISTINCT id FROM users;"); // note that the correct syntax is JSON DISTINCT
  19. }

代码示例来源：origin: OpenNMS/newts

  1. @Inject
  2. public CassandraSampleRepository(CassandraSession session, @Named("samples.cassandra.time-to-live") int ttl, MetricRegistry registry, SampleProcessorService processorService, ContextConfigurations contextConfigurations) {
  3.   m_session = checkNotNull(session, "session argument");
  4.   checkArgument(ttl >= 0, "Negative Cassandra column TTL");
  5.   m_ttl = ttl;
  6.   checkNotNull(registry, "metric registry argument");
  7.   m_processorService = processorService;
  8.   m_contextConfigurations = checkNotNull(contextConfigurations, "contextConfigurations argument");
  9.   Select select = QueryBuilder.select().from(SchemaConstants.T_SAMPLES);
  10.   select.where(eq(SchemaConstants.F_CONTEXT, bindMarker(SchemaConstants.F_CONTEXT)));
  11.   select.where(eq(SchemaConstants.F_PARTITION, bindMarker(SchemaConstants.F_PARTITION)));
  12.   select.where(eq(SchemaConstants.F_RESOURCE, bindMarker(SchemaConstants.F_RESOURCE)));
  13.   select.where(gte(SchemaConstants.F_COLLECTED, bindMarker("start")));
  14.   select.where(lte(SchemaConstants.F_COLLECTED, bindMarker("end")));
  15.   m_selectStatement = m_session.prepare(select.toString());
  16.   Delete delete = QueryBuilder.delete().from(SchemaConstants.T_SAMPLES);
  17.   delete.where(eq(SchemaConstants.F_CONTEXT, bindMarker(SchemaConstants.F_CONTEXT)));
  18.   delete.where(eq(SchemaConstants.F_PARTITION, bindMarker(SchemaConstants.F_PARTITION)));
  19.   delete.where(eq(SchemaConstants.F_RESOURCE, bindMarker(SchemaConstants.F_RESOURCE)));
  20.   m_deleteStatement = m_session.prepare(delete.toString());
  21.   m_sampleSelectTimer = registry.timer(metricName("sample-select-timer"));
  22.   m_measurementSelectTimer = registry.timer(metricName("measurement-select-timer"));
  23.   m_insertTimer = registry.timer(metricName("insert-timer"));
  24.   m_samplesInserted = registry.meter(metricName("samples-inserted"));
  25.   m_samplesSelected = registry.meter(metricName("samples-selected"));
  26. }

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

  1. @Test(groups = "unit")
  2. public void quotingTest() {
  3.  assertEquals(select().from("Metrics", "epochs").toString(), "SELECT * FROM Metrics.epochs;");
  4.  assertEquals(
  5.    select().from("Metrics", quote("epochs")).toString(), "SELECT * FROM Metrics.\"epochs\";");
  6.  assertEquals(
  7.    select().from(quote("Metrics"), "epochs").toString(), "SELECT * FROM \"Metrics\".epochs;");
  8.  assertEquals(
  9.    select().from(quote("Metrics"), quote("epochs")).toString(),
  10.    "SELECT * FROM \"Metrics\".\"epochs\";");
  11.  assertEquals(
  12.    insertInto("Metrics", "epochs").toString(), "INSERT INTO Metrics.epochs () VALUES ();");
  13.  assertEquals(
  14.    insertInto("Metrics", quote("epochs")).toString(),
  15.    "INSERT INTO Metrics.\"epochs\" () VALUES ();");
  16.  assertEquals(
  17.    insertInto(quote("Metrics"), "epochs").toString(),
  18.    "INSERT INTO \"Metrics\".epochs () VALUES ();");
  19.  assertEquals(
  20.    insertInto(quote("Metrics"), quote("epochs")).toString(),
  21.    "INSERT INTO \"Metrics\".\"epochs\" () VALUES ();");
  22. }

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

  1. @Override
  2.   String makePreparedQueryString(TableMetadata table, EntityMapper<?> mapper, MappingManager manager, Set<AliasedMappedProperty> columns, Collection<Mapper.Option> options) {
  3.     Select.Selection selection = select();
  4.     for (AliasedMappedProperty col : mapper.allColumns) {
  5.       Select.SelectionOrAlias column = col.mappedProperty.isComputed()
  6.           ? selection.raw(col.mappedProperty.getMappedName())
  7.           : selection.column(col.mappedProperty.getMappedName());
  8.       if (col.alias == null) {
  9.         selection = column;
  10.       } else {
  11.         selection = column.as(col.alias);
  12.       }
  13.     }
  14.     Select select;
  15.     if (table == null) {
  16.       select = selection.from(mapper.keyspace, mapper.table);
  17.     } else {
  18.       select = selection.from(table);
  19.     }
  20.     Select.Where where = select.where();
  21.     for (int i = 0; i < mapper.primaryKeySize(); i++)
  22.       where.and(eq(mapper.getPrimaryKeyColumn(i).mappedProperty.getMappedName(), bindMarker()));
  23.     for (Mapper.Option option : options) {
  24.       option.validate(QueryType.GET, manager);
  25.       option.modifyQueryString(select);
  26.     }
  27.     return select.toString();
  28.   }
  29. },

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

select

相关文章

    查看更多

    热门标签

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

    最新文章

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