fix BulkWriter.__init__ bug when it has object_class param input

[hagd0520]

fix bug occur to two scenarios

• Initialize BulkWriter directly by BulkWriter.init with object_class parm input.
• Initialize BulkWriter through Document.bulk_writer and Document has collection.

[CAPITAINMARVEL]

fix bug occur to two scenarios

• Initialize BulkWriter directly by BulkWriter.init with object_class parm input.
• Initialize BulkWriter through Document.bulk_writer and Document has collection.

the collection name is only used when add_operation is called and doesnt alter anything as long object_class is not none when you commit

[hagd0520]

fix bug occur to two scenarios

• Initialize BulkWriter directly by BulkWriter.init with object_class parm input.
• Initialize BulkWriter through Document.bulk_writer and Document has collection.

the collection name is only used when add_operation is called and doesnt alter anything as long object_class is not none when you commit

bug appears from the add_operation func.

    def add_operation(
        self,
        object_class: Type[Union[Document, UnionDoc]],
        operation: _WriteOp,
    ):
        if self.object_class is None:
            self.object_class = object_class
            self._collection_name = object_class.get_collection_name()
        else:
            if object_class.get_collection_name() != self._collection_name:
                raise ValueError(
                    "All the operations should be for a same collection name"
                )
        self.operations.append(operation)

under the scenarios i mentioned, initialized BulkWriter has no _collections_name and it raise the ValueError from the line 154 in bulk.py cause its object_class is not None and _collections_name is None.

so that _collections_name should be properly intialized.

[CAPITAINMARVEL]

fix bug occur to two scenarios

• Initialize BulkWriter directly by BulkWriter.init with object_class parm input.
• Initialize BulkWriter through Document.bulk_writer and Document has collection.

the collection name is only used when add_operation is called and doesnt alter anything as long object_class is not none when you commit

bug appears from the add_operation func.

    def add_operation(
        self,
        object_class: Type[Union[Document, UnionDoc]],
        operation: _WriteOp,
    ):
        if self.object_class is None:
            self.object_class = object_class
            self._collection_name = object_class.get_collection_name()
        else:
            if object_class.get_collection_name() != self._collection_name:
                raise ValueError(
                    "All the operations should be for a same collection name"
                )
        self.operations.append(operation)

under the scenarios i mentioned, initialized BulkWriter has no _collections_name and it raise the ValueError from the line 154 in bulk.py cause its object_class is not None and _collections_name is None.

so that _collections_name should be properly intialized.

oh I see what you means now

[CAPITAINMARVEL]

lgtm