class Gateway::CassandraCQL
Public Instance Methods
execute(*args)
click to toggle source
# File lib/gateway-cassandra-cql.rb, line 27 def execute *args arguments = args.dup statement = args.shift block = args.pop if block_given? opts = args.last.is_a?(Hash) ? args.pop : {} bind_vars = args __execute__('cql', statement.to_s, opts) do |conn| if block conn.execute statement, *bind_vars, &block else conn.execute statement, *bind_vars end end end
Also aliased as: __execute__
Protected Instance Methods
connect()
click to toggle source
# File lib/gateway-cassandra-cql.rb, line 45 def connect opt = options[:keyspace] ? {:keyspace => options[:keyspace]} : {} ::CassandraCQL::Database.new options[:servers], opt end
disconnect(conn)
click to toggle source
# File lib/gateway-cassandra-cql.rb, line 50 def disconnect(conn) conn.disconnect! end
reconnect(conn)
click to toggle source
# File lib/gateway-cassandra-cql.rb, line 54 def reconnect(conn) conn.reset! end