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 |