Module: Cequel::Record::Schema::ClassMethods

Extended by:
Util::Forwardable
Defined in:
lib/cequel/record/schema.rb

Overview

Methods available on Cequel::Record class singletons to introspect and modify the schema defined in the database

Since:

  • 1.0.0

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Util::Forwardable

delegate

Instance Attribute Details

#clustering_columns ⇒ Array<ClusteringColumn> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#column_names ⇒ Array<Symbol> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#columns ⇒ Array<Column> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#key_column_names ⇒ Array<Symbol> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#key_columns ⇒ Array<Column> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#partition_key_column_names ⇒ Array<Symbol> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#partition_key_columns ⇒ Array<PartitionKey> (readonly) 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

Instance Method Details

#compact_storage? ⇒ Boolean 



63
64
65
66
 
# File 'lib/cequel/record/schema.rb', line 63

def_delegators :table_schema, :columns, :column_names, :key_columns,
:key_column_names, :partition_key_columns,
:partition_key_column_names, :clustering_columns,
:compact_storage?

#read_schema ⇒ Schema::Table

Read the current state of this record’s table in Cassandra from the database.

Since:

  • 1.0.0



110
111
112
 
# File 'lib/cequel/record/schema.rb', line 110

def read_schema
  table_reader.read
end

#reflect_on_column(name) ⇒ Column 



71
 
# File 'lib/cequel/record/schema.rb', line 71

def_delegator :table_schema, :column, :reflect_on_column

#synchronize_schema ⇒ void

This method returns an undefined value.

Read the current schema assigned to this record’s table from Cassandra, and make any necessary modifications (including creating the table for the first time) so that it matches the schema defined in the record definition

Since:

  • 1.0.0



82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/cequel/record/schema.rb', line 82

def synchronize_schema
  fail MissingTableNameError unless table_name

  patch =
    begin
      existing_table_descriptor = Cequel::Schema::TableReader.read(connection,
                                                                   table_name)

      return if existing_table_descriptor.materialized_view?

      Cequel::Schema::TableDiffer.new(existing_table_descriptor,
                                      table_schema)
        .call

    rescue NoSuchTableError
      Cequel::Schema::TableWriter.new(table_schema)
    end

  patch.statements.each { |stmt| connection.execute(stmt) }
end

#table_schema ⇒ Schema::Table

Returns the schema as defined by the columns specified in the class definition.

Since:

  • 1.0.0



118
119
120
 
# File 'lib/cequel/record/schema.rb', line 118

def table_schema
  dsl.table
end