From 5e4fc9b88cc832db032a1eefe5bb759e43f78cde Mon Sep 17 00:00:00 2001
From: Pekka Enberg <penberg@cloudius-systems.com>
Date: Wed, 31 Dec 2014 11:03:54 +0200
Subject: [PATCH] cql3: convert TruncateStatement to C++

Signed-off-by: Pekka Enberg <penberg@cloudius-systems.com>
---
 cql3/cql3.cc                                  |  1 +
 ...teStatement.java => truncate_statement.hh} | 73 +++++++++++--------
 2 files changed, 43 insertions(+), 31 deletions(-)
 rename cql3/statements/{TruncateStatement.java => truncate_statement.hh} (51%)

diff --git a/cql3/cql3.cc b/cql3/cql3.cc
index edc4e8d749..b373574104 100644
--- a/cql3/cql3.cc
+++ b/cql3/cql3.cc
@@ -18,6 +18,7 @@
 #include "statements/cf_statement.hh"
 #include "statements/use_statement.hh"
 #include "statements/parsed_statement.hh"
+#include "statements/truncate_statement.hh"
 #include "cql_statement.hh"
 
 #include "variable_specifications.hh"
diff --git a/cql3/statements/TruncateStatement.java b/cql3/statements/truncate_statement.hh
similarity index 51%
rename from cql3/statements/TruncateStatement.java
rename to cql3/statements/truncate_statement.hh
index ef1c4a4d55..5f0b42d17e 100644
--- a/cql3/statements/TruncateStatement.java
+++ b/cql3/statements/truncate_statement.hh
@@ -15,49 +15,54 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.cassandra.cql3.statements;
 
-import java.io.IOException;
-import java.util.concurrent.TimeoutException;
+/*
+ * Copyright 2014 Cloudius Systems
+ *
+ * Modified by Cloudius Systems
+ */
 
-import org.apache.cassandra.auth.Permission;
-import org.apache.cassandra.cql3.*;
-import org.apache.cassandra.exceptions.*;
-import org.apache.cassandra.transport.messages.ResultMessage;
-import org.apache.cassandra.service.ClientState;
-import org.apache.cassandra.service.QueryState;
-import org.apache.cassandra.service.StorageProxy;
-import org.apache.cassandra.thrift.ThriftValidation;
+#ifndef CQL3_STATEMENTS_TRUNCATE_STATEMENT_HH
+#define CQL3_STATEMENTS_TRUNCATE_STATEMENT_HH
 
-public class TruncateStatement extends CFStatement implements CQLStatement
-{
-    public TruncateStatement(CFName name)
-    {
-        super(name);
-    }
+#include "cql3/statements/cf_statement.hh"
+#include "cql3/cql_statement.hh"
 
-    public int getBoundTerms()
-    {
+namespace cql3 {
+
+namespace statements {
+
+class truncate_statement : public cf_statement, public virtual cql_statement {
+public:
+    truncate_statement(const cf_name& name)
+        : cf_statement{name}
+    { }
+
+    virtual int get_bound_terms() override {
         return 0;
     }
 
-    public Prepared prepare() throws InvalidRequestException
-    {
-        return new Prepared(this);
+    virtual std::unique_ptr<prepared> prepare(std::unique_ptr<cql_statement>&& stmt) override {
+        return std::make_unique<parsed_statement::prepared>(std::move(stmt));
     }
 
-    public void checkAccess(ClientState state) throws InvalidRequestException, UnauthorizedException
-    {
+    virtual void check_access(const service::client_state& state) override {
+        throw std::runtime_error("not implemented");
+#if 0
         state.hasColumnFamilyAccess(keyspace(), columnFamily(), Permission.MODIFY);
+#endif
     }
 
-    public void validate(ClientState state) throws InvalidRequestException
-    {
+    virtual void validate(const service::client_state& state) override {
+        throw std::runtime_error("not implemented");
+#if 0
         ThriftValidation.validateColumnFamily(keyspace(), columnFamily());
+#endif
     }
 
-    public ResultMessage execute(QueryState state, QueryOptions options) throws InvalidRequestException, TruncateException
-    {
+    virtual transport::messages::result_message execute(service::query_state& state, const query_options& options) override {
+        throw std::runtime_error("not implemented");
+#if 0
         try
         {
             StorageProxy.truncateBlocking(keyspace(), columnFamily());
@@ -75,10 +80,16 @@ public class TruncateStatement extends CFStatement implements CQLStatement
             throw new TruncateException(e);
         }
         return null;
+#endif
     }
 
-    public ResultMessage executeInternal(QueryState state, QueryOptions options)
-    {
-        throw new UnsupportedOperationException();
+    virtual transport::messages::result_message execute_internal(service::query_state& state, const query_options& options) override {
+        throw std::runtime_error("unsupported operation");
     }
+};
+
 }
+
+}
+
+#endif