(
            self, sock_info, doc, ordered,
            check_keys, manipulate, write_concern, op_id, bypass_doc_val)
Internal helper for inserting a single document.
Internal helper for inserting a single document.
Internal helper for inserting a single document .
def _insert_one(
            self, sock_info, doc, ordered,
            check_keys, manipulate, write_concern, op_id, bypass_doc_val):
        """Internal helper for inserting a single document."""
        if manipulate:
            doc = self.__database._apply_incoming_manipulators(doc, self)
            if not isinstance(doc, RawBSONDocument) and '_id' not in doc:
                doc['_id'] = ObjectId()
            doc = self.__database._apply_incoming_copying_manipulators(doc,
                                                                       self)
        concern = (write_concern or self.write_concern).document
        acknowledged = concern.get("w") != 0
        command = SON([('insert', self.name),
                       ('ordered', ordered),
                       ('documents', [doc])])
        if concern:
            command['writeConcern'] = concern

        if sock_info.max_wire_version > 1 and acknowledged:
            if bypass_doc_val and sock_info.max_wire_version >= 4:
                command['bypassDocumentValidation'] = True
            # Insert command.
            result = sock_info.command(
                self.__database.name,
                command,
                codec_options=self.__write_response_codec_options,
                check_keys=check_keys)
            _check_write_command_response([(0, result)])
        else:
            # Legacy OP_INSERT.
            self._legacy_write(
                sock_info, 'insert', command, acknowledged, op_id,
                bypass_doc_val, message.insert, self.__full_name, [doc],
                check_keys, acknowledged, concern, False,
                self.__write_response_codec_options)
        if not isinstance(doc, RawBSONDocument):
            return doc.get('_id')
def _insert_one ( self , sock_info , doc , ordered , check_keys , manipulate , write_concern , op_id , bypass_doc_val ) : if manipulate : doc = self . __database . _apply_incoming_manipulators ( doc , self ) if not isinstance ( doc , RawBSONDocument ) and '_id' not in doc : doc [ '_id' ] = ObjectId ( ) doc = self . __database . _apply_incoming_copying_manipulators ( doc , self ) concern = ( write_concern or self . write_concern ) . document acknowledged = concern . get ( "w" ) != 0 command = SON ( [ ( 'insert' , self . name ) , ( 'ordered' , ordered ) , ( 'documents' , [ doc ] ) ] ) if concern : command [ 'writeConcern' ] = concern if sock_info . max_wire_version > 1 and acknowledged : if bypass_doc_val and sock_info . max_wire_version >= 4 : command [ 'bypassDocumentValidation' ] = True # Insert command. result = sock_info . command ( self . __database . name , command , codec_options = self . __write_response_codec_options , check_keys = check_keys ) _check_write_command_response ( [ ( 0 , result ) ] ) else : # Legacy OP_INSERT. self . _legacy_write ( sock_info , 'insert' , command , acknowledged , op_id , bypass_doc_val , message . insert , self . __full_name , [ doc ] , check_keys , acknowledged , concern , False , self . __write_response_codec_options ) if not isinstance ( doc , RawBSONDocument ) : return doc . get ( '_id' )