python操作MongoDB數據庫

上一篇文章中介紹了怎麼用python連接MongoDB數據庫,現在寫一下python控制MongoDB進行增刪改查操作。

首先連接數據庫:

import  pymongo
# 連接數據庫
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydb"]
mycol = mydb["col"]

Python MongoDB增加數據

插入一條記錄:

x=mycol.insert_one({"name":"劉飛","age":19})
print(x)

輸出結果:

<pymongo.results.InsertOneResult object at 0x02A45620>

insert_one() 方法返回 InsertOneResult 對象,可使用下面方法查看對象所有的屬性:

x=mycol.insert_one({"name":"劉飛","age":19})
print(dir(x))
#輸出結果 [
'_InsertOneResult__acknowledged', '_InsertOneResult__inserted_id', '_WriteResult__acknowledged', '__class__', '__delattr__', '__dir__', '__doc__', '__eq__', '__format__', '__ge__', '__getattribute__', '__gt__', '__hash__', '__init__', '__init_subclass__', '__le__', '__lt__', '__module__', '__ne__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__slots__', '__str__', '__subclasshook__', '_raise_if_unacknowledged', 'acknowledged', 'inserted_id']

該對象包含 inserted_id 屬性,它是插入文檔的 id 值。如果我們在插入文檔時沒有指定 _id,MongoDB 會為每個文檔添加一個唯一的 id

x=mycol.insert_one({"name":"劉飛","age":19})
print(x.inserted_id)
#輸出結果 5d43d8189f5e382760e25acf

插入多個文檔:

集合中插入多個文檔使用 insert_many() 方法,該方法的第一參數是字典列表。

mylist = [
  { "name": "Taobao", "alexa": "100", "url": "https://www.taobao.com" },
  { "name": "QQ", "alexa": "101", "url": "https://www.qq.com" },
  { "name": "Facebook", "alexa": "10", "url": "https://www.facebook.com" },
  { "name": "知乎", "alexa": "103", "url": "https://www.zhihu.com" },
  { "name": "Github", "alexa": "109", "url": "https://www.github.com" }
]
x = mycol.insert_many(mylist)
 
# 輸出插入的所有文檔對應的 _id 值
print(x.inserted_ids)

#輸出結果
[ObjectId('5d43d9069f5e38272c69fc07'), ObjectId('5d43d9069f5e38272c69fc08'), ObjectId('5d43d9069f5e38272c69fc09'), ObjectId('5d43d9069f5e38272c69fc0a'), ObjectId('5d43d9069f5e38272c69fc0b')]

insert_many() 方法返回 InsertManyResult 對象,該對象包含 inserted_ids 屬性,該屬性保存着所有插入文檔的 id 值。

執行完以上查找,我們可以在命令終端,查看數據是否已插入:

《python操作MongoDB數據庫》

插入指定id的多個文檔:

#先刪除之前插入的所有文檔
x=mycol.delete_many({})
print(x.deleted_count, "個文檔已刪除")
#輸出結果 11 個文檔已刪除
mylist = [
    {"_id": 1, "name": "RUNOOB", "cn_name": "菜鳥教程"},
    {"_id": 2, "name": "Google", "address": "Google 搜索"},
    {"_id": 3, "name": "Facebook", "address": "臉書"},
    {"_id": 4, "name": "Taobao", "address": "淘寶"},
    {"_id": 5, "name": "Zhihu", "address": "知乎"}
]

x = mycol.insert_many(mylist)

# 輸出插入的所有文檔對應的 _id 值
print(x.inserted_ids)

#輸出結果
[1, 2, 3, 4, 5]

執行完以上查找,我們可以在命令終端,查看數據是否已插入:

《python操作MongoDB數據庫》

 

 Python MongoDB 刪除數據

 刪除單個文檔:

我們可以使用 delete_one() 方法來刪除一個文檔,該方法第一個參數為查詢對象,指定要刪除哪些數據。

本文使用的測試數據如下:

 《python操作MongoDB數據庫》

x=mycol.delete_one({"name":"Google"})
print(x.deleted_count,'個文檔已刪除')

#輸出結果
1 個文檔已刪除

刪除多個文檔:

我們可以使用 delete_many() 方法來刪除多個文檔,該方法第一個參數為查詢對象,指定要刪除哪些數據。

刪除所有 name 字段中以 F 開頭的文檔:

myquery = {"name": {"$regex": "^F"}}
x = mycol.delete_many(myquery)
print(x.deleted_count, "個文檔已刪除")

#輸出結果
2 個文檔已刪除

刪除集合中所有的文檔:

x = mycol.delete_many({})
print(x.deleted_count, "個文檔已刪除")

#輸出結果
7 個文檔已刪除

刪除集合:

mycol.drop()

如果刪除成功 drop() 返回 true,如果刪除失敗(集合不存在)則返回 false。

我們使用以下命令在終端查看集合是否已刪除:

《python操作MongoDB數據庫》

Python MongoDB 修改文檔

修改一條記錄

在 MongoDB 中使用 update_one() 方法修改文檔中的記錄。該方法第一個參數為查詢的條件,第二個參數為要修改的字段。如果查找到的匹配數據多餘一條,則只會修改第一條。

 本文使用的測試數據如下

《python操作MongoDB數據庫》

將 alexa 字段的值 10000 改為 12345:

mycol.update_one({"alexa":'100'},{'$set':{"alexa":"123456"}})
for i in mycol.find():
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcf'), 'name': 'Facebook', 'alexa': '10', 'url': 'https://www.facebook.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd0'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd1'), 'name': 'Github', 'alexa': '109', 'url': 'https://www.github.com'}

修改多條記錄

使用 update_many()。查找所有以 F 開頭的 name 字段,並將匹配到所有記錄的 alexa 字段修改為 123

x=mycol.update_many({"name":{"$regex":"^F"}},{"$set":{"alexa":"123"}})
print(x.modified_count,'個文檔已修改')

#輸出結果
1 個文檔已修改

Python MongoDB 查詢文檔

MongoDB 中使用了 find 和 find_one 方法來查詢集合中的數據,它類似於 SQL 中的 SELECT 語句。

本文使用的測試數據如下

《python操作MongoDB數據庫》

使用 find_one() 方法來查詢集合中的一條數據。

x = mycol.find_one()
print(x)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}

find() 方法可以查詢集合中的所有數據,類似 SQL 中的 SELECT * 操作。

for i in mycol.find():
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcf'), 'name': 'Facebook', 'alexa': '123', 'url': 'https://www.facebook.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd0'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd1'), 'name': 'Github', 'alexa': '109', 'url': 'https://www.github.com'}

查詢指定字段的數據

我們可以使用 find() 方法來查詢指定字段的數據,將要返回的字段對應值設置為 1。

for i in mycol.find({},{"_id":0,"name":1,"url":1}):
    print(i)

#輸出結果
{'name': 'Taobao', 'url': 'https://www.taobao.com'}
{'name': 'QQ', 'url': 'https://www.qq.com'}
{'name': 'Facebook', 'url': 'https://www.facebook.com'}
{'name': '知乎', 'url': 'https://www.zhihu.com'}
{'name': 'Github', 'url': 'https://www.github.com'}

除了 _id 你不能在一個對象中同時指定 0 和 1,如果你設置了一個字段為 0,則其他都為 1,反之亦然。

以下實例除了 alexa 字段外,其他都返回:

for i in mycol.find({},{"alexa":0}):
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcf'), 'name': 'Facebook', 'url': 'https://www.facebook.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd0'), 'name': '知乎', 'url': 'https://www.zhihu.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd1'), 'name': 'Github', 'url': 'https://www.github.com'}

以下代碼同時指定了 0 和 1 則會報錯

for i in mycol.find({},{"alexa":0,"name":1}):
    print(i)

#報錯信息
pymongo.errors.OperationFailure: Projection cannot have a mix of inclusion and exclusion.

根據指定條件查詢

在 find() 中設置參數來過濾數據。查找 name 字段為 “QQ” 的數據:

mydoc = mycol.find({"name":"QQ"})
for i in mydoc:
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}

高級查詢

查詢的條件語句中,我們還可以使用修飾符。

讀取 name 字段中第一個字母 ASCII 值大於 “H” 的數據,大於的修飾符條件為 {“$gt”: “H”} :

mydoc = mycol.find({"name":{"$gt":"H"}})
for i in mydoc:
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd0'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}

使用正則表達式查詢

正則表達式修飾符只用於搜索字符串的字段。

讀取 name 字段中第一個字母為 “T” 的數據,正則表達式修飾符條件為 {“$regex”: “^T”} :

mydoc = mycol.find({"name":{"$regex":"^T"}})
for i in mydoc:
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}

返回指定條數記錄

如果我們要對查詢結果設置指定條數的記錄可以使用 limit() 方法,該方法只接受一個数字參數。

mydoc = mycol.find().limit(3)
for i in mydoc:
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcf'), 'name': 'Facebook', 'alexa': '123', 'url': 'https://www.facebook.com'}

排序

sort() 方法可以指定升序或降序排序。

sort() 方法第一個參數為要排序的字段,第二個字段指定排序規則,1 為升序,-1 為降序,默認為升序。

對字段 alexa 按升序排序:

mydoc = mycol.find().sort('alexa')
for i in mydoc:
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd0'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd1'), 'name': 'Github', 'alexa': '109', 'url': 'https://www.github.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcf'), 'name': 'Facebook', 'alexa': '123', 'url': 'https://www.facebook.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}

對字段 alexa 按降序排序:

mydoc = mycol.find().sort('alexa',-1)
for i in mydoc:
    print(i)

#輸出結果
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcd'), 'name': 'Taobao', 'alexa': '123456', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bcf'), 'name': 'Facebook', 'alexa': '123', 'url': 'https://www.facebook.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd1'), 'name': 'Github', 'alexa': '109', 'url': 'https://www.github.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bd0'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}
{'_id': ObjectId('5d43e5ff9f5e381df4a69bce'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}

 

done

參考資料:https://www.runoob.com/python3/python-mongodb.html

点赞

發佈留言

發佈留言必須填寫的電子郵件地址不會公開。 必填欄位標示為 *