首頁 > 軟體

Python操作MongoDB的教學詳解(插,查,改,排,刪)

2022-09-30 14:01:12

MongoDB 是一個基於分散式檔案儲存的資料庫。是一個介於關聯式資料庫和非關聯式資料庫之間的產品,是非關聯式資料庫當中功能最豐富,最像關聯式資料庫的。

MongoDB 是目前最流行的 NoSQL 資料庫之一,使用的資料型別 BSON(類似 JSON)。

首先需要安裝MongoDB,安裝過程就不詳細贅述了

然後Python 要連線 MongoDB 需要 MongoDB 驅動,用pip安裝

pip install pymongo

插入檔案

MongoDB 中的一個檔案類似 SQL 表中的一條記錄。

插入集合

集合中插入檔案使用 insert_one() 方法,該方法的第一引數是字典 name => value 對。

例:向 sites 集合中插入檔案

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
mydict = { "name": "NOWCODER", "alexa": "10000", "url": "https://www.nowcoder.com" }
 
x = mycol.insert_one(mydict) 
print(x)
print(x)

結果如下:

<pymongo.results.InsertOneResult object at 0x10a34b288>

返回 _id 欄位

insert_one() 方法返回 InsertOneResult 物件,該物件包含 inserted_id 屬性,它是插入檔案的 id 值。

import pymongo
 
myclient = pymongo.MongoClient('mongodb://localhost:27017/')
mydb = myclient['nowcoderdb']
mycol = mydb["sites"]
 
mydict = { "name": "Google", "alexa": "1", "url": "https://www.google.com" }
 
x = mycol.insert_one(mydict)
print(x.inserted_id)

結果如下: 

5b2369cac315325f3698a1cf

插入多個檔案

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

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
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('5b236aa9c315325f5236bbb6'), ObjectId('5b236aa9c315325f5236bbb7'), ObjectId('5b236aa9c315325f5236bbb8'), ObjectId('5b236aa9c315325f5236bbb9'), ObjectId('5b236aa9c315325f5236bbba')]

插入指定 _id 的多個檔案

我們也可以自己指定 id,插入,以下範例我們在 site2 集合中插入資料,_id 為我們指定的:

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["site2"]
 
mylist = [
  { "_id": 1, "name": "NOWCODER", "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]

查詢檔案

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

查詢一條資料

我們可以使用 find_one() 方法來查詢集合中的一條資料。

例:查詢 sites 檔案中的第一條資料

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
x = mycol.find_one()
print(x)

結果如下:

{'_id': ObjectId('5b23696ac315325f269f28d1'), 'name': 'NOWCODER', 'alexa': '10000', 'url': 'https://www.nowcoder.com'}

查詢集合中所有資料

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

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
for x in mycol.find():
    print(x)
{'_id': ObjectId('5b23696ac315325f269f28d1'), 'name': 'NOWCODER', 'alexa': '10000', 'url': 'https://www.nowcoder.com'}
{'_id': ObjectId('5b2369cac315325f3698a1cf'), 'name': 'Google', 'alexa': '1', 'url': 'https://www.google.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb6'), 'name': 'Taobao', 'alexa': '100', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb7'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb8'), 'name': 'Facebook', 'alexa': '10', 'url': 'https://www.facebook.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb9'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbba'), 'name': 'Github', 'alexa': '109', 'url': 'https://www.github.com'}

查詢指定欄位的資料

我們可以使用 find() 方法來查詢指定欄位的資料,將要返回的欄位對應值設定為 1。

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
for x in mycol.find({},{ "_id": 0, "name": 1, "alexa": 1 }):
    print(x)

結果如下:

{'name': 'NOWCODER', 'alexa': '10000'}
{'name': 'Google', 'alexa': '1'}
{'name': 'Taobao', 'alexa': '100'}
{'name': 'QQ', 'alexa': '101'}
{'name': 'Facebook', 'alexa': '10'}
{'name': '知乎', 'alexa': '103'}
{'name': 'Github', 'alexa': '109'}

根據指定條件查詢

我們可以在 find() 中設定引數來過濾資料。

例:查詢 name 欄位為 "NOWCODER" 的資料

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myquery = { "name": "NOWCODER" }
mydoc = mycol.find(myquery)
for x in mydoc:
    print(x)

結果如下:

{'_id': ObjectId('5b23696ac315325f269f28d1'), 'name': 'NOWCODER', 'alexa': '10000', 'url': 'https://www.nowcoder.com'}

高階查詢

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

以下範例用於讀取 name 欄位中第一個字母 ASCII 值大於 "H" 的資料,大於的修飾符條件為 {"$gt": "H"} :

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myquery = { "name": { "$gt": "H" } }
mydoc = mycol.find(myquery)
for x in mydoc:
    print(x)

結果如下:

{'_id': ObjectId('5b23696ac315325f269f28d1'), 'name': 'NOWCODER', 'alexa': '10000', 'url': 'https://www.nowcoder.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb6'), 'name': 'Taobao', 'alexa': '100', 'url': 'https://www.taobao.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb7'), 'name': 'QQ', 'alexa': '101', 'url': 'https://www.qq.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb9'), 'name': '知乎', 'alexa': '103', 'url': 'https://www.zhihu.com'}

返回指定條數記錄

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

例:返回 3 條檔案記錄

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myresult = mycol.find().limit(3)
 
# 輸出結果
for x in myresult:
    print(x)

結果只有三條了: 

{'_id': ObjectId('5b23696ac315325f269f28d1'), 'name': 'NOWCODER', 'alexa': '10000', 'url': 'https://www.nowcoder.com'}
{'_id': ObjectId('5b2369cac315325f3698a1cf'), 'name': 'Google', 'alexa': '1', 'url': 'https://www.google.com'}
{'_id': ObjectId('5b236aa9c315325f5236bbb6'), 'name': 'Taobao', 'alexa': '100', 'url': 'https://www.taobao.com'}

修改檔案

我們可以在 MongoDB 中使用 update_one() 方法修改檔案中的記錄。該方法第一個引數為查詢的條件,第二個引數為要修改的欄位。如果查詢到的匹配資料多餘一條,則只會修改第一條。

例:將 alexa 欄位的值 10000 改為 12345

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myquery = { "alexa": "10000" }
newvalues = { "$set": { "alexa": "12345" } }
 
mycol.update_one(myquery, newvalues)
 
# 輸出修改後的  "sites"  集合
for x in mycol.find():
    print(x)

update_one() 方法只能修匹配到的第一條記錄,如果要修改所有匹配到的記錄,可以使用 update_many()。

以下範例將查詢所有以 F 開頭的 name 欄位,並將匹配到所有記錄的 alexa 欄位修改為 123:

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myquery = { "name": { "$regex": "^F" } }
newvalues = { "$set": { "alexa": "123" } }
 
x = mycol.update_many(myquery, newvalues)
print(x.modified_count, "檔案已修改")

排序

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

sort() 方法第一個引數為要排序的欄位,第二個欄位指定排序規則,1 為升序,-1 為降序,預設為升序。

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
mydoc = mycol.find().sort("alexa")
for x in mydoc:
    print(x)

以上程式碼實現了對欄位 alexa 按升序排序。

刪除資料

我們可以使用 delete_one() 方法來刪除一個檔案,該方法第一個引數為查詢物件,指定要刪除哪些資料。

例:刪除 name 欄位值為 "Taobao" 的檔案

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myquery = { "name": "Taobao" }
 
mycol.delete_one(myquery)
# 刪除後輸出
for x in mycol.find():
    print(x)

刪除多個檔案

我們可以使用 delete_many() 方法來刪除多個檔案,該方法第一個引數為查詢物件,指定要刪除哪些資料。

例:刪除所有 name 欄位中以 F 開頭的檔案

import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
myquery = { "name": {"$regex": "^F"} }
 
x = mycol.delete_many(myquery)
print(x.deleted_count, "個檔案已刪除")

結果如下:

1 個檔案已刪除

刪除集合中的所有檔案

delete_many() 方法如果傳入的是一個空的查詢物件,則會刪除集合中的所有檔案:

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
x = mycol.delete_many({})
print(x.deleted_count, "個檔案已刪除")

結果如下:

5 個檔案已刪除

刪除集合

我們可以使用 drop() 方法來刪除一個集合。

以下範例刪除了 customers 集合:

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["nowcoderdb"]
mycol = mydb["sites"]
 
mycol.drop()

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

到此這篇關於Python操作MongoDB的教學詳解(插,查,改,排,刪)的文章就介紹到這了,更多相關Python操作MongoDB內容請搜尋it145.com以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援it145.com!


IT145.com E-mail:sddin#qq.com