Class: Mongo::BulkWrite

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Includes:
Operation::ResponseHandling
Defined in:
lib/mongo/bulk_write.rb,
lib/mongo/bulk_write/result.rb,
lib/mongo/bulk_write/combineable.rb,
lib/mongo/bulk_write/validatable.rb,
lib/mongo/bulk_write/transformable.rb,
lib/mongo/bulk_write/result_combiner.rb,
lib/mongo/bulk_write/ordered_combiner.rb,
lib/mongo/bulk_write/unordered_combiner.rb

Defined Under Namespace

Modules: Combineable, Transformable, Validatable Classes: OrderedCombiner, Result, ResultCombiner, UnorderedCombiner

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(collection, requests, options = {}) ⇒ BulkWrite

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.

Create the new bulk write operation.

Examples:

Create an ordered bulk write.

Mongo::BulkWrite.new(collection, [{ insert_one: { _id: 1 }}])

Create an unordered bulk write.

Mongo::BulkWrite.new(collection, [{ insert_one: { _id: 1 }}], ordered: false)

Create an ordered mixed bulk write.

Mongo::BulkWrite.new(
  collection,
  [
    { insert_one: { _id: 1 }},
    { update_one: { filter: { _id: 0 }, update: { '$set' => { name: 'test' }}}},
    { delete_one: { filter: { _id: 2 }}}
  ]
)

Parameters:

  • The collection.

  • The requests.

  • (defaults to: {})

    The options.

Since:

  • 2.1.0

API:

  • private



119
120
121
122
123
 
# File 'lib/mongo/bulk_write.rb', line 119

def initialize(collection, requests, options = {})
  @collection = collection
  @requests = requests
  @options = options || {}
end

Instance Attribute Details

#collection ⇒ Mongo::Collection (readonly)

Returns collection The collection.

Returns:

  • collection The collection.



29
30
31
 
# File 'lib/mongo/bulk_write.rb', line 29

def collection
  @collection
end

#options ⇒ Hash, BSON::Document (readonly)

Returns options The options.

Returns:

  • options The options.



35
36
37
 
# File 'lib/mongo/bulk_write.rb', line 35

def options
  @options
end

#requests ⇒ Array<Hash, BSON::Document> (readonly)

Returns requests The requests.

Returns:

  • requests The requests.



32
33
34
 
# File 'lib/mongo/bulk_write.rb', line 32

def requests
  @requests
end

Instance Method Details

#execute ⇒ Mongo::BulkWrite::Result

Execute the bulk write operation.

Examples:

Execute the bulk write.

bulk_write.execute

Returns:

  • The result.

Since:

  • 2.1.0



55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
 
# File 'lib/mongo/bulk_write.rb', line 55

def execute
  operation_id = Monitoring.next_operation_id
  result_combiner = ResultCombiner.new
  operations = op_combiner.combine

  client.send(:with_session, @options) do |session|
    operations.each do |operation|
      if single_statement?(operation)
        write_concern = write_concern(session)
        write_with_retry(session, write_concern) do |server, txn_num|
          server.with_connection do |connection|
            execute_operation(
              operation.keys.first,
              operation.values.flatten,
              connection,
              operation_id,
              result_combiner,
              session,
              txn_num)
          end
        end
      else
        nro_write_with_retry(session, write_concern) do |server|
          server.with_connection do |connection|
            execute_operation(
              operation.keys.first,
              operation.values.flatten,
              connection,
              operation_id,
              result_combiner,
              session)
          end
        end
      end
    end
  end
  result_combiner.result
end

#ordered? ⇒ true, false

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.

Is the bulk write ordered?

Examples:

Is the bulk write ordered?

bulk_write.ordered?

Returns:

  • If the bulk write is ordered.

Since:

  • 2.1.0

API:

  • private



135
136
137
 
# File 'lib/mongo/bulk_write.rb', line 135

def ordered?
  @ordered ||= options.fetch(:ordered, true)
end

#write_concern(session = nil) ⇒ WriteConcern

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.

Get the write concern for the bulk write.

Examples:

Get the write concern.

bulk_write.write_concern

Returns:

  • The write concern.

Since:

  • 2.1.0

API:

  • private



149
150
151
152
153
 
# File 'lib/mongo/bulk_write.rb', line 149

def write_concern(session = nil)
  @write_concern ||= options[:write_concern] ?
    WriteConcern.get(options[:write_concern]) :
    collection.write_concern_with_session(session)
end