|
OpenQuizz
Une application de gestion des contenus pédagogiques
|


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 | |
The private guts of the bulk write API.
| def __init__ | ( | self, | |
| collection, | |||
| ordered, | |||
| bypass_document_validation | |||
| ) |
Initialize a _Bulk instance.
| def add_delete | ( | self, | |
| selector, | |||
| limit, | |||
collation = None, |
|||
hint = None |
|||
| ) |
Create a delete document and add it to the list of ops.
| def add_insert | ( | self, | |
| document | |||
| ) |
Add an insert document to the list of ops.
| def add_replace | ( | self, | |
| selector, | |||
| replacement, | |||
upsert = False, |
|||
collation = None, |
|||
hint = None |
|||
| ) |
Create a replace document and add it to the list of ops.
| 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.
| def bulk_ctx_class | ( | self | ) |
| def execute | ( | self, | |
| write_concern, | |||
| session | |||
| ) |
Execute operations.
| def execute_command | ( | self, | |
| generator, | |||
| write_concern, | |||
| session | |||
| ) |
Execute using write commands.
| def execute_command_no_results | ( | self, | |
| sock_info, | |||
| generator | |||
| ) |
Execute write commands with OP_MSG and w=0 WriteConcern, ordered.
| def execute_insert_no_results | ( | self, | |
| sock_info, | |||
| run, | |||
| op_id, | |||
| acknowledged | |||
| ) |
Execute insert, returning no results.
| def execute_no_results | ( | self, | |
| sock_info, | |||
| generator | |||
| ) |
Execute all operations, returning no results (w=0).
| def execute_op_msg_no_results | ( | self, | |
| sock_info, | |||
| generator | |||
| ) |
Execute write commands with OP_MSG and w=0 writeConcern, unordered.
| def gen_ordered | ( | self | ) |
Generate batches of operations, batched by type of operation, in the order **provided**.
| def gen_unordered | ( | self | ) |
Generate batches of operations, batched by type of operation, in arbitrary order.
| bypass_doc_val |
| collection |
| current_run |
| executed |
| is_retryable |
| ops |
| ordered |
| retrying |
| started_retryable_write |
| uses_array_filters |
| uses_collation |
| uses_hint |