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

QueryProcessor.execute介绍

[英]A special version of executeInternal that takes the time used as "now" for the query in argument. Note that this only make sense for Selects so this only accept SELECT statements and is only useful in rare cases.
[中]executeInternal的一个特殊版本，将参数中的查询时间用作“现在”。请注意，这只对SELECT有意义，因此它只接受SELECT语句，仅在极少数情况下有用。

代码示例

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

public static Map<UUID, String> viewStatus(String keyspace, String view)
{
  String query = "SELECT host_id, status FROM %s.%s WHERE keyspace_name = ? AND view_name = ?";
  UntypedResultSet results;
  try
  {
    results = QueryProcessor.execute(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
                     ConsistencyLevel.ONE,
                     keyspace,
                     view);
  }
  catch (Exception e)
  {
    return Collections.emptyMap();
  }
  Map<UUID, String> status = new HashMap<>();
  for (UntypedResultSet.Row row : results)
  {
    status.put(row.getUUID("host_id"), row.getString("status"));
  }
  return status;
}

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

public static Map<UUID, String> viewStatus(String keyspace, String view)
{
  String query = "SELECT host_id, status FROM %s.%s WHERE keyspace_name = ? AND view_name = ?";
  UntypedResultSet results;
  try
  {
    results = QueryProcessor.execute(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
                     ConsistencyLevel.ONE,
                     keyspace,
                     view);
  }
  catch (Exception e)
  {
    return Collections.emptyMap();
  }
  Map<UUID, String> status = new HashMap<>();
  for (UntypedResultSet.Row row : results)
  {
    status.put(row.getUUID("host_id"), row.getString("status"));
  }
  return status;
}

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

public static Map<UUID, String> viewStatus(String keyspace, String view)
{
  String query = "SELECT host_id, status FROM %s.%s WHERE keyspace_name = ? AND view_name = ?";
  UntypedResultSet results;
  try
  {
    results = QueryProcessor.execute(String.format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME, VIEW_BUILD_STATUS),
                     ConsistencyLevel.ONE,
                     keyspace,
                     view);
  }
  catch (Exception e)
  {
    return Collections.emptyMap();
  }
  Map<UUID, String> status = new HashMap<>();
  for (UntypedResultSet.Row row : results)
  {
    status.put(row.getUUID("host_id"), row.getString("status"));
  }
  return status;
}

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

public static UntypedResultSet execute(String query, ConsistencyLevel cl, QueryState state, Object... values)
throws RequestExecutionException
{
  try
  {
    ParsedStatement.Prepared prepared = prepareInternal(query);
    ResultMessage result = prepared.statement.execute(state, makeInternalOptions(prepared, values, cl), System.nanoTime());
    if (result instanceof ResultMessage.Rows)
      return UntypedResultSet.create(((ResultMessage.Rows)result).result);
    else
      return null;
  }
  catch (RequestValidationException e)
  {
    throw new RuntimeException("Error validating " + query, e);
  }
}

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

public static UntypedResultSet execute(String query, ConsistencyLevel cl, QueryState state, Object... values)
throws RequestExecutionException
{
  try
  {
    ParsedStatement.Prepared prepared = prepareInternal(query);
    ResultMessage result = prepared.statement.execute(state, makeInternalOptions(prepared, values, cl), System.nanoTime());
    if (result instanceof ResultMessage.Rows)
      return UntypedResultSet.create(((ResultMessage.Rows)result).result);
    else
      return null;
  }
  catch (RequestValidationException e)
  {
    throw new RuntimeException("Error validating " + query, e);
  }
}

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

public static UntypedResultSet execute(String query, ConsistencyLevel cl, QueryState state, Object... values)
throws RequestExecutionException
{
  try
  {
    ParsedStatement.Prepared prepared = prepareInternal(query);
    ResultMessage result = prepared.statement.execute(state, makeInternalOptions(prepared, values, cl), System.nanoTime());
    if (result instanceof ResultMessage.Rows)
      return UntypedResultSet.create(((ResultMessage.Rows)result).result);
    else
      return null;
  }
  catch (RequestValidationException e)
  {
    throw new RuntimeException("Error validating " + query, e);
  }
}