Class: Cassandra::MaterializedView

Inherits:
ColumnContainer show all
Defined in:
lib/cassandra/materialized_view.rb

Overview

Represents a cassandra materialized view

See Also:

Instance Attribute Summary

Attributes inherited from ColumnContainer

#clustering_columns, #id, #keyspace, #name, #options, #partition_key, #primary_key

Instance Method Summary collapse

Methods inherited from ColumnContainer

#column, #each_column, #has_column?

Instance Method Details

#base_table ⇒ Table

Returns the table that this materialized view applies to.

Returns:

  • (Table) —

    the table that this materialized view applies to.



42
43
44
 
# File 'lib/cassandra/materialized_view.rb', line 42

def base_table
  @keyspace.table(@base_table_name)
end

#to_cql ⇒ String

Returns a cql representation of this materialized view.

Returns:

  • (String) —

    a cql representation of this materialized view



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/cassandra/materialized_view.rb', line 47

def to_cql
  keyspace_name = Util.escape_name(@keyspace.name)
  cql = "CREATE MATERIALIZED VIEW #{keyspace_name}.#{Util.escape_name(@name)} AS\nSELECT "
  cql << if @include_all_columns
           '*'
         else
           @columns.map do |column|
             Util.escape_name(column.name)
           end.join(', ')
         end
  cql << "\nFROM #{keyspace_name}.#{Util.escape_name(@base_table_name)}"
  cql << "\nWHERE #{@where_clause}" if @where_clause
  cql << "\nPRIMARY KEY (("
  cql << @partition_key.map do |column|
    Util.escape_name(column.name)
  end.join(', ')
  cql << ')'
  unless @clustering_columns.empty?
    cql << ', '
    cql << @clustering_columns.map do |column|
      Util.escape_name(column.name)
    end.join(', ')
  end
  cql << ")\nWITH #{@options.to_cql.split("\n").join("\n ")};"
end