Sha256: 21bbce9171841ce225d46f87a2af1e852dbe719579bd195f8bb8986451973616
Contents?: true
Size: 927 Bytes
Versions: 23
Compression:
Stored size: 927 Bytes
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
23 entries across 23 versions & 2 rubygems