mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-23 01:50:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

cql3: convert TruncateStatement to C++

Browse Source 
Signed-off-by: Pekka Enberg <penberg@cloudius-systems.com>
This commit is contained in:
Pekka Enberg
2014-12-31 11:03:54 +02:00
parent 852f63f918
commit 5e4fc9b88c
2 changed files with 43 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cql3/cql3.cc
View File

@@ -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"

73
cql3/statements/TruncateStatement.java → cql3/statements/truncate_statement.hh
View File

@@ -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