Python 可以使用 pymongo 庫友善的操作 MongoDB 。插播一句,MongoDB 不同于關系型結構的三層結構——database--> table --> record,它的層級為 database -->collection --> document 。這裡不重點介紹 MongoDB 用法,主要來看一下如何用 Python 使用 MongoDB。
1.安裝MongoDB和pymongo:
[[email protected] ~]# pip install pymongo
[[email protected] ~]# yum install -y mongodb-server
啟動 MongoDB ,其中 --dbpath 指定資料存放目錄,預設為 /data/db ,如果目錄不存在會報錯; --logpath 指定日志輸出檔案,日志會按照時間自動切分:
[[email protected] ~]# mongod --dbpath=/data/mongodb/db/--logpath=/data/mongodb/mongodb.log
注:如果沒有 pip 指令,需要使用 yum 進行安裝:
[[email protected] ~]# yum install -y python-pip
2.建立連接配接:
[[email protected] ~]# python
>>> import pymongo
>>> client = MongoClient()
//與以下兩種方式等同
>>> client = MongoClient(“localhost”, 27017)
>>> client = MongoClient(“mongodb://localhost:27017/”)
3.指定将要進行操作的database和collection:
>>> db = client.test_db
>>> collection = db.test_collection
4.正常操作:
4.1 插入:
>>> mydict = {“name”:”Lucy”, “sex”:”female”,”job”:”nurse”}
>>> collection.insert(mydict)
>>> collection.insert_one(mydict)
>>> collection.insert_many(mydict) //會報錯,.insert_many()時參數必須為 list 形式,做如下包裝:
>>> mylist = []
>>> mylist.append(mydict)
>>> collection.insert_many(mylist) //不會報錯
4.2 查詢:
.find_one() 顯示滿足條件的第一個 collection,find() 的結果則是一個滿足條件的對象數組:
>>> collection.find({“name”:”Lucy”})[0]
>>> collection.find({“name”:”Lucy”})[1]
……
可以使用 for-in 循環進行檢視:
>>> for i in collection.find({“name”:”Lucy”})
… print i
…
{u'job': u'nurse', u'_id': ObjectId('554bd2e1e1382306bba8ade9'),u'name': u'Lucy', u'sex': u'female'}
{u'nationality': u'US', u'age': 24, u'_id': ObjectId('554be1cce138230714d0ab0d'),u'name': u'Lucy'}
查詢指定條件的collection,可以指定一個或多個條件:
>>> collection.find_one({“name”:”Lucy”})
>>> collection.find_one({“name”:”Lucy”, “sex”:”female”})
.count() 統計結果總條數:
>>> collection.find().count() //等同于collection.count()
>>> collection.find({“name”:”Lucy”}).count()
指定大于小于等于等條件進行查詢:
>>> collection.find({“age”: {“$lt”: 30}})
這樣的查詢符号有 $lt(小于), $gt(大于), $lte(小于等于), $gte(大于等于), $ne(不等于),這與原生 MongoDB 中相同。
将查詢結果按條件排序:
>>> collection.find().sort("age") //預設,升序
>>> collection.find().sort("age", pymongo.ASCENDING) //升序
>>> collection.find().sort("age", pymongo.DESCENDING) //降序
查詢 database中所有collection :
>>> db.collection_names()
>>> db.collection_names(include_system_collections=Flase) //不包括系統collection,一般指的是system.indexes
注:這裡的 db 為建立連接配接後的db = client.test_db 。
4.3 更新:
>>> temp = collection.find_one({"name":"Lucy"})
>>> temp2 = temp.copy()
>>> temp["name"] = "Jordan"
>>> collection.save(temp) //或 .update() ,注意參數形式
>>> collection.update(temp, temp2) //将temp更新為temp2
注:如果此時temp[“_id”]在該collection中已經存在,則.save()為更新操作,與 .replace_one() 作用相同,否則 .save() 為插入操作,與 .insert_one() 作用相同。
還要注意的一點是,.replace_one()需要傳入兩個參數,分别為目前document和要更新為的 document ,與 .update() 相同(update和save的差別暫且略過,有興趣可以搜尋引擎一下):
>>> collection.replace_one(old_document, new_document)
4.4 删除:
>>> collection.remove(temp)//即便該temp不存在也不會報錯
>>> collection.delete_one(temp)
>>> collection.delete_many(temp) //與 .insert_many() 不同,在temp不是list類型時也不會報錯
補充:
1.JSON序列化與反序列化:
如果想序列化為标準 JSON 格式,兩種方式,方式一,json 包中的 dumps:
>>> import json
>>> for i in collection.find(“{“name”:”Lucy”})
… del i[“_id”] //不能直接轉換,無法識别ObjectId
… json.dumps(i)
對應的反序列化方法為json.loads()
方式二,bson.json_util包中封裝的 dumps:
>>> from bson import Binary, Code
>>> from bson.json_util import dumps
>>> dumps([{'foo': [1, 2]},
... {'bar': {'hello':'world'}},
... {'code': Code("function x() { return1; }")},
... {'bin': Binary("")}])
'[{"foo": [1, 2]}, {"bar": {"hello":"world"}}, {"code": {"$code": "function x(){ return 1; }", "$scope": {}}}, {"bin":{"$binary": "", "$type": "00"}}]'
對應的反序列化方法為bson.json_util.loads()
2.Deprecated與”Modern”:
在pymongo中,有一些方法雖然沒有被棄用,但也已經不再建議使用,使用這些方法不會出現 error ,但會報出 warning :
__main__:1:DeprecationWarning: insert is deprecated. Use insert_one or insert_manyinstead.
下面列出一些Deprecated Method 和 “Mordern” Method ,供了解(建議不要使用 Deprecated Method,因為沒準哪天就真的被棄用了):
Deprecated “Mordern”
insert insert_one insert_many
save replace_one insert_one
remove delete_one delete_many
update replace_one update_one update_many
參考資料:
http://api.mongodb.org/python/current/tutorial.html
http://api.mongodb.org/python/current/api/bson/json_util.html
本文出自 “細桶假狗屎” 部落格,請務必保留此出處http://xitongjiagoushi.blog.51cto.com/9975742/1657096