ipazc / pymdict Goto Github PK

class BulkMongoDict(MongoDict):
    ...
    def __setitem__(self, key, value):
        self._on_modified_callback()
        self._operations.append(
            UpdateOne({"key": key}, {"$set": {"value": value}}, upsert=True)
        )

        if len(self._operations) > self._buffer_size:
            self.commit()

    def __delitem__(self, key):
        self._on_modified_callback()
        self._operations.append(
            DeleteOne({"key": key})
        )

        if len(self._operations) > self._buffer_size:
            self.commit()

>>> a = MongoDict("a")
>>> a["foo"] = "bar"
>>> sleep(4)
>>> a["foo"] = "fa"

>>> a = MongoDict("a")
>>> sleep(2)
>>> b = a.fork("b")  # It is supposed that b["foo"] == "bar" in the fork
>>> sleep(5)
>>> print(b["foo"])
fa

m = MongoDict("example")
query_elements = m('value % example')

m = MongoDict("example")
query_count = m('value % example', count_only=True)