Contents

module CassandraObject
  class Scope
    module FinderMethods
      def find(ids)
        if ids.is_a?(Array)
          find_some(ids)
        else
          find_one(ids)
        end
      end

      def find_by_id(ids)
        find(ids)
      rescue CassandraObject::RecordNotFound
        nil
      end

      def all
        to_a
      end

      def first
        limit(1).to_a.first
      end

      private
        def find_one(id)
          if id.blank?
            raise CassandraObject::RecordNotFound, "Couldn't find #{self.name} with key #{id.inspect}"
          elsif record = where('KEY' => id).first
            record
          else
            raise CassandraObject::RecordNotFound
          end
        end

        def find_some(ids)
          ids = ids.flatten
          return [] if ids.empty?

          ids = ids.compact.map(&:to_s).uniq

          where("KEY" => ids).to_a
        end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
gotime-cassandra_object-4.5.1	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.5.0	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.4.5	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.4.4	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.4.3	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.3.2	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.3.1	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.3.0	lib/cassandra_object/scope/finder_methods.rb
gotime-cassandra_object-4.2.2	lib/cassandra_object/scope/finder_methods.rb