Class: Mongo::Operation::Commands::MapReduce::Result

Inherits:
Result
  • Object
show all
Defined in:
lib/mongo/operation/commands/map_reduce/result.rb

Overview

Defines custom behaviour of results for a map reduce operation.

Since:

  • 2.0.0

Constant Summary

COUNTS =

The counts field for the map/reduce.

Since:

  • 2.0.0

'counts'.freeze
RESULTS =

The field name for a result without a cursor.

Since:

  • 2.0.0

'results'.freeze
TIME =

The time the operation took constant.

Since:

  • 2.0.0

'timeMillis'.freeze

Constants inherited from Result

Result::CURSOR, Result::CURSOR_ID, Result::FIRST_BATCH, Result::N, Result::NAMESPACE, Result::NEXT_BATCH, Result::OK, Result::RESULT

Instance Attribute Summary

Attributes inherited from Result

#replies

Instance Method Summary collapse

Methods inherited from Result

#acknowledged?, #cursor_id, #each, #initialize, #inspect, #multiple?, #namespace, #ok?, #reply, #returned_count, #written_count

Constructor Details

This class inherits a constructor from Mongo::Operation::Result

Instance Method Details

#countsHash

Gets the map/reduce counts from the reply.

Examples:

Get the counts.

result.counts

Returns:

  • (Hash)

    A hash of the result counts.

Since:

  • 2.0.0



48
49
50
# File 'lib/mongo/operation/commands/map_reduce/result.rb', line 48

def counts
  reply.documents[0][COUNTS]
end

#documentsArray<BSON::Document>

Get the documents from the map/reduce.

Examples:

Get the documents.

result.documents

Returns:

  • (Array<BSON::Document>)

    The documents.

Since:

  • 2.0.0



60
61
62
# File 'lib/mongo/operation/commands/map_reduce/result.rb', line 60

def documents
  reply.documents[0][RESULTS] || reply.documents[0][RESULT]
end

#successful?true, false

Note:

If the write was unacknowledged, then this will always return true.

If the result was a command then determine if it was considered a success.

Examples:

Was the command successful?

result.successful?

Returns:

  • (true, false)

    If the command was successful.

Since:

  • 2.0.0



76
77
78
# File 'lib/mongo/operation/commands/map_reduce/result.rb', line 76

def successful?
  !documents.nil?
end

#timeInteger

Get the execution time of the map/reduce.

Examples:

Get the execution time.

result.time

Returns:

  • (Integer)

    The executing time in milliseconds.

Since:

  • 2.0.0



88
89
90
# File 'lib/mongo/operation/commands/map_reduce/result.rb', line 88

def time
  reply.documents[0][TIME]
end

#validate!Result

Note:

This only checks for errors with writes since authentication is handled at the connection level and any authentication errors would be raised there, before a Result is ever created.

Validate the result by checking for any errors.

Examples:

Validate the result.

result.validate!

Returns:

  • (Result)

    The result if verification passed.

Raises:

Since:

  • 2.0.0



106
107
108
# File 'lib/mongo/operation/commands/map_reduce/result.rb', line 106

def validate!
  documents.nil? ? raise(Error::OperationFailure.new(parser.message)) : self
end