mongo-ruby-driver/lib/mongo/message/update_message.rb

22 lines
469 B
Ruby
Raw Normal View History

2008-11-22 01:00:51 +00:00
require 'mongo/message/message'
require 'mongo/message/opcodes'
module XGen
module Mongo
module Driver
class UpdateMessage < Message
def initialize(name, collection, sel, obj, repsert)
super(OP_UPDATE)
write_int(0)
write_string("#{name}.#{collection}")
write_int(repsert ? 1 : 0) # 1 if a repsert operation (upsert)
write_doc(sel)
write_doc(obj)
end
end
end
end
end