diff --git a/bin/cqlsh b/bin/cqlsh index bb440e0c5b..84543f4af8 100755 --- a/bin/cqlsh +++ b/bin/cqlsh @@ -450,7 +450,7 @@ class Shell(cmd.Cmd): else: transport = transport_factory(hostname, port, os.environ, CONFIG_FILE) self.conn = cql.connect(hostname, port, user=username, password=password, - transport=transport) + cql_version=cqlver, transport=transport) self.set_expanded_cql_version(cqlver) # we could set the keyspace through cql.connect(), but as of 1.0.10, # it doesn't quote the keyspace for USE :( diff --git a/lib/cql-internal-only-1.3.0.zip b/lib/cql-internal-only-1.4.0.zip similarity index 54% rename from lib/cql-internal-only-1.3.0.zip rename to lib/cql-internal-only-1.4.0.zip index 1fde0596fe..10dfeaf643 100644 Binary files a/lib/cql-internal-only-1.3.0.zip and b/lib/cql-internal-only-1.4.0.zip differ diff --git a/pylib/cqlshlib/cql3handling.py b/pylib/cqlshlib/cql3handling.py index 8728f60fea..8e0d987488 100644 --- a/pylib/cqlshlib/cql3handling.py +++ b/pylib/cqlshlib/cql3handling.py @@ -218,6 +218,7 @@ JUNK ::= /([ \t\r\f\v]+|(--|[/][/])[^\n\r]*([\n\r]|$)|[/][*].*?[*][/])/ ; | | ; + ::= token="TOKEN" "(" ( "," )* ")" | ; @@ -728,7 +729,6 @@ syntax_rules += r''' ; ::= "SELECT" "FROM" cf= - ("USING" "CONSISTENCY" selcl=)? ("WHERE" )? ("ORDER" "BY" ( "," )* )? ("LIMIT" )? @@ -753,10 +753,6 @@ syntax_rules += r''' ; ''' -@completer_for('selectStatement', 'selcl') -def select_statement_consistencylevel(ctxt, cass): - return [cl for cl in CqlRuleSet.consistency_levels if cl != 'ANY'] - @completer_for('orderByClause', 'ordercol') def select_order_column_completer(ctxt, cass): prev_order_cols = ctxt.get_binding('ordercol', ()) @@ -815,8 +811,7 @@ syntax_rules += r''' ( "USING" [insertopt]= ( "AND" [insertopt]= )* )? ; - ::= "CONSISTENCY" - | "TIMESTAMP" + ::= "TIMESTAMP" | "TTL" ; ''' @@ -860,7 +855,7 @@ def insert_valcomma_completer(ctxt, cass): @completer_for('insertStatement', 'insertopt') def insert_option_completer(ctxt, cass): - opts = set('CONSISTENCY TIMESTAMP TTL'.split()) + opts = set('TIMESTAMP TTL'.split()) for opt in ctxt.get_binding('insertopt', ()): opts.discard(opt.split()[0]) return opts @@ -882,7 +877,7 @@ syntax_rules += r''' @completer_for('updateStatement', 'updateopt') def insert_option_completer(ctxt, cass): - opts = set('CONSISTENCY TIMESTAMP TTL'.split()) + opts = set('TIMESTAMP TTL'.split()) for opt in ctxt.get_binding('updateopt', ()): opts.discard(opt.split()[0]) return opts @@ -953,14 +948,13 @@ syntax_rules += r''' ; ::= delcol= ( memberbracket="[" memberselector= "]" )? ; - ::= "CONSISTENCY" - | "TIMESTAMP" + ::= "TIMESTAMP" ; ''' @completer_for('deleteStatement', 'delopt') def delete_opt_completer(ctxt, cass): - opts = set('CONSISTENCY TIMESTAMP'.split()) + opts = set('TIMESTAMP'.split()) for opt in ctxt.get_binding('delopt', ()): opts.discard(opt.split()[0]) return opts @@ -988,7 +982,7 @@ syntax_rules += r''' @completer_for('batchStatement', 'batchopt') def batch_opt_completer(ctxt, cass): - opts = set('CONSISTENCY TIMESTAMP'.split()) + opts = set('TIMESTAMP'.split()) for opt in ctxt.get_binding('batchopt', ()): opts.discard(opt.split()[0]) return opts diff --git a/pylib/cqlshlib/tfactory.py b/pylib/cqlshlib/tfactory.py index d16c8e79ff..cc02e883ec 100644 --- a/pylib/cqlshlib/tfactory.py +++ b/pylib/cqlshlib/tfactory.py @@ -27,6 +27,5 @@ def regular_transport_factory(host, port, env, config_file): * env ..........: environment variables (os.environ) - not used by this implementation. * config_file ..: path to cqlsh config file - not used by this implementation. """ - socket = TSocket.TSocket(host, port) - socket.open() - return TTransport.TFramedTransport(socket) + tsocket = TSocket.TSocket(host, port) + return TTransport.TFramedTransport(tsocket)