Class: CassandraRecord::Statement

Inherits:
Object
  • Object
show all
Defined in:
lib/cassandra_record/statement.rb

Class Method Summary collapse

Class Method Details

.create(table_name, columns, values) ⇒ Object 



16
17
18
19
20
21
22
23
24
 
# File 'lib/cassandra_record/statement.rb', line 16

def create(table_name, columns, values)
  cql = "INSERT INTO \#{table_name} (\#{columns.join(\", \")})\nVALUES (\#{value_placeholders(values).join(\", \")})\n  CQL\n\n  insert_statement = db.prepare(cql)\n  db.execute(insert_statement, *values)\nend\n"

.where(table_name, options = {}) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
 
# File 'lib/cassandra_record/statement.rb', line 4

def where(table_name, options={})
  cql = base_where_query(table_name)

  if options.present?
    cql << 'WHERE'
    cql << parse_where_clause_options(options)
  end

  cql << ';'
  db.execute(cql)
end