Class: MongoODM::Collection

Inherits:
Mongo::Collection
  • Object
show all
Defined in:
lib/mongo_odm/collection.rb

Instance Method Summary collapse

Instance Method Details

#find(selector = {}, opts = {}) ⇒ Object

Raises:

  • (RuntimeError) 


5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/mongo_odm/collection.rb', line 5

def find(selector={}, opts={})
  fields = opts.delete(:fields)
  fields = ["_id"] if fields && fields.empty?
  skip   = opts.delete(:skip) || skip || 0
  limit  = opts.delete(:limit) || 0
  sort   = opts.delete(:sort)
  hint   = opts.delete(:hint)
  snapshot   = opts.delete(:snapshot)
  batch_size = opts.delete(:batch_size)
  timeout    = (opts.delete(:timeout) == false) ? false : true

  if timeout == false && !block_given?
    raise ArgumentError, "Collection#find must be invoked with a block when timeout is disabled."
  end

  if hint
    hint = normalize_hint_fields(hint)
  else
    hint = @hint        # assumed to be normalized already
  end

  raise RuntimeError, "Unknown options [#{opts.inspect}]" unless opts.empty?

  cursor = MongoODM::Cursor.new(self, :selector => selector, :fields => fields, :skip => skip, :limit => limit,
    :order => sort, :hint => hint, :snapshot => snapshot, :timeout => timeout, :batch_size => batch_size)

  if block_given?
    yield cursor
    cursor.close()
    nil
  else
    cursor
  end
end

#find_and_modify(*args) ⇒ Object 



40
41
42
 
# File 'lib/mongo_odm/collection.rb', line 40

def find_and_modify(*args)
  MongoODM.instanciate(super)
end

#insert(doc_or_docs, options = {}) ⇒ Object 



44
45
46
47
 
# File 'lib/mongo_odm/collection.rb', line 44

def insert(doc_or_docs, options={})
  doc_or_docs = [doc_or_docs] unless doc_or_docs.is_a?(Array)
  super doc_or_docs.map{|doc| doc.respond_to?(:to_mongo) ? doc.to_mongo : doc}
end