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

QueryProcessor.internalQueryState介绍

暂无

代码示例

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

public static ParsedStatement.Prepared prepareInternal(String query) throws RequestValidationException
{
  ParsedStatement.Prepared prepared = internalStatements.get(query);
  if (prepared != null)
    return prepared;
  // Note: if 2 threads prepare the same query, we'll live so don't bother synchronizing
  prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  internalStatements.putIfAbsent(query, prepared);
  return prepared;
}

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

public static ParsedStatement.Prepared prepareInternal(String query) throws RequestValidationException
{
  ParsedStatement.Prepared prepared = internalStatements.get(query);
  if (prepared != null)
    return prepared;
  // Note: if 2 threads prepare the same query, we'll live so don't bother synchronizing
  prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  internalStatements.putIfAbsent(query, prepared);
  return prepared;
}

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

public static ParsedStatement.Prepared prepareInternal(String query) throws RequestValidationException
{
  ParsedStatement.Prepared prepared = internalStatements.get(query);
  if (prepared != null)
    return prepared;
  // Note: if 2 threads prepare the same query, we'll live so don't bother synchronizing
  prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  internalStatements.putIfAbsent(query, prepared);
  return prepared;
}

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

public static ParsedStatement.Prepared prepareInternal(String query) throws RequestValidationException
{
  ParsedStatement.Prepared prepared = internalStatements.get(query);
  if (prepared != null)
    return prepared;
  // Note: if 2 threads prepare the same query, we'll live so don't bother synchronizing
  prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  internalStatements.putIfAbsent(query, prepared);
  return prepared;
}

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

/**
 * Same than executeInternal, but to use for queries we know are only executed once so that the
 * created statement object is not cached.
 */
public static UntypedResultSet executeOnceInternal(String query, Object... values)
{
  ParsedStatement.Prepared prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

/**
 * Same than executeInternal, but to use for queries we know are only executed once so that the
 * created statement object is not cached.
 */
public static UntypedResultSet executeOnceInternal(String query, Object... values)
{
  ParsedStatement.Prepared prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

/**
 * Same than executeInternal, but to use for queries we know are only executed once so that the
 * created statement object is not cached.
 */
public static UntypedResultSet executeOnceInternal(String query, Object... values)
{
  ParsedStatement.Prepared prepared = parseStatement(query, internalQueryState());
  prepared.statement.validate(internalQueryState().getClientState());
  ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

/**
 * Same than executeInternal, but to use for queries we know are only executed once so that the
 * created statement object is not cached.
 */
public static UntypedResultSet executeOnceInternal(String query, Object... values)
{
  try
  {
    ParsedStatement.Prepared prepared = parseStatement(query, internalQueryState());
    prepared.statement.validate(internalQueryState().getClientState());
    ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
    if (result instanceof ResultMessage.Rows)
      return UntypedResultSet.create(((ResultMessage.Rows)result).result);
    else
      return null;
  }
  catch (RequestExecutionException e)
  {
    throw new RuntimeException(e);
  }
  catch (RequestValidationException e)
  {
    throw new RuntimeException("Error validating query " + query, e);
  }
}

代码示例来源：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.facebook.presto.cassandra/cassandra-server

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

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

public static UntypedResultSet executeInternal(String query, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

public static UntypedResultSet executeInternal(String query, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

代码示例来源：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);
  }
}

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

/**
 * 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.
 */
public static UntypedResultSet executeInternalWithNow(long now, String query, Object... values)
{
  try
  {
    ParsedStatement.Prepared prepared = prepareInternal(query);
    assert prepared.statement instanceof SelectStatement;
    SelectStatement select = (SelectStatement)prepared.statement;
    ResultMessage result = select.executeInternal(internalQueryState(), makeInternalOptions(prepared, values), now);
    assert result instanceof ResultMessage.Rows;
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  }
  catch (RequestExecutionException e)
  {
    throw new RuntimeException(e);
  }
  catch (RequestValidationException e)
  {
    throw new RuntimeException("Error validating query " + query, e);
  }
}

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

/**
 * 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.
 */
public static UntypedResultSet executeInternalWithNow(int nowInSec, long queryStartNanoTime, String query, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  assert prepared.statement instanceof SelectStatement;
  SelectStatement select = (SelectStatement)prepared.statement;
  ResultMessage result = select.executeInternal(internalQueryState(), makeInternalOptions(prepared, values), nowInSec, queryStartNanoTime);
  assert result instanceof ResultMessage.Rows;
  return UntypedResultSet.create(((ResultMessage.Rows)result).result);
}

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

public static UntypedResultSet executeInternal(String query, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  ResultMessage result = prepared.statement.executeInternal(internalQueryState(), makeInternalOptions(prepared, values));
  if (result instanceof ResultMessage.Rows)
    return UntypedResultSet.create(((ResultMessage.Rows)result).result);
  else
    return null;
}

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

/**
 * 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.
 */
public static UntypedResultSet executeInternalWithNow(int nowInSec, long queryStartNanoTime, String query, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  assert prepared.statement instanceof SelectStatement;
  SelectStatement select = (SelectStatement)prepared.statement;
  ResultMessage result = select.executeInternal(internalQueryState(), makeInternalOptions(prepared, values), nowInSec, queryStartNanoTime);
  assert result instanceof ResultMessage.Rows;
  return UntypedResultSet.create(((ResultMessage.Rows)result).result);
}

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

/**
 * 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.
 */
public static UntypedResultSet executeInternalWithNow(int nowInSec, long queryStartNanoTime, String query, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  assert prepared.statement instanceof SelectStatement;
  SelectStatement select = (SelectStatement)prepared.statement;
  ResultMessage result = select.executeInternal(internalQueryState(), makeInternalOptions(prepared, values), nowInSec, queryStartNanoTime);
  assert result instanceof ResultMessage.Rows;
  return UntypedResultSet.create(((ResultMessage.Rows)result).result);
}