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

QueryProcessor.makeInternalOptions介绍

暂无

代码示例

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

private static QueryOptions makeInternalOptions(ParsedStatement.Prepared prepared, Object[] values)
{
  return makeInternalOptions(prepared, values, ConsistencyLevel.ONE);
}

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

private static QueryOptions makeInternalOptions(ParsedStatement.Prepared prepared, Object[] values)
{
  return makeInternalOptions(prepared, values, ConsistencyLevel.ONE);
}

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

private static QueryOptions makeInternalOptions(ParsedStatement.Prepared prepared, Object[] values)
{
  return makeInternalOptions(prepared, values, ConsistencyLevel.ONE);
}

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

public static UntypedResultSet executeInternalWithPaging(String query, int pageSize, Object... values)
{
  try
  {
    ParsedStatement.Prepared prepared = prepareInternal(query);
    if (!(prepared.statement instanceof SelectStatement))
      throw new IllegalArgumentException("Only SELECTs can be paged");
    SelectStatement select = (SelectStatement)prepared.statement;
    QueryPager pager = QueryPagers.localPager(select.getPageableCommand(makeInternalOptions(prepared, values)));
    return UntypedResultSet.create(select, pager, pageSize);
  }
  catch (RequestValidationException e)
  {
    throw new RuntimeException("Error validating query" + e);
  }
}

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

public static UntypedResultSet executeInternalWithPaging(String query, int pageSize, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  if (!(prepared.statement instanceof SelectStatement))
    throw new IllegalArgumentException("Only SELECTs can be paged");
  SelectStatement select = (SelectStatement)prepared.statement;
  QueryPager pager = select.getQuery(makeInternalOptions(prepared, values), FBUtilities.nowInSeconds()).getPager(null, ProtocolVersion.CURRENT);
  return UntypedResultSet.create(select, pager, pageSize);
}

代码示例来源：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 executeInternalWithPaging(String query, int pageSize, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  if (!(prepared.statement instanceof SelectStatement))
    throw new IllegalArgumentException("Only SELECTs can be paged");
  SelectStatement select = (SelectStatement)prepared.statement;
  QueryPager pager = select.getQuery(makeInternalOptions(prepared, values), FBUtilities.nowInSeconds()).getPager(null, ProtocolVersion.CURRENT);
  return UntypedResultSet.create(select, pager, pageSize);
}

代码示例来源：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: 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: 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: com.strapdata.cassandra/cassandra-all

public static UntypedResultSet executeInternalWithPaging(String query, int pageSize, Object... values)
{
  ParsedStatement.Prepared prepared = prepareInternal(query);
  if (!(prepared.statement instanceof SelectStatement))
    throw new IllegalArgumentException("Only SELECTs can be paged");
  SelectStatement select = (SelectStatement)prepared.statement;
  QueryPager pager = select.getQuery(makeInternalOptions(prepared, values), FBUtilities.nowInSeconds()).getPager(null, ProtocolVersion.CURRENT);
  return UntypedResultSet.create(select, pager, pageSize);
}

代码示例来源：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.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: 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

/**
 * 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);
}

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