Module: Mongoid::Contextual::Atomic
- Defined in:
- lib/mongoid/contextual/atomic.rb
Instance Method Summary collapse
-
#add_each_to_set(adds) ⇒ nil
Perform an atomic $addToSet/$each on the matching documents.
-
#add_to_set(adds) ⇒ nil
Execute an atomic $addToSet on the matching documents.
-
#bit(bits) ⇒ nil
Perform an atomic $bit operation on the matching documents.
-
#inc(incs) ⇒ nil
Perform an atomic $inc operation on the matching documents.
-
#pop(pops) ⇒ nil
Perform an atomic $pop operation on the matching documents.
-
#pull(pulls) ⇒ nil
Perform an atomic $pull operation on the matching documents.
-
#pull_all(pulls) ⇒ nil
Perform an atomic $pullAll operation on the matching documents.
-
#push(pushes) ⇒ nil
Perform an atomic $push operation on the matching documents.
-
#push_all(pushes) ⇒ nil
Perform an atomic $push/$each operation on the matching documents.
-
#rename(renames) ⇒ nil
Perform an atomic $rename of fields on the matching documents.
-
#set(sets) ⇒ nil
Perform an atomic $set of fields on the matching documents.
-
#unset(*args) ⇒ nil
Perform an atomic $unset of a field on the matching documents.
Instance Method Details
#add_each_to_set(adds) ⇒ nil
Perform an atomic $addToSet/$each on the matching documents.
32 33 34 |
# File 'lib/mongoid/contextual/atomic.rb', line 32 def add_each_to_set(adds) view.update_many("$addToSet" => collect_each_operations(adds)) end |
#add_to_set(adds) ⇒ nil
Execute an atomic $addToSet on the matching documents.
18 19 20 |
# File 'lib/mongoid/contextual/atomic.rb', line 18 def add_to_set(adds) view.update_many("$addToSet" => collect_operations(adds)) end |
#bit(bits) ⇒ nil
Perform an atomic $bit operation on the matching documents.
46 47 48 |
# File 'lib/mongoid/contextual/atomic.rb', line 46 def bit(bits) view.update_many("$bit" => collect_operations(bits)) end |
#inc(incs) ⇒ nil
Perform an atomic $inc operation on the matching documents.
60 61 62 |
# File 'lib/mongoid/contextual/atomic.rb', line 60 def inc(incs) view.update_many("$inc" => collect_operations(incs)) end |
#pop(pops) ⇒ nil
Perform an atomic $pop operation on the matching documents.
77 78 79 |
# File 'lib/mongoid/contextual/atomic.rb', line 77 def pop(pops) view.update_many("$pop" => collect_operations(pops)) end |
#pull(pulls) ⇒ nil
Expression pulling is not yet supported.
Perform an atomic $pull operation on the matching documents.
93 94 95 |
# File 'lib/mongoid/contextual/atomic.rb', line 93 def pull(pulls) view.update_many("$pull" => collect_operations(pulls)) end |
#pull_all(pulls) ⇒ nil
Perform an atomic $pullAll operation on the matching documents.
107 108 109 |
# File 'lib/mongoid/contextual/atomic.rb', line 107 def pull_all(pulls) view.update_many("$pullAll" => collect_operations(pulls)) end |
#push(pushes) ⇒ nil
Perform an atomic $push operation on the matching documents.
121 122 123 |
# File 'lib/mongoid/contextual/atomic.rb', line 121 def push(pushes) view.update_many("$push" => collect_operations(pushes)) end |
#push_all(pushes) ⇒ nil
Perform an atomic $push/$each operation on the matching documents.
135 136 137 |
# File 'lib/mongoid/contextual/atomic.rb', line 135 def push_all(pushes) view.update_many("$push" => collect_each_operations(pushes)) end |
#rename(renames) ⇒ nil
Perform an atomic $rename of fields on the matching documents.
149 150 151 152 153 154 155 |
# File 'lib/mongoid/contextual/atomic.rb', line 149 def rename(renames) operations = renames.inject({}) do |ops, (old_name, new_name)| ops[old_name] = new_name.to_s ops end view.update_many("$rename" => collect_operations(operations)) end |
#set(sets) ⇒ nil
Perform an atomic $set of fields on the matching documents.
167 168 169 |
# File 'lib/mongoid/contextual/atomic.rb', line 167 def set(sets) view.update_many("$set" => collect_operations(sets)) end |
#unset(*args) ⇒ nil
Perform an atomic $unset of a field on the matching documents.
184 185 186 187 188 189 |
# File 'lib/mongoid/contextual/atomic.rb', line 184 def unset(*args) fields = args.map { |a| a.is_a?(Hash) ? a.keys : a } .__find_args__ .map { |f| [database_field_name(f), true] } view.update_many("$unset" => Hash[fields]) end |