py操作mongodb總結

python使用的版本

python3.7

python操作mongodb使用的是pymongo，安裝方法：

pip install pymongo

測試 PyMongo

接下來我們可以創建一個測試文件 demo_test_mongodb.py，代碼如下：

 

import pymongo

執行以上代碼文件，如果沒有出現錯誤，表示安裝成功。

創建數據庫

創建一個數據庫

創建數據庫需要使用 MongoClient 對象，並且指定連接的 URL 地址和要創建的數據庫名。

如下實例中，我們創建的數據庫 runoobdb :

 

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]

注意: 在 MongoDB 中，數據庫只有在內容插入后才會創建! 就是說，數據庫創建后要創建集合(數據表)並插入一個文檔(記錄)，數據庫才會真正創建。

判斷數據庫是否已存在

我們可以讀取 MongoDB 中的所有數據庫，並判斷指定的數據庫是否存在：

import pymongo
 
myclient = pymongo.MongoClient('mongodb://localhost:27017/')
 
dblist = myclient.list_database_names()
# dblist = myclient.database_names() 
if "runoobdb" in dblist:
  print("數據庫已存在！")

創建集合

MongoDB 中的集合類似 SQL 的表。

創建一個集合

MongoDB 使用數據庫對象來創建集合，實例如下：

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

判斷集合是否已存在

我們可以讀取 MongoDB 數據庫中的所有集合，並判斷指定的集合是否存在：

import pymongo
 
myclient = pymongo.MongoClient('mongodb://localhost:27017/')
 
mydb = myclient['runoobdb']
 
collist = mydb. list_collection_names()
# collist = mydb.collection_names()
if "sites" in collist:   # 判斷 sites 集合是否存在
  print("集合已存在！")

Python Mongodb 插入文檔 

插入集合

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

以下實例向 sites 集合中插入文檔：

import pymongo

client = pymongo.MongoClient("mongodb://127.0.0.1:27017")

db = client["runoobdb"]
col = db["site2"]

# 插入一條記錄

student = {"name":"王小波","gender":"male","age":"30","love":"寫書","socre":"99"}
x = col.insert_one(student)
print(x)                # 返回的是InsertOneResult 對象
print(x.inserted_id) # 返回的是_id字段的值

插入多個文檔

集合中插入多個文檔使用 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 = col.insert_many(mylist)
print(x.inserted_ids) 
"""
輸出結果
[
  ObjectId('5b236aa9c315325f5236bbb6'),
  ObjectId('5b236aa9c315325f5236bbb7'),
  ObjectId('5b236aa9c315325f5236bbb8'),
  ObjectId('5b236aa9c315325f5236bbb9'), 
  ObjectId('5b236aa9c315325f5236bbba')
]
"""

插入指定 _id 的多個文檔

我們也可以自己指定 id，插入，以下實例我們在 site2 集合中插入數據，_id 為我們指定的：

# 插入指定_id的多個文檔
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 = col.insert_many(mylist)
# 輸出結果：[1, 2, 3, 4, 5]
print(x.inserted_ids)

Python Mongodb 查詢文檔

查詢一條數據

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

查詢 sites 文檔中的第一條數據：

import pymongo

client = pymongo.MongoClient("mongodb://127.0.0.1:27017")

db = client["runoobdb"]
col = db["site2"]

# 查詢集合中的一條數據
x = col.find_one() 
print(x) # pymongo.cursor.Cursor 對象

查詢集合中所有數據

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

以下實例查找 sites 集合中的所有數據：

# 查詢集合中的所有數據
for x in col.find():
    print(x)  
結果:
    {'_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': '知乎'}

查詢指定字段的數據

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

for x in col.find({},{"_id":0,"name":1,"address":1}):
    print(x)
{'name': 'Google', 'address': 'Google 搜索'}
{'name': 'Facebook', 'address': '臉書'}
{'name': 'Taobao', 'address': '淘寶'}
{'name': 'Zhihu', 'address': '知乎'}

根據指定條件查詢

我們可以在 find() 中設置參數來過濾數據。

以下實例查找 name 字段為 "Google" 的數據：

myquery = {"name":"Google"}
mydoc = col.find(myquery)
for x in mydoc:
    print(x) # {'_id': 2, 'name': 'Google', 'address': 'Google 搜索'}

高級查詢

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

以下實例用於讀取 name 字段中第一個字母 ASCII 值大於 "H" 的數據，大於的修飾符條件為 {"$gt": "H"} :

# 讀取 name 字段中第一個字母 ASCII 值大於 "H" 的數據
myquery = {"name":{"$gt":"H"}}
mydoc = col.find(myquery)
for x in mydoc:
    print(x)

使用正則表達式查詢

我們還可以使用正則表達式作為修飾符。

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

以下實例用於讀取 name 字段中第一個字母為 "R" 的數據，正則表達式修飾符條件為 {"$regex": "^R"} :

myquery = { "name": { "$regex": "^R" } }
mydoc = col.find(myquery)
for x in mydoc:
    print(x) # {'_id': 1, 'name': 'RUNOOB', 'cn_name': '菜鳥教程'}

返回指定條數記錄

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

以下實例返回 3 條文檔記錄：

myresult = col.find().limit(3)
for x in myresult:
    print(x)

{'_id': 1, 'name': 'RUNOOB', 'cn_name': '菜鳥教程'}
{'_id': 2, 'name': 'Google', 'address': 'Google 搜索'}
{'_id': 3, 'name': 'Facebook', 'address': '臉書'}

Python Mongodb 修改文檔

 

我們可以在 MongoDB 中使用 update_one() 方法修改文檔中的記錄。該方法第一個參數為查詢的條件，第二個參數為要修改的字段。

如果查找到的匹配數據多余一條，則只會修改第一條。

以下實例將 alexa 字段的值 10000 改為 12345:

 

import pymongo

client = pymongo.MongoClient("mongodb://127.0.0.1:27017")

db = client["runoobdb"]
col = db["sites"]


# 將 alexa 字段的值 10000 改為 12345:
myquery = {"alexa":"100"}
newvalue = {"$set":{"alexa":"12345"}}
col.update_one(myquery,newvalue)

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

以下實例將查找所有以 F 開頭的 name 字段，並將匹配到所有記錄的 alexa 字段修改為 123：

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
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 為降序，默認為升序。

對字段 alexa 按升序排序：

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

對字段 alexa 按降序排序：

 

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

Python Mongodb 刪除數據

 

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

 

以下實例刪除 name 字段值為 "Taobao" 的文檔：

 

import pymongo
 
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
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["runoobdb"]
mycol = mydb["sites"]
 
myquery = { "name": {"$regex": "^F"} }
 
x = mycol.delete_many(myquery)
 
print(x.deleted_count, "個文檔已刪除")

刪除集合中的所有文檔

delete_many() 方法如果傳入的是一個空的查詢對象，則會刪除集合中的所有文檔：

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

刪除集合

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

以下實例刪除了 customers 集合：

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

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