Sha256: c5cdf4dcf86d42424edd060112879b32adf7b750692713fb5021ecf88dc76bf6
Contents?: true
Size: 1.19 KB
Versions: 13
Compression:
Stored size: 1.19 KB
Contents
require 'cassandra_object/scope/batches'
require 'cassandra_object/scope/finder_methods'
require 'cassandra_object/scope/query_methods'
module CassandraObject
class Scope
include Batches, FinderMethods, QueryMethods
attr_accessor :klass
attr_accessor :limit_value, :select_values, :where_values
def initialize(klass)
@klass = klass
@limit_value = nil
@select_values = []
@where_values = []
end
private
def method_missing(method_name, *args, &block)
if klass.respond_to?(method_name)
klass.send(method_name, *args, &block)
elsif Array.method_defined?(method_name)
to_a.send(method_name, *args, &block)
else
super
end
end
def instantiate_from_cql(cql_string, *args)
results = []
klass.execute_cql(cql_string, *args).fetch do |cql_row|
results << instantiate_cql_row(cql_row)
end
results.compact!
results
end
def instantiate_cql_row(cql_row)
attributes = cql_row.to_hash
key = attributes.delete('KEY')
if attributes.any?
klass.instantiate(key, attributes)
end
end
end
end
Version data entries
13 entries across 13 versions & 2 rubygems