Module: CassandraObject::Connection::ClassMethods

Defined in:
lib/cassandra_object/connection.rb

Instance Method Summary collapse

Instance Method Details

#cql ⇒ Object 



23
24
25
 
# File 'lib/cassandra_object/connection.rb', line 23

def cql
  @@cql ||= CassandraCQL::Database.new(config.servers, {keyspace: config.keyspace}, config.thrift_options)
end

#execute_cql(cql_string, *bind_vars) ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/cassandra_object/connection.rb', line 27

def execute_cql(cql_string, *bind_vars)
  statement = CassandraCQL::Statement.sanitize(cql_string, bind_vars).force_encoding(Encoding::UTF_8)

  ActiveSupport::Notifications.instrument("cql.cassandra_object", cql: statement) do
    cql.execute statement
  end
end