org.apache.cassandra.cql3.QueryProcessor.process()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(88)

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

QueryProcessor.process介绍

暂无

代码示例

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

private UntypedResultSet process(String query) throws RequestExecutionException
  {
    return QueryProcessor.process(query, ConsistencyLevel.LOCAL_ONE);
  }
}

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

private UntypedResultSet process(String query) throws RequestExecutionException
  {
    return QueryProcessor.process(query, ConsistencyLevel.LOCAL_ONE);
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

private void buildGeoPointType(String ksName) throws RequestExecutionException {
  String query = String.format(Locale.ROOT, "CREATE TYPE IF NOT EXISTS \"%s\".\"%s\" ( %s double, %s double)", 
      ksName, GEO_POINT_TYPE,org.elasticsearch.index.mapper.BaseGeoPointFieldMapper.Names.LAT,org.elasticsearch.index.mapper.BaseGeoPointFieldMapper.Names.LON);
  QueryProcessor.process(query, ConsistencyLevel.LOCAL_ONE);
}

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

public ResultMessage process(String query,
               QueryState state,
               QueryOptions options,
               Map<String, ByteBuffer> customPayload,
               long queryStartNanoTime) throws RequestExecutionException, RequestValidationException
{
  return process(query, state, options, queryStartNanoTime);
}

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

public ResultMessage process(String query,
               QueryState state,
               QueryOptions options,
               Map<String, ByteBuffer> customPayload,
               long queryStartNanoTime) throws RequestExecutionException, RequestValidationException
{
  return process(query, state, options, queryStartNanoTime);
}

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

public ResultMessage process(String query,
               QueryState state,
               QueryOptions options,
               Map<String, ByteBuffer> customPayload,
               long queryStartNanoTime) throws RequestExecutionException, RequestValidationException
{
  return process(query, state, options, queryStartNanoTime);
}

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

private static boolean hasExistingRoles() throws RequestExecutionException
{
  // Try looking up the 'cassandra' default role first, to avoid the range query if possible.
  String defaultSUQuery = String.format("SELECT * FROM %s.%s WHERE role = '%s'", SchemaConstants.AUTH_KEYSPACE_NAME, AuthKeyspace.ROLES, DEFAULT_SUPERUSER_NAME);
  String allUsersQuery = String.format("SELECT * FROM %s.%s LIMIT 1", SchemaConstants.AUTH_KEYSPACE_NAME, AuthKeyspace.ROLES);
  return !QueryProcessor.process(defaultSUQuery, ConsistencyLevel.ONE).isEmpty()
      || !QueryProcessor.process(defaultSUQuery, ConsistencyLevel.QUORUM).isEmpty()
      || !QueryProcessor.process(allUsersQuery, ConsistencyLevel.QUORUM).isEmpty();
}

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

private static boolean hasExistingRoles() throws RequestExecutionException
{
  // Try looking up the 'cassandra' default role first, to avoid the range query if possible.
  String defaultSUQuery = String.format("SELECT * FROM %s.%s WHERE role = '%s'", SchemaConstants.AUTH_KEYSPACE_NAME, AuthKeyspace.ROLES, DEFAULT_SUPERUSER_NAME);
  String allUsersQuery = String.format("SELECT * FROM %s.%s LIMIT 1", SchemaConstants.AUTH_KEYSPACE_NAME, AuthKeyspace.ROLES);
  return !QueryProcessor.process(defaultSUQuery, ConsistencyLevel.ONE).isEmpty()
      || !QueryProcessor.process(defaultSUQuery, ConsistencyLevel.QUORUM).isEmpty()
      || !QueryProcessor.process(allUsersQuery, ConsistencyLevel.QUORUM).isEmpty();
}

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

/**
 * Executes the provided query.
 * This shouldn't be used during setup as this will directly return an error if the manager is not setup yet. Setup tasks
 * should use QueryProcessor.process directly.
 */
private UntypedResultSet process(String query, ConsistencyLevel consistencyLevel) throws RequestValidationException, RequestExecutionException
{
  if (!isClusterReady)
    throw new InvalidRequestException("Cannot process role related query as the role manager isn't yet setup. "
                    + "This is likely because some of nodes in the cluster are on version 2.1 or earlier. "
                    + "You need to upgrade all nodes to Cassandra 2.2 or more to use roles.");
  return QueryProcessor.process(query, consistencyLevel);
}

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

public ResultMessage execute(ClientState state) throws RequestValidationException, RequestExecutionException
  {
    return QueryProcessor.process(String.format("SELECT * FROM %s.%s", Auth.AUTH_KS, Auth.USERS_CF),
                   ConsistencyLevel.QUORUM,
                   QueryState.forInternalCalls());
  }
}

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

private static boolean hasExistingRoles() throws RequestExecutionException
{
  // Try looking up the 'cassandra' default role first, to avoid the range query if possible.
  String defaultSUQuery = String.format("SELECT * FROM %s.%s WHERE role = '%s'", SchemaConstants.AUTH_KEYSPACE_NAME, AuthKeyspace.ROLES, DEFAULT_SUPERUSER_NAME);
  String allUsersQuery = String.format("SELECT * FROM %s.%s LIMIT 1", SchemaConstants.AUTH_KEYSPACE_NAME, AuthKeyspace.ROLES);
  return !QueryProcessor.process(defaultSUQuery, ConsistencyLevel.ONE).isEmpty()
      || !QueryProcessor.process(defaultSUQuery, ConsistencyLevel.QUORUM).isEmpty()
      || !QueryProcessor.process(allUsersQuery, ConsistencyLevel.QUORUM).isEmpty();
}

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

public ResultMessage process(String query,
               QueryState state,
               QueryOptions options,
               Map<String, ByteBuffer> customPayload,
               long queryStartNanoTime)
{
  ResultMessage result = queryProcessor.process(query, state, options, customPayload, queryStartNanoTime);
  result.setCustomPayload(customPayload);
  return result;
}

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

public ResultMessage process(String query,
               QueryState state,
               QueryOptions options,
               Map<String, ByteBuffer> customPayload,
               long queryStartNanoTime)
{
  ResultMessage result = queryProcessor.process(query, state, options, customPayload, queryStartNanoTime);
  result.setCustomPayload(customPayload);
  return result;
}

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

public ResultMessage process(String query,
               QueryState state,
               QueryOptions options,
               Map<String, ByteBuffer> customPayload,
               long queryStartNanoTime)
{
  ResultMessage result = queryProcessor.process(query, state, options, customPayload, queryStartNanoTime);
  result.setCustomPayload(customPayload);
  return result;
}

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

public static UntypedResultSet process(String query, ConsistencyLevel cl, List<ByteBuffer> values) throws RequestExecutionException
{
  ResultMessage result = instance.process(query, QueryState.forInternalCalls(), QueryOptions.forInternalCalls(cl, values), System.nanoTime());
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

public static UntypedResultSet process(String query, ConsistencyLevel cl, List<ByteBuffer> values) throws RequestExecutionException
{
  ResultMessage result = instance.process(query, QueryState.forInternalCalls(), QueryOptions.forInternalCalls(cl, values), System.nanoTime());
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

public static void startViewBuild(String keyspace, String view, UUID hostId)
{
  String query = "INSERT INTO %s.%s (keyspace_name, view_name, host_id, status) VALUES (?, ?, ?, ?)";
  QueryProcessor.process(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
              ConsistencyLevel.ONE,
              Lists.newArrayList(bytes(keyspace),
                       bytes(view),
                       bytes(hostId),
                       bytes(BuildStatus.STARTED.toString())));
}

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

public static void successfulViewBuild(String keyspace, String view, UUID hostId)
{
  String query = "UPDATE %s.%s SET status = ? WHERE keyspace_name = ? AND view_name = ? AND host_id = ?";
  QueryProcessor.process(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
              ConsistencyLevel.ONE,
              Lists.newArrayList(bytes(BuildStatus.SUCCESS.toString()),
                       bytes(keyspace),
                       bytes(view),
                       bytes(hostId)));
}

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

public static void successfulViewBuild(String keyspace, String view, UUID hostId)
{
  String query = "UPDATE %s.%s SET status = ? WHERE keyspace_name = ? AND view_name = ? AND host_id = ?";
  QueryProcessor.process(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
              ConsistencyLevel.ONE,
              Lists.newArrayList(bytes(BuildStatus.SUCCESS.toString()),
                       bytes(keyspace),
                       bytes(view),
                       bytes(hostId)));
}

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

public static void startViewBuild(String keyspace, String view, UUID hostId)
{
  String query = "INSERT INTO %s.%s (keyspace_name, view_name, host_id, status) VALUES (?, ?, ?, ?)";
  QueryProcessor.process(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
              ConsistencyLevel.ONE,
              Lists.newArrayList(bytes(keyspace),
                       bytes(view),
                       bytes(hostId),
                       bytes(BuildStatus.STARTED.toString())));
}

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

QueryProcessor

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    QueryProcessor类方法

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