module Mongo::Operation::Write::WriteCommandEnabled
This module contains common functionality for operations that send either a write command or a specific wire protocol message, depending on server version. For server versions >= 2.6, a write command is sent.
@since 2.1.0
Public Instance Methods
execute(server)
click to toggle source
Execute the operation.
@example Execute the operation.
operation.execute(server)
@param [ Mongo::Server
] server The server to send this operation to.
@return [ Result
] The operation result.
@since 2.1.0
# File lib/mongo/operation/write/write_command_enabled.rb, line 36 def execute(server) if unacknowledged_write? raise Error::UnsupportedCollation.new(Error::UnsupportedCollation::UNACKNOWLEDGED_WRITES_MESSAGE) if has_collation? raise Error::UnsupportedArrayFilters.new(Error::UnsupportedArrayFilters::UNACKNOWLEDGED_WRITES_MESSAGE) if has_array_filters? end if server.features.op_msg_enabled? # version 3.6 execute_write_command(server) else # server version is 2.6 through 3.4 if unacknowledged_write? execute_message(server) else execute_write_command(server) end end end
Private Instance Methods
execute_write_command(server)
click to toggle source
# File lib/mongo/operation/write/write_command_enabled.rb, line 67 def execute_write_command(server) result_class = self.class.const_defined?(:Result, false) ? self.class::Result : Result result = result_class.new(write_command_op.execute(server)) server.update_cluster_time(result) session.process(result) if session result.validate! end
has_array_filters?()
click to toggle source
# File lib/mongo/operation/write/write_command_enabled.rb, line 55 def has_array_filters? false end
has_collation?()
click to toggle source
# File lib/mongo/operation/write/write_command_enabled.rb, line 59 def has_collation? false end
unacknowledged_write?()
click to toggle source
# File lib/mongo/operation/write/write_command_enabled.rb, line 63 def unacknowledged_write? write_concern && write_concern.get_last_error.nil? end