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

QueryProcessor.executeInternal介绍

[英]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

/**
 * Clears persisted read rates from system.sstable_activity for SSTables that have been deleted.
 */
public static void clearSSTableReadMeter(String keyspace, String table, int generation)
{
  String cql = "DELETE FROM system.%s WHERE keyspace_name=? AND columnfamily_name=? and generation=?";
  executeInternal(String.format(cql, SSTABLE_ACTIVITY), keyspace, table, generation);
}

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

public static void beginViewBuild(String ksname, String viewName, int generationNumber)
{
  executeInternal(String.format("INSERT INTO system.%s (keyspace_name, view_name, generation_number) VALUES (?, ?, ?)", VIEWS_BUILDS_IN_PROGRESS),
          ksname,
          viewName,
          generationNumber);
}

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

/**
 * Clears size estimates for a table (on table drop)
 */
public static void clearSizeEstimates(String keyspace, String table)
{
  String cql = String.format("DELETE FROM %s.%s WHERE keyspace_name = ? AND table_name = ?", SchemaConstants.SYSTEM_KEYSPACE_NAME, SIZE_ESTIMATES);
  executeInternal(cql, keyspace, table);
}

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

public static TabularData getCompactionHistory() throws OpenDataException
{
  UntypedResultSet queryResultSet = executeInternal(String.format("SELECT * from system.%s", COMPACTION_HISTORY));
  return CompactionHistoryTabularData.from(queryResultSet);
}

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

public static boolean isViewBuilt(String keyspaceName, String viewName)
{
  String req = "SELECT view_name FROM %s.\"%s\" WHERE keyspace_name=? AND view_name=?";
  UntypedResultSet result = executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_VIEWS), keyspaceName, viewName);
  return !result.isEmpty();
}

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

public static void setIndexRemoved(String keyspaceName, String indexName)
{
  String req = "DELETE FROM %s.\"%s\" WHERE table_name = ? AND index_name = ?";
  executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_INDEXES), keyspaceName, indexName);
  forceBlockingFlush(BUILT_INDEXES);
}

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

public static void writePreparedStatement(String loggedKeyspace, MD5Digest key, String cql)
{
  executeInternal(String.format("INSERT INTO %s.%s"
                 + " (logged_keyspace, prepared_id, query_string) VALUES (?, ?, ?)",
                 SchemaConstants.SYSTEM_KEYSPACE_NAME, PREPARED_STATEMENTS),
          loggedKeyspace, key.byteBuffer(), cql);
  logger.debug("stored prepared statement for logged keyspace '{}': '{}'", loggedKeyspace, cql);
}

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

public static boolean isViewBuilt(String keyspaceName, String viewName)
{
  String req = "SELECT view_name FROM %s.\"%s\" WHERE keyspace_name=? AND view_name=?";
  UntypedResultSet result = executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_VIEWS), keyspaceName, viewName);
  return !result.isEmpty();
}

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

public static void setViewBuilt(String keyspaceName, String viewName, boolean replicated)
{
  String req = "INSERT INTO %s.\"%s\" (keyspace_name, view_name, status_replicated) VALUES (?, ?, ?)";
  executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_VIEWS), keyspaceName, viewName, replicated);
  forceBlockingFlush(BUILT_VIEWS);
}

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

public static void setIndexBuilt(String keyspaceName, String indexName)
{
  String req = "INSERT INTO %s.\"%s\" (table_name, index_name) VALUES (?, ?)";
  executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_INDEXES), keyspaceName, indexName);
  forceBlockingFlush(BUILT_INDEXES);
}

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

public static Future<?> updatePeerInfo(final InetAddress ep, final String columnName, final Object value, ExecutorService executorService)
{
  if (ep.equals(FBUtilities.getBroadcastAddress()))
    return Futures.immediateFuture(null);
  String req = "INSERT INTO system.%s (peer, %s) VALUES (?, ?)";
  return executorService.submit((Runnable) () -> executeInternal(String.format(req, PEERS, columnName), ep, value));
}

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

public static void setBootstrapState(BootstrapState state)
{
  String req = "INSERT INTO system.%s (key, bootstrapped) VALUES ('%s', ?)";
  executeInternal(String.format(req, LOCAL, LOCAL), state.name());
  forceBlockingFlush(LOCAL);
}

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

public static void updateViewBuildStatus(String ksname, String viewName, Token token)
{
  String req = "INSERT INTO system.%s (keyspace_name, view_name, last_token) VALUES (?, ?, ?)";
  Token.TokenFactory factory = ViewsBuildsInProgress.partitioner.getTokenFactory();
  executeInternal(String.format(req, VIEWS_BUILDS_IN_PROGRESS), ksname, viewName, factory.toString(token));
}

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

public static synchronized void saveTruncationRecord(ColumnFamilyStore cfs, long truncatedAt, CommitLogPosition position)
{
  String req = "UPDATE system.%s SET truncated_at = truncated_at + ? WHERE key = '%s'";
  executeInternal(String.format(req, LOCAL, LOCAL), truncationAsMapEntry(cfs, truncatedAt, position));
  truncationRecords = null;
  forceBlockingFlush(LOCAL);
}

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

/**
 * Record tokens being used by another node
 */
public static Future<?> updateTokens(final InetAddress ep, final Collection<Token> tokens, ExecutorService executorService)
{
  if (ep.equals(FBUtilities.getBroadcastAddress()))
    return Futures.immediateFuture(null);
  String req = "INSERT INTO system.%s (peer, tokens) VALUES (?, ?)";
  return executorService.submit((Runnable) () -> executeInternal(String.format(req, PEERS), ep, tokensAsSet(tokens)));
}

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

@VisibleForTesting
public int countAllBatches()
{
  String query = String.format("SELECT count(*) FROM %s.%s", SchemaConstants.SYSTEM_KEYSPACE_NAME, SystemKeyspace.BATCHES);
  UntypedResultSet results = executeInternal(query);
  if (results == null || results.isEmpty())
    return 0;
  return (int) results.one().getLong("count");
}

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

public static boolean isViewStatusReplicated(String keyspaceName, String viewName)
{
  String req = "SELECT status_replicated FROM %s.\"%s\" WHERE keyspace_name=? AND view_name=?";
  UntypedResultSet result = executeInternal(String.format(req, SchemaConstants.SYSTEM_KEYSPACE_NAME, BUILT_VIEWS), keyspaceName, viewName);
  if (result.isEmpty())
    return false;
  UntypedResultSet.Row row = result.one();
  return row.has("status_replicated") && row.getBoolean("status_replicated");
}

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

public static Collection<Token> getSavedTokens()
{
  String req = "SELECT tokens FROM system.%s WHERE key='%s'";
  UntypedResultSet result = executeInternal(String.format(req, LOCAL, LOCAL));
  return result.isEmpty() || !result.one().has("tokens")
     ? Collections.<Token>emptyList()
     : deserializeTokens(result.one().getSet("tokens", UTF8Type.instance));
}

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

/**
 * Gets the stored data center for the local node, or null if none have been set yet.
 */
public static String getDatacenter()
{
  String req = "SELECT data_center FROM system.%s WHERE key='%s'";
  UntypedResultSet result = executeInternal(String.format(req, LOCAL, LOCAL));
  // Look up the Data center (return it if found)
  if (!result.isEmpty() && result.one().has("data_center"))
    return result.one().getString("data_center");
  return null;
}

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

/**
 * Gets the stored data center for the local node, or null if none have been set yet.
 */
public static String getDatacenter()
{
  String req = "SELECT data_center FROM system.%s WHERE key='%s'";
  UntypedResultSet result = executeInternal(String.format(req, LOCAL, LOCAL));
  // Look up the Data center (return it if found)
  if (!result.isEmpty() && result.one().has("data_center"))
    return result.one().getString("data_center");
  return null;
}