OpenQuizz
Une application de gestion des contenus pédagogiques
_Bulk Class Reference
Inheritance diagram for _Bulk:
Collaboration diagram for _Bulk:

Public Member Functions

def __init__ (self, collection, ordered, bypass_document_validation)
 
def bulk_ctx_class (self)
 
def add_insert (self, document)
 
def add_update (self, selector, update, multi=False, upsert=False, collation=None, array_filters=None, hint=None)
 
def add_replace (self, selector, replacement, upsert=False, collation=None, hint=None)
 
def add_delete (self, selector, limit, collation=None, hint=None)
 
def gen_ordered (self)
 
def gen_unordered (self)
 
def execute_command (self, generator, write_concern, session)
 
def execute_insert_no_results (self, sock_info, run, op_id, acknowledged)
 
def execute_op_msg_no_results (self, sock_info, generator)
 
def execute_command_no_results (self, sock_info, generator)
 
def execute_no_results (self, sock_info, generator)
 
def execute (self, write_concern, session)
 

Data Fields

 collection
 
 ordered
 
 ops
 
 executed
 
 bypass_doc_val
 
 uses_collation
 
 uses_array_filters
 
 uses_hint
 
 is_retryable
 
 retrying
 
 started_retryable_write
 
 current_run
 

Detailed Description

The private guts of the bulk write API.

Constructor & Destructor Documentation

◆ __init__()

def __init__ (   self,
  collection,
  ordered,
  bypass_document_validation 
)
Initialize a _Bulk instance.

Member Function Documentation

◆ add_delete()

def add_delete (   self,
  selector,
  limit,
  collation = None,
  hint = None 
)
Create a delete document and add it to the list of ops.

◆ add_insert()

def add_insert (   self,
  document 
)
Add an insert document to the list of ops.

◆ add_replace()

def add_replace (   self,
  selector,
  replacement,
  upsert = False,
  collation = None,
  hint = None 
)
Create a replace document and add it to the list of ops.

◆ add_update()

def add_update (   self,
  selector,
  update,
  multi = False,
  upsert = False,
  collation = None,
  array_filters = None,
  hint = None 
)
Create an update document and add it to the list of ops.

◆ bulk_ctx_class()

def bulk_ctx_class (   self)

◆ execute()

def execute (   self,
  write_concern,
  session 
)
Execute operations.

◆ execute_command()

def execute_command (   self,
  generator,
  write_concern,
  session 
)
Execute using write commands.

◆ execute_command_no_results()

def execute_command_no_results (   self,
  sock_info,
  generator 
)
Execute write commands with OP_MSG and w=0 WriteConcern, ordered.

◆ execute_insert_no_results()

def execute_insert_no_results (   self,
  sock_info,
  run,
  op_id,
  acknowledged 
)
Execute insert, returning no results.

◆ execute_no_results()

def execute_no_results (   self,
  sock_info,
  generator 
)
Execute all operations, returning no results (w=0).

◆ execute_op_msg_no_results()

def execute_op_msg_no_results (   self,
  sock_info,
  generator 
)
Execute write commands with OP_MSG and w=0 writeConcern, unordered.

◆ gen_ordered()

def gen_ordered (   self)
Generate batches of operations, batched by type of
operation, in the order **provided**.

◆ gen_unordered()

def gen_unordered (   self)
Generate batches of operations, batched by type of
operation, in arbitrary order.

Field Documentation

◆ bypass_doc_val

bypass_doc_val

◆ collection

collection

◆ current_run

current_run

◆ executed

executed

◆ is_retryable

is_retryable

◆ ops

ops

◆ ordered

ordered

◆ retrying

retrying

◆ started_retryable_write

started_retryable_write

◆ uses_array_filters

uses_array_filters

◆ uses_collation

uses_collation

◆ uses_hint

uses_hint

The documentation for this class was generated from the following file: