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