pip install pymongo

# coding=utf-8
import random
import pymongo
client = pymongo.MongoClient('mongodb://localhost:27017/')
client.drop_database('test') # 保證之前沒(méi)有數(shù)據(jù)， 刪除名為test的數(shù)據(jù)庫(kù)
db = client.test # 使用test這個(gè)數(shù)據(jù)庫(kù)
coll = db.coll # 使用coll這個(gè)集合
# 插入單條
rs = coll.insert_one({'a': 1, 'b': 2})
object_id = rs.inserted_id
print rs.inserted_id # 打印插入的對(duì)象id
# 插入多條
rs = coll.insert_many([{'a': random.randint(1, 10), 'b': 10}
            for _ in range(10)])
print rs.inserted_ids # 打印插入的對(duì)象id列表
# 查詢單條（符合的第一條）
print coll.find_one({'a': 1, 'b': 2})
# 集合當(dāng)前全部文檔數(shù)
print coll.count()
cursor = coll.find({'a': {'$lte': 1}}) # 查詢結(jié)果是一個(gè)游標(biāo)
print cursor.count() # 符合查詢的文檔數(shù)
for r in cursor:
  print r, r['b'] # 打印符合查詢的文檔內(nèi)容， 以及其中b鍵的值
# 注意， 這個(gè)循環(huán)只能進(jìn)行一次. 如果想再獲得需要重新find或者使用list(cursor)把結(jié)果存起來(lái)
# 對(duì)查詢結(jié)果排序
print list(coll.find({'a': {'$lte': 1}}).sort([('b', -1)]))
# -1也可以表示為pymongo.DESCENDING
# 對(duì)查詢結(jié)果可以限制返回文檔數(shù)， 控制跳過(guò)的結(jié)果數(shù)
print coll.find({'b': {'$gt': 1}}).limit(1).skip(1).next() # next相當(dāng)于find_one
# 找到后更新， 下面例子第一個(gè)參數(shù)是過(guò)濾條件， 第二個(gè)參數(shù)是要更新的操作（設(shè)置b為3， a自增長(zhǎng)1）
# upsert為True表示找不到會(huì)創(chuàng)建一個(gè),也就是get_or_create
rs = coll.find_one_and_update({'a': 1, 'b': 2},
               {'$set': {'b': 3}, '$inc': {'a': 1}},
               upsert=False)
print rs # 返回更新前的文檔
# 同樣的還有find_one_and_replace和find_one_and_delete
print list(coll.find({'a': 2, 'b': 3})) # 上述文檔已經(jīng)被更新為這個(gè)文檔
coll.find_one_and_update({'a': 1, 'b': 2},
             {'$set': {'b': 3}, '$inc': {'a': 1}},
             upsert=True) # 雖然沒(méi)有符合{'a': 1, 'b': 2}的記錄，但是會(huì)新建一個(gè)
print coll.find({'a': 2, 'b': 3}).count() # 發(fā)現(xiàn)現(xiàn)在有2條文檔記錄了
# 刪除單個(gè)文檔
coll.delete_one({'a': 2, 'b': 3})
# 一次性刪除多個(gè)文檔
rs = coll.delete_many({'a': 2, 'b': 3})
# 如果沒(méi)有符合的條目也不會(huì)提示， 但是可以通過(guò)rs.deleted_count獲得刪除的數(shù)量
print rs.deleted_count