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

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

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

QueryProcessor.prepare介绍

暂无

代码示例

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

public ResultMessage.Prepared prepare(String query,
                   QueryState state,
                   Map<String, ByteBuffer> customPayload) throws RequestValidationException
{
  return prepare(query, state);
}

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

public ResultMessage.Prepared prepare(String query,
                   QueryState state,
                   Map<String, ByteBuffer> customPayload) throws RequestValidationException
{
  return prepare(query, state);
}

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

public ResultMessage.Prepared prepare(String query,
                   QueryState state,
                   Map<String, ByteBuffer> customPayload) throws RequestValidationException
{
  return prepare(query, state);
}

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

public ResultMessage.Prepared prepare(String query, QueryState state, Map<String, ByteBuffer> customPayload)
{
  ResultMessage.Prepared prepared = queryProcessor.prepare(query, state, customPayload);
  prepared.setCustomPayload(customPayload);
  return prepared;
}

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

public ResultMessage.Prepared prepare(String query, QueryState state, Map<String, ByteBuffer> customPayload)
{
  ResultMessage.Prepared prepared = queryProcessor.prepare(query, state, customPayload);
  prepared.setCustomPayload(customPayload);
  return prepared;
}

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

public ResultMessage.Prepared prepare(String queryString, QueryState queryState)
{
  ClientState cState = queryState.getClientState();
  return prepare(queryString, cState, cState instanceof ThriftClientState);
}

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

public ResultMessage.Prepared prepare(String queryString, QueryState queryState)
{
  ClientState cState = queryState.getClientState();
  return prepare(queryString, cState, cState instanceof ThriftClientState);
}

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

public ResultMessage.Prepared prepare(String queryString, QueryState queryState)
{
  ClientState cState = queryState.getClientState();
  return prepare(queryString, cState, cState instanceof ThriftClientState);
}

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

public ResultMessage.Prepared prepare(String queryString, QueryState queryState)
throws RequestValidationException
{
  ClientState cState = queryState.getClientState();
  return prepare(queryString, cState, cState instanceof ThriftClientState);
}

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

public ResultMessage.Prepared prepare(String query, QueryState state, Map<String, ByteBuffer> customPayload)
{
  ResultMessage.Prepared prepared = queryProcessor.prepare(query, state, customPayload);
  prepared.setCustomPayload(customPayload);
  return prepared;
}

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

public static void preloadPreparedStatement()
{
  ClientState clientState = ClientState.forInternalCalls();
  int count = 0;
  for (Pair<String, String> useKeyspaceAndCQL : SystemKeyspace.loadPreparedStatements())
  {
    try
    {
      clientState.setKeyspace(useKeyspaceAndCQL.left);
      prepare(useKeyspaceAndCQL.right, clientState, false);
      count++;
    }
    catch (RequestValidationException e)
    {
      logger.warn("prepared statement recreation error: {}", useKeyspaceAndCQL.right, e);
    }
  }
  logger.info("Preloaded {} prepared statements", count);
}

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

public static void preloadPreparedStatement()
{
  ClientState clientState = ClientState.forInternalCalls();
  int count = 0;
  for (Pair<String, String> useKeyspaceAndCQL : SystemKeyspace.loadPreparedStatements())
  {
    try
    {
      clientState.setKeyspace(useKeyspaceAndCQL.left);
      prepare(useKeyspaceAndCQL.right, clientState, false);
      count++;
    }
    catch (RequestValidationException e)
    {
      logger.warn("prepared statement recreation error: {}", useKeyspaceAndCQL.right, e);
    }
  }
  logger.info("Preloaded {} prepared statements", count);
}

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

public static void preloadPreparedStatement()
{
  ClientState clientState = ClientState.forInternalCalls();
  int count = 0;
  for (Pair<String, String> useKeyspaceAndCQL : SystemKeyspace.loadPreparedStatements())
  {
    try
    {
      clientState.setKeyspace(useKeyspaceAndCQL.left);
      prepare(useKeyspaceAndCQL.right, clientState, false);
      count++;
    }
    catch (RequestValidationException e)
    {
      logger.warn("prepared statement recreation error: {}", useKeyspaceAndCQL.right, e);
    }
  }
  logger.info("Preloaded {} prepared statements", count);
}

相关文章

微信公众号

最新文章

更多