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

RegularStatement.getQueryString介绍

[英]Returns the query string for this statement.
[中]返回此语句的查询字符串。

代码示例

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

/**
  * Returns this statement as a CQL query string.
  *
  * <p>It is important to note that the query string is merely a CQL representation of this
  * statement, but it does <em>not</em> convey all the information stored in {@link Statement}
  * objects.
  *
  * <p>See the javadocs of {@link #getQueryString()} for more information.
  *
  * @return this statement as a CQL query string.
  * @see #getQueryString()
  */
 @Override
 public String toString() {
  return getQueryString();
 }
}

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

/**
 * Returns the query string for this statement.
 *
 * <p>This method calls {@link #getQueryString(CodecRegistry)} with {@link
 * CodecRegistry#DEFAULT_INSTANCE}. Whether you should use this or the other variant depends on
 * the type of statement this is called on:
 *
 * <ul>
 *   <li>for a {@link SimpleStatement} or {@link SchemaStatement}, the codec registry isn't
 *       actually needed, so it's always safe to use this method;
 *   <li>for a {@link BuiltStatement} you can use this method if you use no custom codecs, or if
 *       your custom codecs are registered with the default registry. Otherwise, use the other
 *       method and provide the registry that contains your codecs (see {@link BuiltStatement} for
 *       more explanations on why this is so);
 *   <li>for a {@link BatchStatement}, use the first rule if it contains no built statements, or
 *       the second rule otherwise.
 * </ul>
 *
 * @return a valid CQL query string.
 */
public String getQueryString() {
 return getQueryString(CodecRegistry.DEFAULT_INSTANCE);
}

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

IdAndValues getIdAndValues(ProtocolVersion protocolVersion, CodecRegistry codecRegistry) {
 IdAndValues idAndVals = new IdAndValues(statements.size());
 for (Statement statement : statements) {
  if (statement instanceof StatementWrapper)
   statement = ((StatementWrapper) statement).getWrappedStatement();
  if (statement instanceof RegularStatement) {
   RegularStatement st = (RegularStatement) statement;
   ByteBuffer[] vals = st.getValues(protocolVersion, codecRegistry);
   String query = st.getQueryString(codecRegistry);
   idAndVals.ids.add(query);
   idAndVals.values.add(
     vals == null ? Collections.<ByteBuffer>emptyList() : Arrays.asList(vals));
  } else {
   // We handle BatchStatement in add() so ...
   assert statement instanceof BoundStatement;
   BoundStatement st = (BoundStatement) statement;
   idAndVals.ids.add(st.statement.getPreparedId().boundValuesMetadata.id);
   idAndVals.values.add(Arrays.asList(st.wrapper.values));
  }
 }
 return idAndVals;
}

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

@Override
StringBuilder buildQueryString(List<Object> variables, CodecRegistry codecRegistry) {
 StringBuilder builder = new StringBuilder();
 builder.append(
   isCounterOp() ? "BEGIN COUNTER BATCH" : (logged ? "BEGIN BATCH" : "BEGIN UNLOGGED BATCH"));
 if (!usings.usings.isEmpty()) {
  builder.append(" USING ");
  Utils.joinAndAppend(builder, codecRegistry, " AND ", usings.usings, variables);
 }
 builder.append(' ');
 for (int i = 0; i < statements.size(); i++) {
  RegularStatement stmt = statements.get(i);
  if (stmt instanceof BuiltStatement) {
   BuiltStatement bst = (BuiltStatement) stmt;
   builder.append(maybeAddSemicolon(bst.buildQueryString(variables, codecRegistry)));
  } else {
   String str = stmt.getQueryString(codecRegistry);
   builder.append(str);
   if (!str.trim().endsWith(";")) builder.append(';');
   // Note that we force hasBindMarkers if there is any non-BuiltStatement, so we know
   // that we can only get there with variables == null
   assert variables == null;
  }
 }
 builder.append("APPLY BATCH;");
 return builder;
}

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

md.update(rs.getQueryString().getBytes());
values = rs.getValues(protocolVersion, codecRegistry);

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

throw new IllegalArgumentException(
  "Batch statement cannot contain regular statements with named values ("
    + ((RegularStatement) statement).getQueryString()
    + ")");

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

/** {@inheritDoc} */
@Override
public ListenableFuture<PreparedStatement> prepareAsync(final RegularStatement statement) {
 if (statement.hasValues())
  throw new IllegalArgumentException("A statement to prepare should not have values");
 final CodecRegistry codecRegistry = getCluster().getConfiguration().getCodecRegistry();
 ListenableFuture<PreparedStatement> prepared =
   prepareAsync(statement.getQueryString(codecRegistry), statement.getOutgoingPayload());
 return GuavaCompatibility.INSTANCE.transform(
   prepared,
   new Function<PreparedStatement, PreparedStatement>() {
    @Override
    public PreparedStatement apply(PreparedStatement prepared) {
     ProtocolVersion protocolVersion =
       getCluster().getConfiguration().getProtocolOptions().getProtocolVersion();
     ByteBuffer routingKey = statement.getRoutingKey(protocolVersion, codecRegistry);
     if (routingKey != null) prepared.setRoutingKey(routingKey);
     if (statement.getConsistencyLevel() != null)
      prepared.setConsistencyLevel(statement.getConsistencyLevel());
     if (statement.getSerialConsistencyLevel() != null)
      prepared.setSerialConsistencyLevel(statement.getSerialConsistencyLevel());
     if (statement.isTracing()) prepared.enableTracing();
     prepared.setRetryPolicy(statement.getRetryPolicy());
     prepared.setOutgoingPayload(statement.getOutgoingPayload());
     prepared.setIdempotent(statement.isIdempotent());
     return prepared;
    }
   });
}

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

protected int append(Statement statement, StringBuilder buffer, int remaining) {
 if (statement instanceof RegularStatement) {
  RegularStatement rs = (RegularStatement) statement;
  String query = rs.getQueryString();
  remaining = append(query.trim(), buffer, remaining);
 } else if (statement instanceof BoundStatement) {

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

@Test(groups = "unit")
public void should_not_serialize_raw_query_values() {
 RegularStatement select = select().from("test").where(gt("i", raw("1")));
 assertThat(select.getQueryString()).doesNotContain("?");
 assertThat(select.getValues(ProtocolVersion.NEWEST_SUPPORTED, CodecRegistry.DEFAULT_INSTANCE))
   .isNull();
}

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

@Override
  public String toString() {
    return getQueryString();
  }
}

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

@Test(groups = "unit", expectedExceptions = CodecNotFoundException.class)
public void rejectUnknownValueTest() throws Exception {
 RegularStatement s =
   update("foo").with(set("a", new byte[13])).where(eq("k", 2)).setForceNoValues(true);
 s.getQueryString();
}

代码示例来源：origin: smartcat-labs/cassandra-diagnostics

private String statementQueryString(final RegularStatement statement) {
  return statement.getQueryString() + ";";
}

代码示例来源：origin: valchkou/cassandra-driver-mapping

public static String getScript(String keyspace, Session session, Class<?> clazz, SyncOptions syncOptions) {
  StringBuilder sb = new StringBuilder();
  EntityTypeMetadata entityMetadata = EntityTypeParser.getEntityMetadata(clazz);
  List<RegularStatement> statements = buildSyncStatements(keyspace, session, entityMetadata, syncOptions);
  
  for (RegularStatement stmt: statements) {
    sb.append(stmt.getQueryString());
    sb.append("\n");
  }
  
  return sb.toString();
}

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

IdAndValues getIdAndValues() {
  IdAndValues idAndVals = new IdAndValues(statements.size());
  for (Statement statement : statements) {
    if (statement instanceof RegularStatement) {
      RegularStatement st = (RegularStatement)statement;
      ByteBuffer[] vals = st.getValues();
      idAndVals.ids.add(st.getQueryString());
      idAndVals.values.add(vals == null ? Collections.<ByteBuffer>emptyList() : Arrays.asList(vals));
    } else {
      // We handle BatchStatement in add() so ...
      assert statement instanceof BoundStatement;
      BoundStatement st = (BoundStatement)statement;
      idAndVals.ids.add(st.statement.getPreparedId().id);
      idAndVals.values.add(Arrays.asList(st.values));
    }
  }
  return idAndVals;
}

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

int size = Header.lengthFor(protocolVersion);
try {
 size += CBUtil.sizeOfLongString(getQueryString(codecRegistry));
 switch (protocolVersion) {
  case V1:

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

rawNamedValues == null ? Collections.<String, ByteBuffer>emptyMap() : rawNamedValues;
String qString = rs.getQueryString(codecRegistry);

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

private static String getQuery(Statement statement) {
 String query = null;
 if (statement instanceof BoundStatement) {
  query = ((BoundStatement) statement).preparedStatement().getQueryString();
 } else if (statement instanceof RegularStatement) {
  query = ((RegularStatement) statement).getQueryString();
 }
 return query == null ? "" : query;
}

代码示例来源：origin: info.archinnov/achilles-common

private static String maybeGetQueryString(Statement statement) {
    if (LOGGER.isTraceEnabled()) {
      LOGGER.trace(String.format("Maybe get query string from %s ", statement.toString()));
    }

    if (statement instanceof RegularStatement) {
      return ((RegularStatement) statement).getQueryString();
    } else if (statement instanceof BoundStatement) {
      return ((BoundStatement) statement).preparedStatement().getQueryString();
    } else if (statement instanceof BatchStatement) {
      return BEGIN_BATCH;
    } else if (statement instanceof StatementWrapper) {
      return maybeGetQueryString(StatementWrapperUtils.getWrappedStatement(((StatementWrapper) statement)));
    } else {
      return OTHER_STATEMENT;
    }
  }
}

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

@Test(groups = "unit")
public void should_not_serialize_raw_query_values() {
 RegularStatement select = select().from("test").where(gt("i", raw("1")));
 assertThat(select.getQueryString()).doesNotContain("?");
 assertThat(select.getValues(ProtocolVersion.NEWEST_SUPPORTED, CodecRegistry.DEFAULT_INSTANCE))
   .isNull();
}

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

@Test(groups = "unit", expectedExceptions = CodecNotFoundException.class)
public void rejectUnknownValueTest() throws Exception {
 RegularStatement s =
   update("foo").with(set("a", new byte[13])).where(eq("k", 2)).setForceNoValues(true);
 s.getQueryString();
}