Class: Mongo::Operation::Result
Relationships & Source Files | |
Namespace Children | |
Modules:
| |
Extension / Inclusion / Inheritance Descendants | |
Subclasses:
Aggregate::Result, CollectionsInfo::Result, Delete::BulkResult, Delete::Result, Explain::Result, Find::Result, GetMore::Result, Indexes::Result, Insert::BulkResult, Insert::Result, ListCollections::Result, MapReduce::Result, ParallelScan::Result, Update::BulkResult, Update::Result, UsersInfo::Result
|
|
Super Chains via Extension / Inclusion / Inheritance | |
Class Chain:
self,
Forwardable
|
|
Instance Chain:
self,
Enumerable
|
|
Inherits: | Object |
Defined in: | lib/mongo/operation/result.rb, lib/mongo/operation/shared/result/aggregatable.rb, lib/mongo/operation/shared/result/use_legacy_error_parser.rb |
Overview
Result
wrapper for wire protocol replies.
An operation has zero or one replies. The only operations producing zero replies are unacknowledged writes; all other operations produce one reply. This class provides an object that can be operated on (for example, to check whether an operation succeeded) even when the operation did not produce a reply (in which case it is assumed to have succeeded).
Constant Summary
-
CURSOR =
Internal use only
The field name for the cursor document in an aggregation.
'cursor'.freeze
-
CURSOR_ID =
Internal use only
The cursor id field in the cursor document.
'id'.freeze
-
FIRST_BATCH =
Internal use only
The field name for the first batch of a cursor.
'firstBatch'.freeze
-
N =
Internal use only
The number of documents updated in the write.
'n'.freeze
-
NAMESPACE =
Internal use only
The namespace field in the cursor document.
'ns'.freeze
-
NEXT_BATCH =
Internal use only
The field name for the next batch of a cursor.
'nextBatch'.freeze
-
OK =
Internal use only
The ok status field in the result.
'ok'.freeze
-
RESULT =
Internal use only
The result field constant.
'result'.freeze
Class Method Summary
-
.new(replies, connection_description = nil, connection_global_id = nil) ⇒ Result
constructor
Internal use only
Internal use only
Initialize a new result.
Instance Attribute Summary
-
#acknowledged? ⇒ true, false
readonly
Is the result acknowledged?
- #connection_description ⇒ Server::Description readonly Internal use only Internal use only
- #connection_global_id ⇒ Object readonly Internal use only Internal use only
-
#has_cursor_id? ⇒ true, false
readonly
Internal use only
Internal use only
Whether the result contains cursor_id.
-
#ok? ⇒ true, false
readonly
Check the first document’s ok field.
- #replies ⇒ Array<Protocol::Message> readonly Internal use only Internal use only
-
#successful? ⇒ true, false
readonly
If the result was a command then determine if it was considered a success.
-
#write_concern_error? ⇒ Boolean
readonly
Internal use only
Internal use only
Whether the operation failed with a write concern error.
- #query_failure? ⇒ Boolean readonly private
Instance Method Summary
-
#cluster_time ⇒ ClusterTime | nil
Get the cluster time reported in the server response.
-
#cursor_id ⇒ Integer
Internal use only
Internal use only
Get the cursor id if the response is acknowledged.
-
#documents ⇒ Array<BSON::Document>
Get the documents in the result.
-
#each {|Each| ... } ⇒ Enumerator
Iterate over the documents in the replies.
-
#error ⇒ Error::OperationFailure
Internal use only
Internal use only
The exception instance (of the
::Mongo::Error::OperationFailure
class) that would be raised during processing of this result. -
#inspect ⇒ String
Get the pretty formatted inspection of the result.
-
#labels ⇒ Array
Internal use only
Internal use only
Gets the set of error labels associated with the result.
-
#n
Alias for #written_count.
-
#namespace ⇒ Nil
Internal use only
Internal use only
Get the namespace of the cursor.
-
#operation_time ⇒ Object | nil
Get the operation time reported in the server response.
-
#reply ⇒ Protocol::Message
Internal use only
Internal use only
Get the reply from the result.
-
#returned_count ⇒ Integer
Get the number of documents returned by the server in this batch.
- #snapshot_timestamp
- #topology_version ⇒ TopologyVersion | nil Internal use only Internal use only
-
#validate! ⇒ Result
Internal use only
Internal use only
Validate the result by checking for any errors.
-
#written_count ⇒ Integer
(also: #n)
Get the number of documents written by the server.
- #aggregate_returned_count private
- #aggregate_written_count private
- #first_document private
- #parser private
-
#raise_operation_failure
private
Raises a Mongo::OperationFailure exception corresponding to the error information in this result.
Instance Attribute Details
#acknowledged? ⇒ true
, false
(readonly)
On MongoDB 2.6 and higher all writes are acknowledged since the driver uses write commands for all write operations. On 2.4 and lower, the result is acknowledged if the GLE has been executed after the command. If not, no replies will be specified. Reads will always return true here since a replies is always provided.
Is the result acknowledged?
# File 'lib/mongo/operation/result.rb', line 157
def acknowledged? !!@replies end
#connection_description ⇒ Server::Description (readonly)
# File 'lib/mongo/operation/result.rb', line 133
attr_reader :connection_description
#connection_global_id ⇒ Object
(readonly)
# File 'lib/mongo/operation/result.rb', line 139
attr_reader :connection_global_id
#has_cursor_id? ⇒ true
, false
(readonly)
Whether the result contains cursor_id
# File 'lib/mongo/operation/result.rb', line 166
def has_cursor_id? acknowledged? && replies.last.respond_to?(:cursor_id) end
#ok? ⇒ true
, false
(readonly)
Check the first document’s ok field.
# File 'lib/mongo/operation/result.rb', line 305
def ok? # first_document[OK] is a float, and the server can return # ok as a BSON int32, BSON int64 or a BSON double. # The number 1 is exactly representable in a float, hence # 1.0 == 1 is going to perform correctly all of the time # (until the server returns something other than 1 for success, that is) first_document[OK] == 1 end
#query_failure? ⇒ Boolean
(readonly, private)
#replies ⇒ Array
<Protocol::Message> (readonly)
# File 'lib/mongo/operation/result.rb', line 127
attr_reader :replies
#successful? ⇒ true
, false
(readonly)
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.
# File 'lib/mongo/operation/result.rb', line 287
def successful? return true if !acknowledged? if first_document.has_key?(OK) ok? && parser. .empty? else !query_failure? && parser. .empty? end end
#write_concern_error? ⇒ Boolean
(readonly)
Whether the operation failed with a write concern error.
# File 'lib/mongo/operation/result.rb', line 444
def write_concern_error? !!(first_document && first_document['writeConcernError']) end
Instance Method Details
#aggregate_returned_count (private)
#aggregate_written_count (private)
#cluster_time ⇒ ClusterTime | nil
Get the cluster time reported in the server response.
Changed in version 2.9.0: This attribute became an instance of ::Mongo::ClusterTime
, which is a subclass of BSON::Document. Previously it was an instance of BSON::Document.
# File 'lib/mongo/operation/result.rb', line 424
def cluster_time first_document && ClusterTime[first_document['$clusterTime']] end
#cursor_id ⇒ Integer
::Mongo::Cursor
ids of 0 indicate there is no cursor on the server.
Get the cursor id if the response is acknowledged.
# File 'lib/mongo/operation/result.rb', line 181
def cursor_id acknowledged? ? replies.last.cursor_id : 0 end
#documents ⇒ Array
<BSON::Document
>
Get the documents in the result.
# File 'lib/mongo/operation/result.rb', line 205
def documents if acknowledged? replies.flat_map(&:documents) else [] end end
#each {|Each| ... } ⇒ Enumerator
Iterate over the documents in the replies.
# File 'lib/mongo/operation/result.rb', line 226
def each(&block) documents.each(&block) end
#error ⇒ Error::OperationFailure
The exception instance (of the ::Mongo::Error::OperationFailure
class) that would be raised during processing of this result.
This method should only be called when result is not successful.
# File 'lib/mongo/operation/result.rb', line 341
def error @error ||= Error::OperationFailure.new( parser., self, code: parser.code, code_name: parser.code_name, write_concern_error_document: parser.write_concern_error_document, write_concern_error_code: parser.write_concern_error_code, write_concern_error_code_name: parser.write_concern_error_code_name, write_concern_error_labels: parser.write_concern_error_labels, labels: parser.labels, wtimeout: parser.wtimeout, connection_description: connection_description, document: parser.document, server_message: parser., ) end
#first_document (private)
# File 'lib/mongo/operation/result.rb', line 474
def first_document @first_document ||= first || BSON::Document.new end
#inspect ⇒ String
Get the pretty formatted inspection of the result.
# File 'lib/mongo/operation/result.rb', line 239
def inspect "#<#{self.class.name}:0x#{object_id} documents=#{documents}>" end
#labels ⇒ Array
Gets the set of error labels associated with the result.
# File 'lib/mongo/operation/result.rb', line 437
def labels @labels ||= parser.labels end
#n
Alias for #written_count.
# File 'lib/mongo/operation/result.rb', line 396
alias :n :written_count
#namespace ⇒ Nil
Get the namespace of the cursor. The method should be defined in result classes where ‘ns’ is in the server response.
# File 'lib/mongo/operation/result.rb', line 192
def namespace nil end
#operation_time ⇒ Object
| nil
Get the operation time reported in the server response.
# File 'lib/mongo/operation/result.rb', line 407
def operation_time first_document && first_document[OPERATION_TIME] end
#parser (private)
# File 'lib/mongo/operation/result.rb', line 470
def parser @parser ||= Error::Parser.new(first_document, replies) end
#raise_operation_failure (private)
Raises a Mongo::OperationFailure exception corresponding to the error information in this result.
# File 'lib/mongo/operation/result.rb', line 363
private def raise_operation_failure raise error end
#reply ⇒ Protocol::Message
Get the reply from the result.
Returns nil if there is no reply (i.e. the operation was an unacknowledged write).
# File 'lib/mongo/operation/result.rb', line 252
def reply if acknowledged? replies.first else nil end end
#returned_count ⇒ Integer
Get the number of documents returned by the server in this batch.
# File 'lib/mongo/operation/result.rb', line 266
def returned_count if acknowledged? reply.number_returned else 0 end end
#snapshot_timestamp
#topology_version ⇒ TopologyVersion | nil
# File 'lib/mongo/operation/result.rb', line 370
def topology_version unless defined?(@topology_version) @topology_version = first_document['topologyVersion'] && TopologyVersion.new(first_document['topologyVersion']) end @topology_version end
#validate! ⇒ Result
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.
# File 'lib/mongo/operation/result.rb', line 329
def validate! !successful? ? raise_operation_failure : self end
#written_count ⇒ Integer
Also known as: #n
Get the number of documents written by the server.
# File 'lib/mongo/operation/result.rb', line 387
def written_count if acknowledged? first_document[N] || 0 else 0 end end