natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Conditional create/drop ks/table/index statements 

patch by michalm; reviewed by slebresne for CASSANDRA-2737
This commit is contained in:
Sylvain Lebresne 2013-06-21 11:21:54 +02:00
parent 0ba5cf12b9
commit b73f9d4231
10 changed files with 141 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -61,6 +61,7 @@
* Include a timestamp with all read commands to determine column expiration
(CASSANDRA-5149)
* Streaming 2.0 (CASSANDRA-5286)
* Conditional create/drop ks/table/index statements in CQL3 (CASSANDRA-2737)
1.2.6
* Fix cross-DC mutation forwarding (CASSANDRA-5632)

26
doc/cql3/CQL.textile
View File

@ -134,7 +134,7 @@ h3(#createKeyspaceStmt). CREATE KEYSPACE
__Syntax:__
bc(syntax)..
<create-keyspace-stmt> ::= CREATE KEYSPACE <identifier> WITH <properties>
<create-keyspace-stmt> ::= CREATE KEYSPACE (IF NOT EXISTS)? <identifier> WITH <properties>
p.
__Sample:__
@ -159,6 +159,8 @@ The @replication@ @<property>@ is mandatory. It must at least contains the @'cla
* @'NetworkTopologyStrategy'@: A replication strategy that allows to set the replication factor independently for each data-center. The rest of the sub-options are key-value pairs where each time the key is the name of a datacenter and the value the replication factor for that data-center.
* @'OldNetworkTopologyStrategy'@: A legacy replication strategy. You should avoid this strategy for new keyspaces and prefer @'NetworkTopologyStrategy'@.
Attempting to create an already existing keyspace will return an error unless the @IF NOT EXISTS@ option is used. If it is used, the statement will be a no-op if the keyspace already exists.
h3(#useStmt). USE
__Syntax:__
@ -192,7 +194,7 @@ h3(#dropKeyspaceStmt). DROP KEYSPACE
__Syntax:__
bc(syntax). <drop-keyspace-stmt> ::= DROP KEYSPACE <identifier>
bc(syntax). <drop-keyspace-stmt> ::= DROP KEYSPACE ( IF EXISTS )? <identifier>
__Sample:__
@ -200,13 +202,15 @@ bc(sample). DROP KEYSPACE myApp;
A @DROP KEYSPACE@ statement results in the immediate, irreversible removal of an existing keyspace, including all column families in it, and all data contained in those column families.
If the keyspace does not exists, the statement will return an error, unless @IF EXISTS@ is used in which case the operation is a no-op.
h3(#createTableStmt). CREATE TABLE
__Syntax:__
bc(syntax)..
<create-table-stmt> ::= CREATE (TABLE | COLUMNFAMILY) <tablename>
<create-table-stmt> ::= CREATE ( TABLE | COLUMNFAMILY ) ( IF NOT EXISTS )? <tablename>
'(' <definition> ( ',' <definition> )* ')'
( WITH <option> ( AND <option>)* )?
@ -245,6 +249,8 @@ CREATE TABLE timeline (
p.
The @CREATE TABLE@ statement creates a new table. Each such table is a set of _rows_ (usually representing related entities) for which it defines a number of properties. A table is defined by a "name":#createTableName, it defines the <a href="#createTableColumn"><it>columns</it></a> composing rows of the table and have a number of "options":#createTableOptions. Note that the @CREATE COLUMNFAMILY@ syntax is supported as an alias for @CREATE TABLE@ (for historical reasons).
Attempting to create an already existing table will return an error unless the @IF NOT EXISTS@ option is used. If it is used, the statement will be a no-op if the table already exists.
h4(#createTableName). @<tablename>@
Valid table names are the same than valid "keyspace names":#createKeyspaceStmt (up to 32 characters long alphanumerical identifiers). If the table name is provided alone, the table is created within the current keyspace (see <a href="#useStmt"><tt>USE</tt></a>), but if it is prefixed by an existing keyspace name (see "@<tablename>@":#statements grammar), it is created in the specified keyspace (but does *not* change the current keyspace).
@ -366,7 +372,7 @@ h3(#dropTableStmt). DROP TABLE
__Syntax:__
bc(syntax). <drop-table-stmt> ::= DROP TABLE <tablename>
bc(syntax). <drop-table-stmt> ::= DROP TABLE ( IF EXISTS )? <tablename>
__Sample:__
@ -374,6 +380,8 @@ bc(sample). DROP TABLE worldSeriesAttendees;
The @DROP TABLE@ statement results in the immediate, irreversible removal of a table, including all data contained in it. As for table creation, @DROP COLUMNFAMILY@ is allowed as an alias for @DROP TABLE@.
If the table does not exists, the statement will return an error, unless @IF EXISTS@ is used in which case the operation is a no-op.
h3(#truncateStmt). TRUNCATE
__Syntax:__
@ -391,7 +399,7 @@ h3(#createIndexStmt). CREATE INDEX
__Syntax:__
bc(syntax). <create-index-stmt> ::= CREATE ( CUSTOM )? INDEX <identifier>? ON <tablename> '(' <identifier> ')'
bc(syntax). <create-index-stmt> ::= CREATE ( CUSTOM )? INDEX ( IF NOT EXISTS )? <identifier>? ON <tablename> '(' <identifier> ')'
( USING <string> )?
__Sample:__
@ -403,11 +411,13 @@ CREATE CUSTOM INDEX ON users (email) USING 'path.to.the.IndexClass';
The @CREATE INDEX@ statement is used to create a new (automatic) secondary index for a given (existing) column in a given table. A name for the index itself can be specified before the @ON@ keyword, if desired. If data already exists for the column, it will be indexed during the execution of this statement. After the index is created, new data for the column is indexed automatically at insertion time.
Attempting to create an already existing index will return an error unless the @IF NOT EXISTS@ option is used. If it is used, the statement will be a no-op if the index already exists.
h3(#dropIndexStmt). DROP INDEX
__Syntax:__
bc(syntax). <drop-index-stmt> ::= DROP INDEX <identifier>
bc(syntax). <drop-index-stmt> ::= DROP INDEX ( IF EXISTS )? <identifier>
__Sample:__
@ -415,6 +425,7 @@ bc(sample). DROP INDEX userIndex;
The @DROP INDEX@ statement is used to drop an existing secondary index. The argument of the statement is the index name.
If the index does not exists, the statement will return an error, unless @IF EXISTS@ is used in which case the operation is a no-op.
h2(#dataManipulation). Data Manipulation
@ -1059,7 +1070,8 @@ The following describes the addition/changes brought for each version of CQL.
h3. 3.1.0
* "ALTER TABLE":#alterTableStmt @DROP@ option has been reenabled for CQL3 tables and has new semantics now: the space formerly used by dropped columns will now be eventually reclaimed (post-compaction). You should not readd previously dropped columns unless you use timestamps with microsecond precision (see "CASSANDRA-3919":https://issues.apache.org/jira/browse/CASSANDRA-3919 for more details).
* SELECT statement now supports aliases in select clause. Aliases in WHERE and ORDER BY clauses are not supported. See the "section on select"#selectStmt for details.
* @SELECT@ statement now supports aliases in select clause. Aliases in WHERE and ORDER BY clauses are not supported. See the "section on select"#selectStmt for details.
* @CREATE@ statements for @KEYSPACE@, @TABLE@ and @INDEX@ now supports an @IF NOT EXISTS@ condition. Similarly, @DROP@ statements support a @IF EXISTS@ condition.
h3. 3.0.4

16
pylib/cqlshlib/cql3handling.py
View File

@ -49,11 +49,11 @@ class Cql3ParsingRuleSet(CqlParsingRuleSet):
'keyspace', 'schema', 'columnfamily', 'table', 'index', 'on', 'drop',
'primary', 'into', 'values', 'timestamp', 'ttl', 'alter', 'add', 'type',
'compact', 'storage', 'order', 'by', 'asc', 'desc', 'clustering',
'token', 'writetime', 'map', 'list', 'to', 'custom'
'token', 'writetime', 'map', 'list', 'to', 'custom', 'if', 'not'
))
unreserved_keywords = set((
'key', 'clustering', 'ttl', 'compact', 'storage', 'type', 'values', 'custom'
'key', 'clustering', 'ttl', 'compact', 'storage', 'type', 'values', 'custom', 'exists'
))
columnfamily_layout_options = (
@ -834,7 +834,7 @@ syntax_rules += r'''
'''
syntax_rules += r'''
<createKeyspaceStatement> ::= "CREATE" wat=( "KEYSPACE" | "SCHEMA" ) ksname=<cfOrKsName>
<createKeyspaceStatement> ::= "CREATE" wat=( "KEYSPACE" | "SCHEMA" ) ("IF" "NOT" "EXISTS")? ksname=<cfOrKsName>
"WITH" <property> ( "AND" <property> )*
;
'''
@ -913,7 +913,7 @@ def keyspace_properties_map_ender_completer(ctxt, cass):
return ['}']
syntax_rules += r'''
<createColumnFamilyStatement> ::= "CREATE" wat=( "COLUMNFAMILY" | "TABLE" )
<createColumnFamilyStatement> ::= "CREATE" wat=( "COLUMNFAMILY" | "TABLE" ) ("IF" "NOT" "EXISTS")?
( ks=<nonSystemKeyspaceName> dot="." )? cf=<cfOrKsName>
"(" ( <singleKeyCfSpec> | <compositeKeyCfSpec> ) ")"
( "WITH" <cfamProperty> ( "AND" <cfamProperty> )* )?
@ -1007,7 +1007,7 @@ def create_cf_composite_primary_key_comma_completer(ctxt, cass):
return [',']
syntax_rules += r'''
<createIndexStatement> ::= "CREATE" "CUSTOM"? "INDEX" indexname=<identifier>? "ON"
<createIndexStatement> ::= "CREATE" "CUSTOM"? "INDEX" ("IF" "NOT" "EXISTS")? indexname=<identifier>? "ON"
cf=<columnFamilyName> "(" col=<cident> ")"
( "USING" <stringLiteral> )?
;
@ -1022,13 +1022,13 @@ def create_index_col_completer(ctxt, cass):
return map(maybe_escape_name, colnames)
syntax_rules += r'''
<dropKeyspaceStatement> ::= "DROP" "KEYSPACE" ksname=<nonSystemKeyspaceName>
<dropKeyspaceStatement> ::= "DROP" "KEYSPACE" ("IF" "EXISTS")? ksname=<nonSystemKeyspaceName>
;
<dropColumnFamilyStatement> ::= "DROP" ( "COLUMNFAMILY" | "TABLE" ) cf=<columnFamilyName>
<dropColumnFamilyStatement> ::= "DROP" ( "COLUMNFAMILY" | "TABLE" ) ("IF" "EXISTS")? cf=<columnFamilyName>
;
<dropIndexStatement> ::= "DROP" "INDEX" indexname=<identifier>
<dropIndexStatement> ::= "DROP" "INDEX" ("IF" "EXISTS")? indexname=<identifier>
;
'''

45
src/java/org/apache/cassandra/cql3/Cql.g
View File

@ -430,23 +430,28 @@ batchStatementObjective returns [ModificationStatement.Parsed statement]
;
/**
* CREATE KEYSPACE <KEYSPACE> WITH attr1 = value1 AND attr2 = value2;
* CREATE KEYSPACE [IF NOT EXISTS] <KEYSPACE> WITH attr1 = value1 AND attr2 = value2;
*/
createKeyspaceStatement returns [CreateKeyspaceStatement expr]
@init { KSPropDefs attrs = new KSPropDefs(); }
: K_CREATE K_KEYSPACE ks=keyspaceName
K_WITH properties[attrs] { $expr = new CreateKeyspaceStatement(ks, attrs); }
@init {
KSPropDefs attrs = new KSPropDefs();
boolean ifNotExists = false;
}
: K_CREATE K_KEYSPACE (K_IF K_NOT K_EXISTS { ifNotExists = true; } )? ks=keyspaceName
K_WITH properties[attrs] { $expr = new CreateKeyspaceStatement(ks, attrs, ifNotExists); }
;
/**
* CREATE COLUMNFAMILY <CF> (
* CREATE COLUMNFAMILY [IF NOT EXISTS] <CF> (
* <name1> <type>,
* <name2> <type>,
* <name3> <type>
* ) WITH <property> = <value> AND ...;
*/
createColumnFamilyStatement returns [CreateColumnFamilyStatement.RawStatement expr]
: K_CREATE K_COLUMNFAMILY cf=columnFamilyName { $expr = new CreateColumnFamilyStatement.RawStatement(cf); }
@init { boolean ifNotExists = false; }
: K_CREATE K_COLUMNFAMILY (K_IF K_NOT K_EXISTS { ifNotExists = true; } )?
cf=columnFamilyName { $expr = new CreateColumnFamilyStatement.RawStatement(cf, ifNotExists); }
cfamDefinition[expr]
;
@ -477,16 +482,18 @@ cfamOrdering[CreateColumnFamilyStatement.RawStatement expr]
;
/**
* CREATE INDEX [indexName] ON <columnFamily> (<columnName>);
* CREATE CUSTOM INDEX [indexName] ON <columnFamily> (<columnName>) USING <indexClass>;
* CREATE INDEX [IF NOT EXISTS] [indexName] ON <columnFamily> (<columnName>);
* CREATE CUSTOM INDEX [IF NOT EXISTS] [indexName] ON <columnFamily> (<columnName>) USING <indexClass>;
*/
createIndexStatement returns [CreateIndexStatement expr]
@init {
boolean isCustom = false;
boolean ifNotExists = false;
}
: K_CREATE (K_CUSTOM { isCustom = true; })? K_INDEX (idxName=IDENT)? K_ON cf=columnFamilyName '(' id=cident ')'
: K_CREATE (K_CUSTOM { isCustom = true; })? K_INDEX (K_IF K_NOT K_EXISTS { ifNotExists = true; } )?
(idxName=IDENT)? K_ON cf=columnFamilyName '(' id=cident ')'
( K_USING cls=STRING_LITERAL )?
{ $expr = new CreateIndexStatement(cf, $idxName.text, id, isCustom, $cls.text); }
{ $expr = new CreateIndexStatement(cf, $idxName.text, id, ifNotExists, isCustom, $cls.text); }
;
/**
@ -543,26 +550,28 @@ alterTableStatement returns [AlterTableStatement expr]
;
/**
* DROP KEYSPACE <KSP>;
* DROP KEYSPACE [IF EXISTS] <KSP>;
*/
dropKeyspaceStatement returns [DropKeyspaceStatement ksp]
: K_DROP K_KEYSPACE ks=keyspaceName { $ksp = new DropKeyspaceStatement(ks); }
@init { boolean ifExists = false; }
: K_DROP K_KEYSPACE (K_IF K_EXISTS { ifExists = true; } )? ks=keyspaceName { $ksp = new DropKeyspaceStatement(ks, ifExists); }
;
/**
* DROP COLUMNFAMILY <CF>;
* DROP COLUMNFAMILY [IF EXISTS] <CF>;
*/
dropColumnFamilyStatement returns [DropColumnFamilyStatement stmt]
: K_DROP K_COLUMNFAMILY cf=columnFamilyName { $stmt = new DropColumnFamilyStatement(cf); }
@init { boolean ifExists = false; }
: K_DROP K_COLUMNFAMILY (K_IF K_EXISTS { ifExists = true; } )? cf=columnFamilyName { $stmt = new DropColumnFamilyStatement(cf, ifExists); }
;
/**
* DROP INDEX <INDEX_NAME>
* DROP INDEX [IF EXISTS] <INDEX_NAME>
*/
dropIndexStatement returns [DropIndexStatement expr]
:
K_DROP K_INDEX index=IDENT
{ $expr = new DropIndexStatement($index.text); }
@init { boolean ifExists = false; }
: K_DROP K_INDEX (K_IF K_EXISTS { ifExists = true; } )? index=IDENT
{ $expr = new DropIndexStatement($index.text, ifExists); }
;
/**

22
src/java/org/apache/cassandra/cql3/statements/CreateColumnFamilyStatement.java
View File

@ -32,6 +32,7 @@ import org.apache.cassandra.config.Schema;
import org.apache.cassandra.cql3.*;
import org.apache.cassandra.db.ColumnFamilyType;
import org.apache.cassandra.db.marshal.*;
import org.apache.cassandra.exceptions.AlreadyExistsException;
import org.apache.cassandra.io.compress.CompressionParameters;
import org.apache.cassandra.service.ClientState;
import org.apache.cassandra.service.MigrationManager;
@ -52,11 +53,13 @@ public class CreateColumnFamilyStatement extends SchemaAlteringStatement
private final Map<ColumnIdentifier, AbstractType> columns = new HashMap<ColumnIdentifier, AbstractType>();
private final CFPropDefs properties;
private final boolean ifNotExists;
public CreateColumnFamilyStatement(CFName name, CFPropDefs properties)
public CreateColumnFamilyStatement(CFName name, CFPropDefs properties, boolean ifNotExists)
{
super(name);
this.properties = properties;
this.ifNotExists = ifNotExists;
try
{
@ -101,7 +104,15 @@ public class CreateColumnFamilyStatement extends SchemaAlteringStatement
public void announceMigration() throws RequestValidationException
{
MigrationManager.announceNewColumnFamily(getCFMetaData());
try
{
MigrationManager.announceNewColumnFamily(getCFMetaData());
}
catch (AlreadyExistsException e)
{
if (!ifNotExists)
throw e;
}
}
public ResultMessage.SchemaChange.Change changeType()
@ -154,9 +165,12 @@ public class CreateColumnFamilyStatement extends SchemaAlteringStatement
private boolean useCompactStorage;
private final Multiset<ColumnIdentifier> definedNames = HashMultiset.create(1);
public RawStatement(CFName name)
private final boolean ifNotExists;
public RawStatement(CFName name, boolean ifNotExists)
{
super(name);
this.ifNotExists = ifNotExists;
}
/**
@ -176,7 +190,7 @@ public class CreateColumnFamilyStatement extends SchemaAlteringStatement
properties.validate();
CreateColumnFamilyStatement stmt = new CreateColumnFamilyStatement(cfName, properties);
CreateColumnFamilyStatement stmt = new CreateColumnFamilyStatement(cfName, properties, ifNotExists);
stmt.setBoundTerms(getBoundsTerms());
Map<ByteBuffer, CollectionType> definedCollections = null;

14
src/java/org/apache/cassandra/cql3/statements/CreateIndexStatement.java
View File

@ -42,14 +42,16 @@ public class CreateIndexStatement extends SchemaAlteringStatement
private final String indexName;
private final ColumnIdentifier columnName;
private final boolean ifNotExists;
private final boolean isCustom;
private final String indexClass;
public CreateIndexStatement(CFName name, String indexName, ColumnIdentifier columnName, boolean isCustom, String indexClass)
public CreateIndexStatement(CFName name, String indexName, ColumnIdentifier columnName, boolean ifNotExists, boolean isCustom, String indexClass)
{
super(name);
this.indexName = indexName;
this.columnName = columnName;
this.ifNotExists = ifNotExists;
this.isCustom = isCustom;
this.indexClass = indexClass;
}
@ -69,7 +71,12 @@ public class CreateIndexStatement extends SchemaAlteringStatement
throw new InvalidRequestException("No column definition found for column " + columnName);
if (cd.getIndexType() != null)
throw new InvalidRequestException("Index already exists");
{
if (ifNotExists)
return;
else
throw new InvalidRequestException("Index already exists");
}
if (isCustom && indexClass == null)
throw new InvalidRequestException("CUSTOM index requires specifiying the index class");
@ -94,6 +101,9 @@ public class CreateIndexStatement extends SchemaAlteringStatement
CFMetaData cfm = Schema.instance.getCFMetaData(keyspace(), columnFamily()).clone();
ColumnDefinition cd = cfm.getColumnDefinition(columnName.key);
if (cd.getIndexType() != null && ifNotExists)
return;
if (isCustom)
cd.setIndexType(IndexType.CUSTOM, Collections.singletonMap(SecondaryIndex.CUSTOM_INDEX_OPTION_NAME, indexClass));
else if (cfm.getCfDef().isComposite)

15
src/java/org/apache/cassandra/cql3/statements/CreateKeyspaceStatement.java
View File

@ -22,6 +22,7 @@ import org.apache.cassandra.auth.Permission;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.config.Schema;
import org.apache.cassandra.cql3.KSPropDefs;
import org.apache.cassandra.exceptions.AlreadyExistsException;
import org.apache.cassandra.exceptions.InvalidRequestException;
import org.apache.cassandra.exceptions.RequestValidationException;
import org.apache.cassandra.exceptions.UnauthorizedException;
@ -37,6 +38,7 @@ public class CreateKeyspaceStatement extends SchemaAlteringStatement
{
private final String name;
private final KSPropDefs attrs;
private final boolean ifNotExists;
/**
* Creates a new <code>CreateKeyspaceStatement</code> instance for a given
@ -45,11 +47,12 @@ public class CreateKeyspaceStatement extends SchemaAlteringStatement
* @param name the name of the keyspace to create
* @param attrs map of the raw keyword arguments that followed the <code>WITH</code> keyword.
*/
public CreateKeyspaceStatement(String name, KSPropDefs attrs)
public CreateKeyspaceStatement(String name, KSPropDefs attrs, boolean ifNotExists)
{
super();
this.name = name;
this.attrs = attrs;
this.ifNotExists = ifNotExists;
}
@Override
@ -99,7 +102,15 @@ public class CreateKeyspaceStatement extends SchemaAlteringStatement
public void announceMigration() throws RequestValidationException
{
MigrationManager.announceNewKeyspace(attrs.asKSMetadata(name));
try
{
MigrationManager.announceNewKeyspace(attrs.asKSMetadata(name));
}
catch (AlreadyExistsException e)
{
if (!ifNotExists)
throw e;
}
}
public ResultMessage.SchemaChange.Change changeType()

15
src/java/org/apache/cassandra/cql3/statements/DropColumnFamilyStatement.java
View File

@ -28,9 +28,12 @@ import org.apache.cassandra.transport.messages.ResultMessage;
public class DropColumnFamilyStatement extends SchemaAlteringStatement
{
public DropColumnFamilyStatement(CFName name)
private final boolean ifExists;
public DropColumnFamilyStatement(CFName name, boolean ifExists)
{
super(name);
this.ifExists = ifExists;
}
public void checkAccess(ClientState state) throws UnauthorizedException, InvalidRequestException
@ -40,7 +43,15 @@ public class DropColumnFamilyStatement extends SchemaAlteringStatement
public void announceMigration() throws ConfigurationException
{
MigrationManager.announceColumnFamilyDrop(keyspace(), columnFamily());
try
{
MigrationManager.announceColumnFamilyDrop(keyspace(), columnFamily());
}
catch (ConfigurationException e)
{
if (!ifExists)
throw e;
}
}
public ResultMessage.SchemaChange.Change changeType()

22
src/java/org/apache/cassandra/cql3/statements/DropIndexStatement.java
View File

@ -31,16 +31,22 @@ import org.apache.cassandra.transport.messages.ResultMessage;
public class DropIndexStatement extends SchemaAlteringStatement
{
public final String indexName;
public final boolean ifExists;
public DropIndexStatement(String indexName)
public DropIndexStatement(String indexName, boolean ifExists)
{
super(new CFName());
this.indexName = indexName;
this.ifExists = ifExists;
}
public void checkAccess(ClientState state) throws UnauthorizedException, InvalidRequestException
{
state.hasColumnFamilyAccess(keyspace(), findIndexedCF().cfName, Permission.ALTER);
CFMetaData cfm = findIndexedCF();
if (cfm == null)
return;
state.hasColumnFamilyAccess(cfm.ksName, cfm.cfName, Permission.ALTER);
}
public ResultMessage.SchemaChange.Change changeType()
@ -51,7 +57,11 @@ public class DropIndexStatement extends SchemaAlteringStatement
public void announceMigration() throws InvalidRequestException, ConfigurationException
{
CFMetaData updatedCfm = updateCFMetadata(findIndexedCF());
CFMetaData cfm = findIndexedCF();
if (cfm == null)
return;
CFMetaData updatedCfm = updateCFMetadata(cfm);
MigrationManager.announceColumnFamilyUpdate(updatedCfm, false);
}
@ -75,7 +85,11 @@ public class DropIndexStatement extends SchemaAlteringStatement
if (findIndexedColumn(cfm) != null)
return cfm;
}
throw new InvalidRequestException("Index '" + indexName + "' could not be found in any of the column families of keyspace '" + keyspace() + "'");
if (ifExists)
return null;
else
throw new InvalidRequestException("Index '" + indexName + "' could not be found in any of the column families of keyspace '" + keyspace() + "'");
}
private ColumnDefinition findIndexedColumn(CFMetaData cfm)

14
src/java/org/apache/cassandra/cql3/statements/DropKeyspaceStatement.java
View File

@ -30,11 +30,13 @@ import org.apache.cassandra.transport.messages.ResultMessage;
public class DropKeyspaceStatement extends SchemaAlteringStatement
{
private final String keyspace;
private final boolean ifExists;
public DropKeyspaceStatement(String keyspace)
public DropKeyspaceStatement(String keyspace, boolean ifExists)
{
super();
this.keyspace = keyspace;
this.ifExists = ifExists;
}
public void checkAccess(ClientState state) throws UnauthorizedException, InvalidRequestException
@ -57,7 +59,15 @@ public class DropKeyspaceStatement extends SchemaAlteringStatement
public void announceMigration() throws ConfigurationException
{
MigrationManager.announceKeyspaceDrop(keyspace);
try
{
MigrationManager.announceKeyspaceDrop(keyspace);
}
catch(ConfigurationException e)
{
if (!ifExists)
throw e;
}
}
public ResultMessage.SchemaChange.Change changeType()