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?, #cluster_time, #each, #initialize, #inspect, #multiple?, #namespace, #ok?, #operation_time, #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

#cursor_idInteger

Get the cursor id.

Examples:

Get the cursor id.

result.cursor_id

Returns:

  • (Integer)

    Always 0 because map reduce doesn't return a cursor.

Since:

  • 2.5.0



118
119
120
# File 'lib/mongo/operation/commands/map_reduce/result.rb', line 118

def cursor_id
  0
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)) : self
end