class Gateway::CassandraCQL

Public Instance Methods

__execute__(*args)
Alias for: execute
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