Class: CassandraModel::TableDescriptor

Inherits:
Record
  • Object
show all
Defined in:
lib/cassandra_model/table_descriptor.rb

Instance Attribute Summary

Attributes inherited from Record

#attributes, #execution_info, #valid

Class Method Summary collapse

Methods inherited from Record

#==, batch_type, before_save, before_save_callbacks, cassandra_columns, #clustering_columns, columns, connection_name=, #delete, #delete_async, first, first_async, #initialize, #inspect, #invalidate!, normalized_attributes, normalized_column, order_by_clause, #partition_key, #primary_key, query_for_delete, query_for_save, query_for_update, request, request_async, request_meta, restriction_attributes, #save, #save_async, save_in_batch, select_column, select_columns, shard, shard_key, table, table=, table_name=, #update, #update_async

Methods included from QueryHelper

#after, #all, #before, def_query_helper, #find_by

Methods included from RecordDebug

#debug

Methods included from DisplayableAttributes

#as_json, included

Methods included from MetaColumns

included

Constructor Details

This class inherits a constructor from CassandraModel::Record

Class Method Details

.create(table_definition) ⇒ Object 



9
10
11
 
# File 'lib/cassandra_model/table_descriptor.rb', line 9

def create(table_definition)
  create_async(table_definition).get
end

.create_async(table_definition) ⇒ Object 



5
6
7
 
# File 'lib/cassandra_model/table_descriptor.rb', line 5

def create_async(table_definition)
  super(table_descriptor(table_definition), check_exists: true)
end

.create_descriptor_table ⇒ Object 



13
14
15
 
# File 'lib/cassandra_model/table_descriptor.rb', line 13

def create_descriptor_table
  session.execute(table_desc.to_cql(no_id: true)) unless descriptor_table_exists?
end

.drop_descriptor_table ⇒ Object 



17
18
19
 
# File 'lib/cassandra_model/table_descriptor.rb', line 17

def drop_descriptor_table
  session.execute("DROP TABLE #{table_name}") if descriptor_table_exists?
end