Module: Mongo::Collection::View::Readable
- Included in:
- Mongo::Collection::View
- Defined in:
- build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb
Overview
Defines read related behavior for collection view.
Instance Method Summary collapse
-
#aggregate(pipeline, options = {}) ⇒ Aggregation
Execute an aggregation on the collection view.
-
#allow_disk_use ⇒ View
Allows the server to write temporary data to disk while executing a find operation.
-
#allow_partial_results ⇒ View
Allows the query to get partial results if some shards are down.
-
#await_data ⇒ View
Tell the query’s cursor to stay open and wait for data.
-
#batch_size(batch_size = nil) ⇒ Integer, View
The number of documents returned in each batch of results from MongoDB.
-
#comment(comment = nil) ⇒ String, View
Associate a comment with the query.
-
#count(opts = {}) ⇒ Integer
deprecated
Deprecated.
Use #count_documents or #estimated_document_count instead. However, note that the following operators will need to be substituted when switching to #count_documents:
* $where should be replaced with $expr (only works on 3.6+) * $near should be replaced with $geoWithin with $center * $nearSphere should be replaced with $geoWithin with $centerSphere
-
#count_documents(opts = {}) ⇒ Integer
Get a count of matching documents in the collection.
-
#cursor_type(type = nil) ⇒ :tailable, ...
The type of cursor to use.
-
#distinct(field_name, opts = {}) ⇒ Array<Object>
Get a list of distinct values for a specific field.
-
#estimated_document_count(opts = {}) ⇒ Integer
Gets an estimate of the count of documents in a collection using collection metadata.
-
#hint(hint = nil) ⇒ Hash, View
The index that MongoDB will be forced to use for the query.
-
#limit(limit = nil) ⇒ Integer, View
The max number of docs to return from the query.
-
#map_reduce(map, reduce, options = {}) ⇒ MapReduce
Execute a map/reduce operation on the collection view.
-
#max_await_time_ms(max = nil) ⇒ Integer, View
A cumulative time limit in milliseconds for processing get more operations on a cursor.
-
#max_scan(value = nil) ⇒ Integer, View
deprecated
Deprecated.
This option is deprecated as of MongoDB server version 4.0.
-
#max_time_ms(max = nil) ⇒ Integer, View
A cumulative time limit in milliseconds for processing operations on a cursor.
-
#max_value(value = nil) ⇒ Hash, View
Set the maximum value to search.
-
#min_value(value = nil) ⇒ Hash, View
Set the minimum value to search.
-
#modifiers(doc = nil) ⇒ Hash, View
If called without arguments or with a nil argument, returns the legacy (OP_QUERY) server modifiers for the current view.
-
#no_cursor_timeout ⇒ View
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use.
-
#projection(document = nil) ⇒ Hash, View
The fields to include or exclude from each doc in the result set.
-
#read(value = nil) ⇒ Symbol, View
The read preference to use for the query.
- #read_concern ⇒ Object private
- #read_preference ⇒ Object private
-
#return_key(value = nil) ⇒ true, ...
Set whether to return only the indexed field or fields.
-
#show_disk_loc(value = nil) ⇒ true, ...
(also: #show_record_id)
Set whether the disk location should be shown for each document.
-
#skip(number = nil) ⇒ Integer, View
The number of docs to skip before returning results.
-
#snapshot(value = nil) ⇒ Object
deprecated
Deprecated.
This option is deprecated as of MongoDB server version 4.0.
-
#sort(spec = nil) ⇒ Hash, View
The key and direction pairs by which the result set will be sorted.
Instance Method Details
#aggregate(pipeline, options = {}) ⇒ Aggregation
Execute an aggregation on the collection view.
60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 60 def aggregate(pipeline, = {}) = @options.merge() unless Mongo. aggregation = Aggregation.new(self, pipeline, ) # Because the $merge and $out pipeline stages write documents to the # collection, it is necessary to clear the cache when they are performed. # # Opt to clear the entire cache rather than one namespace because # the $out and $merge stages do not have to write to the same namespace # on which the aggregation is performed. QueryCache.clear if aggregation.write? aggregation end |
#allow_disk_use ⇒ View
Allows the server to write temporary data to disk while executing a find operation.
79 80 81 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 79 def allow_disk_use configure(:allow_disk_use, true) end |
#allow_partial_results ⇒ View
Allows the query to get partial results if some shards are down.
91 92 93 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 91 def allow_partial_results configure(:allow_partial_results, true) end |
#await_data ⇒ View
Tell the query’s cursor to stay open and wait for data.
103 104 105 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 103 def await_data configure(:await_data, true) end |
#batch_size(batch_size = nil) ⇒ Integer, View
Specifying 1 or a negative number is analogous to setting a limit.
The number of documents returned in each batch of results from MongoDB.
120 121 122 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 120 def batch_size(batch_size = nil) configure(:batch_size, batch_size) end |
#comment(comment = nil) ⇒ String, View
Set profilingLevel to 2 and the comment will be logged in the profile collection along with the query.
Associate a comment with the query.
138 139 140 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 138 def comment(comment = nil) configure(:comment, comment) end |
#count(opts = {}) ⇒ Integer
Use #count_documents or #estimated_document_count instead. However, note that the following operators will need to be substituted when switching to #count_documents:
* $where should be replaced with $expr (only works on 3.6+)
* $near should be replaced with $geoWithin with $center
* $nearSphere should be replaced with $geoWithin with $centerSphere
Get a count of matching documents in the collection.
170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 170 def count(opts = {}) opts = @options.merge(opts) unless Mongo. cmd = { :count => collection.name, :query => filter } cmd[:skip] = opts[:skip] if opts[:skip] cmd[:hint] = opts[:hint] if opts[:hint] cmd[:limit] = opts[:limit] if opts[:limit] if read_concern cmd[:readConcern] = Options::Mapper.transform_values_to_strings( read_concern) end cmd[:maxTimeMS] = opts[:max_time_ms] if opts[:max_time_ms] Mongo::Lint.validate_underscore_read_preference(opts[:read]) read_pref = opts[:read] || read_preference selector = ServerSelector.get(read_pref || server_selector) with_session(opts) do |session| read_with_retry(session, selector) do |server| Operation::Count.new( selector: cmd, db_name: database.name, options: {:limit => -1}, read: read_pref, session: session, # For some reason collation was historically accepted as a # string key. Note that this isn't documented as valid usage. collation: opts[:collation] || opts['collation'] || collation, comment: opts[:comment], ).execute(server, context: Operation::Context.new(client: client, session: session)) end.n.to_i end end |
#count_documents(opts = {}) ⇒ Integer
Get a count of matching documents in the collection.
223 224 225 226 227 228 229 230 231 232 233 234 235 236 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 223 def count_documents(opts = {}) opts = @options.merge(opts) unless Mongo. pipeline = [:'$match' => filter] pipeline << { :'$skip' => opts[:skip] } if opts[:skip] pipeline << { :'$limit' => opts[:limit] } if opts[:limit] pipeline << { :'$group' => { _id: 1, n: { :'$sum' => 1 } } } opts = opts.slice(:hint, :max_time_ms, :read, :collation, :session, :comment) opts[:collation] ||= collation first = aggregate(pipeline, opts).first return 0 unless first first['n'].to_i end |
#cursor_type(type = nil) ⇒ :tailable, ...
The type of cursor to use. Can be :tailable or :tailable_await.
626 627 628 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 626 def cursor_type(type = nil) configure(:cursor_type, type) end |
#distinct(field_name, opts = {}) ⇒ Array<Object>
Get a list of distinct values for a specific field.
317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 317 def distinct(field_name, opts = {}) if field_name.nil? raise ArgumentError, 'Field name for distinct operation must be not nil' end opts = @options.merge(opts) unless Mongo. cmd = { :distinct => collection.name, :key => field_name.to_s, :query => filter, } cmd[:maxTimeMS] = opts[:max_time_ms] if opts[:max_time_ms] if read_concern cmd[:readConcern] = Options::Mapper.transform_values_to_strings( read_concern) end Mongo::Lint.validate_underscore_read_preference(opts[:read]) read_pref = opts[:read] || read_preference selector = ServerSelector.get(read_pref || server_selector) with_session(opts) do |session| read_with_retry(session, selector) do |server| Operation::Distinct.new( selector: cmd, db_name: database.name, options: {:limit => -1}, read: read_pref, session: session, comment: opts[:comment], # For some reason collation was historically accepted as a # string key. Note that this isn't documented as valid usage. collation: opts[:collation] || opts['collation'] || collation, ).execute(server, context: Operation::Context.new(client: client, session: session)) end.first['values'] end end |
#estimated_document_count(opts = {}) ⇒ Integer
Gets an estimate of the count of documents in a collection using collection metadata.
254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 254 def estimated_document_count(opts = {}) unless view.filter.empty? raise ArgumentError, "Cannot call estimated_document_count when querying with a filter" end %i[limit skip].each do |opt| if .key?(opt) || opts.key?(opt) raise ArgumentError, "Cannot call estimated_document_count when querying with #{opt}" end end opts = @options.merge(opts) unless Mongo. Mongo::Lint.validate_underscore_read_preference(opts[:read]) read_pref = opts[:read] || read_preference selector = ServerSelector.get(read_pref || server_selector) with_session(opts) do |session| read_with_retry(session, selector) do |server| context = Operation::Context.new(client: client, session: session) cmd = { count: collection.name } cmd[:maxTimeMS] = opts[:max_time_ms] if opts[:max_time_ms] if read_concern cmd[:readConcern] = Options::Mapper.transform_values_to_strings(read_concern) end result = Operation::Count.new( selector: cmd, db_name: database.name, read: read_pref, session: session, comment: opts[:comment], ).execute(server, context: context) result.n.to_i end end rescue Error::OperationFailure => exc if exc.code == 26 # NamespaceNotFound # This should only happen with the aggregation pipeline path # (server 4.9+). Previous servers should return 0 for nonexistent # collections. 0 else raise end end |
#hint(hint = nil) ⇒ Hash, View
The index that MongoDB will be forced to use for the query.
360 361 362 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 360 def hint(hint = nil) configure(:hint, hint) end |
#limit(limit = nil) ⇒ Integer, View
The max number of docs to return from the query.
374 375 376 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 374 def limit(limit = nil) configure(:limit, limit) end |
#map_reduce(map, reduce, options = {}) ⇒ MapReduce
Execute a map/reduce operation on the collection view.
390 391 392 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 390 def map_reduce(map, reduce, = {}) MapReduce.new(self, map, reduce, @options.merge()) end |
#max_await_time_ms(max = nil) ⇒ Integer, View
A cumulative time limit in milliseconds for processing get more operations on a cursor.
598 599 600 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 598 def max_await_time_ms(max = nil) configure(:max_await_time_ms, max) end |
#max_scan(value = nil) ⇒ Integer, View
This option is deprecated as of MongoDB server version 4.0.
Set the max number of documents to scan.
407 408 409 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 407 def max_scan(value = nil) configure(:max_scan, value) end |
#max_time_ms(max = nil) ⇒ Integer, View
A cumulative time limit in milliseconds for processing operations on a cursor.
612 613 614 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 612 def max_time_ms(max = nil) configure(:max_time_ms, max) end |
#max_value(value = nil) ⇒ Hash, View
Set the maximum value to search.
421 422 423 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 421 def max_value(value = nil) configure(:max_value, value) end |
#min_value(value = nil) ⇒ Hash, View
Set the minimum value to search.
435 436 437 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 435 def min_value(value = nil) configure(:min_value, value) end |
#modifiers(doc = nil) ⇒ Hash, View
If called without arguments or with a nil argument, returns the legacy (OP_QUERY) server modifiers for the current view. If called with a non-nil argument, which must be a Hash or a subclass, merges the provided modifiers into the current view. Both string and symbol keys are allowed in the input hash.
579 580 581 582 583 584 585 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 579 def modifiers(doc = nil) if doc.nil? Operation::Find::Builder::Modifiers.map_server_modifiers() else new(.merge(Operation::Find::Builder::Modifiers.(BSON::Document.new(doc)))) end end |
#no_cursor_timeout ⇒ View
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to prevent that.
448 449 450 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 448 def no_cursor_timeout configure(:no_cursor_timeout, true) end |
#projection(document = nil) ⇒ Hash, View
A value of 0 excludes a field from the doc. A value of 1 includes it. Values must all be 0 or all be 1, with the exception of the _id value. The _id field is included by default. It must be excluded explicitly.
The fields to include or exclude from each doc in the result set.
466 467 468 469 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 466 def projection(document = nil) validate_doc!(document) if document configure(:projection, document) end |
#read(value = nil) ⇒ Symbol, View
If none is specified for the query, the read preference of the collection will be used.
The read preference to use for the query.
482 483 484 485 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 482 def read(value = nil) return read_preference if value.nil? configure(:read, value) end |
#read_concern ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
631 632 633 634 635 636 637 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 631 def read_concern if [:session] && [:session].in_transaction? [:session].send(:txn_read_concern) || collection.client.read_concern else collection.read_concern end end |
#read_preference ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 640 def read_preference @read_preference ||= begin # Operation read preference is always respected, and has the # highest priority. If we are in a transaction, we look at # transaction read preference and default to client, ignoring # collection read preference. If we are not in transaction we # look at collection read preference which defaults to client. rp = if [:read] [:read] elsif [:session] && [:session].in_transaction? [:session].txn_read_preference || collection.client.read_preference else collection.read_preference end Lint.validate_underscore_read_preference(rp) rp end end |
#return_key(value = nil) ⇒ true, ...
Set whether to return only the indexed field or fields.
497 498 499 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 497 def return_key(value = nil) configure(:return_key, value) end |
#show_disk_loc(value = nil) ⇒ true, ... Also known as: show_record_id
Set whether the disk location should be shown for each document.
512 513 514 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 512 def show_disk_loc(value = nil) configure(:show_disk_loc, value) end |
#skip(number = nil) ⇒ Integer, View
The number of docs to skip before returning results.
528 529 530 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 528 def skip(number = nil) configure(:skip, number) end |
#snapshot(value = nil) ⇒ Object
This option is deprecated as of MongoDB server version 4.0.
When set to true, prevents documents from returning more than once.
Set the snapshot value for the view.
546 547 548 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 546 def snapshot(value = nil) configure(:snapshot, value) end |
#sort(spec = nil) ⇒ Hash, View
The key and direction pairs by which the result set will be sorted.
561 562 563 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', line 561 def sort(spec = nil) configure(:sort, spec) end |