基本的 CRUD 操作

MongoDB 将数据记录存储为 BSON 文档。BSON 是 JSON 的二进制表示。

$ python
>>> from pymongo import MongoClient
>>> client = MongoClient()
>>> col = client.mydb.test

创建

插入单个文件 insert_one(document)

>>> result = col.insert_one({'x':1})
>>> result.inserted_id
ObjectId('583c16b9dc32d44b6e93cd9b')

插入多个文件 insert_many(documents)

>>> result = col.insert_many([{'x': 2}, {'x': 3}])
>>> result.inserted_ids
[ObjectId('583c17e7dc32d44b6e93cd9c'), ObjectId('583c17e7dc32d44b6e93cd9d')]

替换与过滤器 replace_one(filter, replacement, upsert=False) 匹配的单个文档。 （如果匹配的文档不存在，则插入新文档，使用 upsert=True）

>>> result = col.replace_one({'x': 1}, {'y': 1})
>>> result.matched_count
1
>>> result.modified_count
1

更新

更新与过滤器 update_one(filter, update, upsert=False) 匹配的单个文档

>>> result = col.update_one({'x': 1}, {'x': 3})

更新与过滤器 update_many(filter, update, upsert=False) 匹配的一个或多个文档

>>> result = col.update_many({'x': 1}, {'x': 3})

读

查询数据库 find(filter=None, projection=None, skip=0, limit=0, no_cursor_timeout=False)。该滤波器参数是一个原型的文件，所有的结果必须匹配。

>>> result = col.find({'x': 1})

从数据库 find_one(filter=None) 获取单个文档

>>> result = col.find_one()

使用投影查询

query={'x':1}
projection={'_id':0, 'x':1} # show x but not show _id
result=col.find(query,projection)

删除

删除与过滤器 delete_one(filter) 匹配的单个文档

>>> result = col.delete_one({'x': 1})
>>> result.deleted_count
1

删除与过滤器 delete_many(filter) 匹配的一个或多个文档

>>> result = col.delete_many({'x': 1})
>>> result.deleted_count
3

PyMongo 还提供 find_one_and_delete()，find_one_and_update() 和 find_one_and_replace() 功能。