Support for custom commands about txmongo HOT 5 CLOSED

#!/usr/bin/env python
# coding: utf-8

import txmongo
from twisted.internet import defer, reactor

from txmongo._pymongo.son import SON

@defer.inlineCallbacks
def example():
    mongo = yield txmongo.MongoConnection()

    test = mongo.test       # `test` database
    things = test.things    # `things` collection

    # insert new document
    yield things.insert({"foo":"bar", "name":"bar_name"}, safe=True)

    # find_and_modify
    # @see: http://www.mongodb.org/display/DOCS/findAndModify+Command
    spec = SON([
        ("findAndModify", "things"),
        ("query", {"foo":"bar"}),
        ("update", {"$set": {"name": "changed_name"}}),
        ("new", True)])

    result = yield things._database["$cmd"].find_one(spec)
    print result

if __name__ == '__main__':
    example().addCallback(lambda ign: reactor.stop())
    reactor.run()