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

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

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

Select.getQueryString介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

  1. @Override
  2. public RecordSet getRecordSet(ConnectorTransactionHandle transaction, ConnectorSession session, ConnectorSplit split, List<? extends ColumnHandle> columns)
  3. {
  4.   CassandraSplit cassandraSplit = (CassandraSplit) split;
  5.   List<CassandraColumnHandle> cassandraColumns = columns.stream()
  6.       .map(column -> (CassandraColumnHandle) column)
  7.       .collect(toList());
  8.   String selectCql = CassandraCqlUtils.selectFrom(cassandraSplit.getCassandraTableHandle(), cassandraColumns).getQueryString();
  9.   StringBuilder sb = new StringBuilder(selectCql);
  10.   if (sb.charAt(sb.length() - 1) == ';') {
  11.     sb.setLength(sb.length() - 1);
  12.   }
  13.   sb.append(cassandraSplit.getWhereClause());
  14.   String cql = sb.toString();
  15.   log.debug("Creating record set: %s", cql);
  16.   return new CassandraRecordSet(cassandraSession, cql, cassandraColumns);
  17. }

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

  1. /** @jira_ticket JAVA-1312 */
  2. @Test(groups = "unit")
  3. public void should_not_append_last_column_twice() throws Exception {
  4.  Select.SelectionOrAlias select = select().column("a").column("b");
  5.  Select fromUsers1 = select.from("users");
  6.  Select fromUsers2 = select.from("users");
  7.  assertThat(fromUsers1.getQueryString())
  8.    .isEqualTo(fromUsers2.getQueryString())
  9.    .isEqualTo("SELECT a,b FROM users;");
  10. }

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

  1. /**
  2.  * @test_category queries:builder
  3.  * @jira_ticket JAVA-1286
  4.  * @jira_ticket CASSANDRA-7423
  5.  */
  6. @Test(groups = "unit")
  7. public void should_handle_retrieving_udt_fields() throws Exception {
  8.  assertThat(select().path("a", Metadata.quote("B")).raw("c.\"D\"").from("tbl").getQueryString())
  9.    .isEqualTo("SELECT a.\"B\",c.\"D\" FROM tbl;");
  10. }

代码示例来源：origin: prestosql/presto

  1. @Override
  2. public RecordSet getRecordSet(ConnectorTransactionHandle transaction, ConnectorSession session, ConnectorSplit split, List<? extends ColumnHandle> columns)
  3. {
  4.   CassandraSplit cassandraSplit = (CassandraSplit) split;
  5.   List<CassandraColumnHandle> cassandraColumns = columns.stream()
  6.       .map(column -> (CassandraColumnHandle) column)
  7.       .collect(toList());
  8.   String selectCql = CassandraCqlUtils.selectFrom(cassandraSplit.getCassandraTableHandle(), cassandraColumns).getQueryString();
  9.   StringBuilder sb = new StringBuilder(selectCql);
  10.   if (sb.charAt(sb.length() - 1) == ';') {
  11.     sb.setLength(sb.length() - 1);
  12.   }
  13.   sb.append(cassandraSplit.getWhereClause());
  14.   String cql = sb.toString();
  15.   log.debug("Creating record set: %s", cql);
  16.   return new CassandraRecordSet(cassandraSession, cql, cassandraColumns);
  17. }

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

  1. @Override
  2. public RecordSet getRecordSet(ConnectorTransactionHandle transaction, ConnectorSession session, ConnectorSplit split, List<? extends ColumnHandle> columns)
  3. {
  4.   CassandraSplit cassandraSplit = (CassandraSplit) split;
  5.   List<CassandraColumnHandle> cassandraColumns = columns.stream()
  6.       .map(column -> (CassandraColumnHandle) column)
  7.       .collect(toList());
  8.   String selectCql = CassandraCqlUtils.selectFrom(cassandraSplit.getCassandraTableHandle(), cassandraColumns).getQueryString();
  9.   StringBuilder sb = new StringBuilder(selectCql);
  10.   if (sb.charAt(sb.length() - 1) == ';') {
  11.     sb.setLength(sb.length() - 1);
  12.   }
  13.   sb.append(cassandraSplit.getWhereClause());
  14.   String cql = sb.toString();
  15.   log.debug("Creating record set: %s", cql);
  16.   return new CassandraRecordSet(cassandraSession, cql, cassandraColumns);
  17. }

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

  1. @Override
  2. @Nonnull
  3. protected PreparedStatement prepare(Operation operation) {
  4.  checkArgument(operation, Get.class, Scan.class);
  5.  Select select = null;
  6.  if (operation instanceof Get) {
  7.   select = prepare((Get) operation);
  8.  } else {
  9.   select = prepare((Scan) operation);
  10.  }
  11.  return prepare(select.getQueryString());
  12. }

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

  1. .perPartitionLimit(bindMarker())
  2.         .limit(3)
  3.         .getQueryString(),
  4.       2))
  5. .hasSize(3);
  6.         .perPartitionLimit(bindMarker())
  7.         .limit(3)
  8.         .getQueryString(),
  9.       2))
  10. .hasSize(3);
  11.         .where(eq("a", bindMarker()))
  12.         .perPartitionLimit(bindMarker())
  13.         .getQueryString(),
  14.       2,
  15.       3))
  16.         .orderBy(desc("b"))
  17.         .perPartitionLimit(bindMarker())
  18.         .getQueryString(),
  19.       2,
  20.       3))
  21.         .perPartitionLimit(bindMarker())
  22.         .allowFiltering()
  23.         .getQueryString(),
  24.       2,
  25.       0,

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

  1. /** @jira_ticket JAVA-1312 */
  2. @Test(groups = "unit")
  3. public void should_not_append_last_column_twice() throws Exception {
  4.  Select.SelectionOrAlias select = select().column("a").column("b");
  5.  Select fromUsers1 = select.from("users");
  6.  Select fromUsers2 = select.from("users");
  7.  assertThat(fromUsers1.getQueryString())
  8.    .isEqualTo(fromUsers2.getQueryString())
  9.    .isEqualTo("SELECT a,b FROM users;");
  10. }

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

  1. private String getSelectStatement() {
  2.  return QueryBuilder.select().all()
  3.   .from(config.getKeyspace(), config.getTable())
  4.   .getQueryString();
  5. }

代码示例来源：origin: apifest/apifest-oauth20

  1. @Override
  2. public List<Scope> getAllScopes() {
  3.   List<Scope> list = new ArrayList<Scope>();
  4.   Select stmt = QueryBuilder.select().from(KEYSPACE_NAME, SCOPE_TABLE_NAME);
  5.   try {
  6.     ResultSet rs = session.execute(stmt);
  7.     for (Row row : rs) {
  8.       Scope scope = new Scope();
  9.       scope.setScope(row.getString("scope"));
  10.       scope.setDescription(row.getString("description"));
  11.       scope.setCcExpiresIn(row.getInt("cc_expires_in"));
  12.       scope.setPassExpiresIn(row.getInt("pass_expires_in"));
  13.       scope.setRefreshExpiresIn(row.getInt("refresh_expires_in"));
  14.       list.add(scope);
  15.     }
  16.   } catch (NoHostAvailableException e) {
  17.     log.error("No host in the %s cluster can be contacted to execute the query.\n",
  18.         session.getCluster());
  19.   } catch (QueryExecutionException e) {
  20.     log.error("An exception was thrown by Cassandra because it cannot " +
  21.         "successfully execute the query with the specified consistency level.");
  22.   } catch (QueryValidationException e) {
  23.     log.error(String.format("The query %s \nis not valid, for example, incorrect syntax.\n",
  24.         stmt.getQueryString()));
  25.   } catch (IllegalStateException e) {
  26.     log.error("The BoundStatement is not ready.");
  27.   }
  28.   return list;
  29. }

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

  1. /**
  2.  * @test_category queries:builder
  3.  * @jira_ticket JAVA-1286
  4.  * @jira_ticket CASSANDRA-7423
  5.  */
  6. @Test(groups = "unit")
  7. public void should_handle_retrieving_udt_fields() throws Exception {
  8.  assertThat(select().path("a", Metadata.quote("B")).raw("c.\"D\"").from("tbl").getQueryString())
  9.    .isEqualTo("SELECT a.\"B\",c.\"D\" FROM tbl;");
  10. }

代码示例来源：origin: apifest/apifest-oauth20

  1. } catch (QueryValidationException e) {
  2.   log.error(String.format("The query %s \nis not valid, for example, incorrect syntax.\n",
  3.       stmt.getQueryString()));
  4. } catch (IllegalStateException e) {
  5.   log.error("The BoundStatement is not ready.");

代码示例来源：origin: com.moz.fiji.schema/fiji-schema-cassandra

  1. /**
  2.  * Prepare the statement for reading from the hash table.
  3.  *
  4.  * @param admin The Cassandra cluster connection.
  5.  * @param schemaHashTable The table name.
  6.  * @return A read statement for the hash table.
  7.  */
  8. private PreparedStatement prepareQueryReadHashTable(
  9.   final CassandraAdmin admin,
  10.   final CassandraTableName schemaHashTable
  11. ) {
  12.  final Select select =
  13.    QueryBuilder
  14.      .select(SCHEMA_COLUMN_VALUE)
  15.      .from(schemaHashTable.getKeyspace(), schemaHashTable.getTable())
  16.      .where(eq(SCHEMA_COLUMN_HASH_KEY, bindMarker()))
  17.      .orderBy(desc(SCHEMA_COLUMN_TIME))
  18.      .limit(1);
  19.  return admin.getPreparedStatement(select.getQueryString());
  20. }

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

  1. .perPartitionLimit(bindMarker())
  2.         .limit(3)
  3.         .getQueryString(),
  4.       2))
  5. .hasSize(3);
  6.         .perPartitionLimit(bindMarker())
  7.         .limit(3)
  8.         .getQueryString(),
  9.       2))
  10. .hasSize(3);
  11.         .where(eq("a", bindMarker()))
  12.         .perPartitionLimit(bindMarker())
  13.         .getQueryString(),
  14.       2,
  15.       3))
  16.         .orderBy(desc("b"))
  17.         .perPartitionLimit(bindMarker())
  18.         .getQueryString(),
  19.       2,
  20.       3))
  21.         .perPartitionLimit(bindMarker())
  22.         .allowFiltering()
  23.         .getQueryString(),
  24.       2,
  25.       0,

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

select

相关文章

    查看更多

    热门标签

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

    最新文章

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