Class: DatastaxRails::Cql::Base
- Defined in:
- lib/datastax_rails/cql/base.rb
Overview
Base class for CQL generation
Direct Known Subclasses
AlterColumnFamily, CreateColumnFamily, CreateIndex, CreateKeyspace, Delete, DropColumnFamily, DropIndex, DropKeyspace, Insert, Select, Truncate, Update, UseKeyspace
Instance Method Summary collapse
-
#execute ⇒ Object
Generates the CQL and calls Cassandra to execute it.
-
#initialize(klass, *_args) ⇒ Base
constructor
Base initialize that sets the default consistency.
-
#to_cql ⇒ Object
Abstract.
- #using(consistency) ⇒ Object
Constructor Details
#initialize(klass, *_args) ⇒ Base
Base initialize that sets the default consistency.
6 7 8 9 10 |
# File 'lib/datastax_rails/cql/base.rb', line 6 def initialize(klass, *_args) @consistency = klass.default_consistency.to_s.downcase.to_sym @keyspace = DatastaxRails::Base.config[:keyspace] @values = [] end |
Instance Method Details
#execute ⇒ Object
Generates the CQL and calls Cassandra to execute it. If you are using this outside of Rails, then DatastaxRails::Base.connection must have already been set up (Rails does this for you).
25 26 27 28 29 30 31 32 33 34 35 36 |
# File 'lib/datastax_rails/cql/base.rb', line 25 def execute cql = to_cql puts cql if ENV['DEBUG_CQL'] == 'true' pp @values if ENV['DEBUG_CQL'] == 'true' digest = Digest::MD5.digest cql stmt = DatastaxRails::Base.statement_cache[digest] ||= DatastaxRails::Base.connection.prepare(cql) if @consistency stmt.execute(*@values, consistency: @consistency) else stmt.execute(*@values) end end |
#to_cql ⇒ Object
Abstract. Should be overridden by subclasses
18 19 20 |
# File 'lib/datastax_rails/cql/base.rb', line 18 def to_cql fail NotImplementedError end |
#using(consistency) ⇒ Object
12 13 14 15 |
# File 'lib/datastax_rails/cql/base.rb', line 12 def using(consistency) @consistency = consistency.to_s.downcase.to_sym self end |