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

QueryProcessor.computeId介绍

暂无

代码示例

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

private static ResultMessage.Prepared getStoredPreparedStatement(String queryString, String keyspace, boolean forThrift)
throws InvalidRequestException
{
  if (forThrift)
  {
    Integer thriftStatementId = computeThriftId(queryString, keyspace);
    ParsedStatement.Prepared existing = thriftPreparedStatements.get(thriftStatementId);
    if (existing == null)
      return null;
    checkTrue(queryString.equals(existing.rawCQLStatement),
         String.format("MD5 hash collision: query with the same MD5 hash was already prepared. \n Existing: '%s'", existing.rawCQLStatement));
    return ResultMessage.Prepared.forThrift(thriftStatementId, existing.boundNames);
  }
  else
  {
    MD5Digest statementId = computeId(queryString, keyspace);
    ParsedStatement.Prepared existing = preparedStatements.get(statementId);
    if (existing == null)
      return null;
    checkTrue(queryString.equals(existing.rawCQLStatement),
         String.format("MD5 hash collision: query with the same MD5 hash was already prepared. \n Existing: '%s'", existing.rawCQLStatement));
    return new ResultMessage.Prepared(statementId, existing);
  }
}

代码示例来源：origin: jsevellec/cassandra-unit

private static ResultMessage.Prepared getStoredPreparedStatement(String queryString, String keyspace, boolean forThrift)
throws InvalidRequestException
{
  if (forThrift)
  {
    Integer thriftStatementId = computeThriftId(queryString, keyspace);
    ParsedStatement.Prepared existing = thriftPreparedStatements.get(thriftStatementId);
    if (existing == null)
      return null;
    checkTrue(queryString.equals(existing.rawCQLStatement),
         String.format("MD5 hash collision: query with the same MD5 hash was already prepared. \n Existing: '%s'", existing.rawCQLStatement));
    return ResultMessage.Prepared.forThrift(thriftStatementId, existing.boundNames);
  }
  else
  {
    MD5Digest statementId = computeId(queryString, keyspace);
    ParsedStatement.Prepared existing = preparedStatements.get(statementId);
    if (existing == null)
      return null;
    checkTrue(queryString.equals(existing.rawCQLStatement),
         String.format("MD5 hash collision: query with the same MD5 hash was already prepared. \n Existing: '%s'", existing.rawCQLStatement));
    return new ResultMessage.Prepared(statementId, existing);
  }
}

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

private static ResultMessage.Prepared getStoredPreparedStatement(String queryString, String keyspace, boolean forThrift)
throws InvalidRequestException
{
  if (forThrift)
  {
    Integer thriftStatementId = computeThriftId(queryString, keyspace);
    ParsedStatement.Prepared existing = thriftPreparedStatements.get(thriftStatementId);
    if (existing == null)
      return null;
    checkTrue(queryString.equals(existing.rawCQLStatement),
         String.format("MD5 hash collision: query with the same MD5 hash was already prepared. \n Existing: '%s'", existing.rawCQLStatement));
    return ResultMessage.Prepared.forThrift(thriftStatementId, existing.boundNames);
  }
  else
  {
    MD5Digest statementId = computeId(queryString, keyspace);
    ParsedStatement.Prepared existing = preparedStatements.get(statementId);
    if (existing == null)
      return null;
    checkTrue(queryString.equals(existing.rawCQLStatement),
         String.format("MD5 hash collision: query with the same MD5 hash was already prepared. \n Existing: '%s'", existing.rawCQLStatement));
    return new ResultMessage.Prepared(statementId, existing);
  }
}

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

private static ResultMessage.Prepared getStoredPreparedStatement(String queryString, String keyspace, boolean forThrift)
throws InvalidRequestException
{
  if (forThrift)
  {
    Integer thriftStatementId = computeThriftId(queryString, keyspace);
    ParsedStatement.Prepared existing = thriftPreparedStatements.get(thriftStatementId);
    return existing == null ? null : ResultMessage.Prepared.forThrift(thriftStatementId, existing.boundNames);
  }
  else
  {
    MD5Digest statementId = computeId(queryString, keyspace);
    ParsedStatement.Prepared existing = preparedStatements.get(statementId);
    return existing == null ? null : new ResultMessage.Prepared(statementId, existing);
  }
}

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

private static ResultMessage.Prepared storePreparedStatement(String queryString, String keyspace, ParsedStatement.Prepared prepared, boolean forThrift)
throws InvalidRequestException
{
  // Concatenate the current keyspace so we don't mix prepared statements between keyspace (#5352).
  // (if the keyspace is null, queryString has to have a fully-qualified keyspace so it's fine.
  long statementSize = measure(prepared.statement);
  // don't execute the statement if it's bigger than the allowed threshold
  if (statementSize > MAX_CACHE_PREPARED_MEMORY)
    throw new InvalidRequestException(String.format("Prepared statement of size %d bytes is larger than allowed maximum of %d bytes.",
                            statementSize,
                            MAX_CACHE_PREPARED_MEMORY));
  if (forThrift)
  {
    Integer statementId = computeThriftId(queryString, keyspace);
    thriftPreparedStatements.put(statementId, prepared);
    return ResultMessage.Prepared.forThrift(statementId, prepared.boundNames);
  }
  else
  {
    MD5Digest statementId = computeId(queryString, keyspace);
    preparedStatements.put(statementId, prepared);
    return new ResultMessage.Prepared(statementId, prepared);
  }
}

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

DatabaseDescriptor.getPreparedStatementsCacheSizeMB(),
                          queryString.substring(0, 200)));
MD5Digest statementId = computeId(queryString, keyspace);
preparedStatements.put(statementId, prepared);
SystemKeyspace.writePreparedStatement(keyspace, statementId, queryString);

代码示例来源：origin: jsevellec/cassandra-unit

DatabaseDescriptor.getPreparedStatementsCacheSizeMB(),
                          queryString.substring(0, 200)));
MD5Digest statementId = computeId(queryString, keyspace);
preparedStatements.put(statementId, prepared);
SystemKeyspace.writePreparedStatement(keyspace, statementId, queryString);

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

DatabaseDescriptor.getPreparedStatementsCacheSizeMB(),
                          queryString.substring(0, 200)));
MD5Digest statementId = computeId(queryString, keyspace);
preparedStatements.put(statementId, prepared);
SystemKeyspace.writePreparedStatement(keyspace, statementId, queryString);