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

4 entries across 4 versions & 1 rubygems

Version	Path
gotime-cassandra_object-4.5.1	lib/cassandra_object/scope.rb
gotime-cassandra_object-4.5.0	lib/cassandra_object/scope.rb
gotime-cassandra_object-4.4.5	lib/cassandra_object/scope.rb
gotime-cassandra_object-4.4.4	lib/cassandra_object/scope.rb