add method signature for processing a already parsed CQL statement
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b3bc28bd Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b3bc28bd Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b3bc28bd Branch: refs/heads/trunk Commit: b3bc28bdb49d1c683de61b0ac0d63fead3cf5c3b Parents: f2a4309 Author: T Jake Luciani <jak...@gmail.com> Authored: Tue Feb 14 15:36:43 2012 -0500 Committer: T Jake Luciani <jak...@gmail.com> Committed: Tue Feb 14 15:36:43 2012 -0500 ---------------------------------------------------------------------- .../org/apache/cassandra/cql/QueryProcessor.java | 7 +++++++ 1 files changed, 7 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b3bc28bd/src/java/org/apache/cassandra/cql/QueryProcessor.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/cql/QueryProcessor.java b/src/java/org/apache/cassandra/cql/QueryProcessor.java index b037d17..3008d99 100644 --- a/src/java/org/apache/cassandra/cql/QueryProcessor.java +++ b/src/java/org/apache/cassandra/cql/QueryProcessor.java @@ -498,6 +498,13 @@ public class QueryProcessor logger.trace("CQL QUERY: {}", queryString); CQLStatement statement = getStatement(queryString); + + return process(statement, clientState); + } + + public static CqlResult process(CQLStatement statement, ClientState clientState) + throws RecognitionException, UnavailableException, InvalidRequestException, TimedOutException, SchemaDisagreementException + { String keyspace = null; // Some statements won't have (or don't need) a keyspace (think USE, or CREATE).