Python 也能操作 MongoDB 數據庫

前言

作爲非關係數據庫的代表 --Mongo,可以說是讓人又愛又恨,讓人愛的是它的便捷性,讓人恨的是它的配置,實在是坑多。那麼今天我們就來深入剖析它吧。

一、下載並導入 Python 連接 Mongo 的模塊

pip install pymongo
from pymongo import MongoClient

二、連接 Mongo 數據庫

1. 普通登錄,又稱遊客登陸,安全等級低

MongoClient('mongodb://localhost:27017/')

2. 用戶密碼登陸,安全等級高

MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')

這裏連接到了用戶名爲 hwzjj,密碼爲 123456 的用戶。

三、執行插入操作

爲了安全,我們使用用戶名和密碼登陸,然後創建一個集合,不知道大家對 Mongo 創建集合還有沒有印象,反正小編還有,廢話不多說,先創建兩個集合。

db.createCollection(name='student',option={capped:true,autoIndexId:true,size:100,max:1000})
db.createCollection(name='teacher',option={capped:true,autoIndexId:true,size:200,max:2000})

這樣就創建了一 student 和 teacher 的集合了。然後我們再來顯示一下所有的集合名:

show collections;

然後我們往集合裏插入數據,在 Mongo 中是這樣插入的:

可以看到我們成功插入了兩條數據,接下來我們利用 Python 來插入數據。

1. 直接使用創建好的集合插入數據

from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw') 連接數據庫
db=client['hw']        選擇數據庫hw
coll=db['student']     選擇集合
res={'id':'0003','name':'任性','age':43}
first=coll.insert_one(res)  將數據插入到集合中
print(first.inserted_id)   打印插入數據的id(每個插入數據都會有)

2. 自己創建集合插入數據

from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')
db=client['hw']
db.create_collection('teacher')  創建集合
res={'id':'0001','name':'boy','age':36}
last=db.student.insert_one(res)  插入數據
print(last.inserted_id) 打印id

3. 插入多條數據

import random
from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')
db=client['hw']
coll=db['student']
def get():
    for y in range(100000):
        data={'id':y,'name':'user--'+str(y),'age':random.choice(range(100))}
        yield data
for y in get():
    coll.insert(y)

同樣是插入十萬個數據, 不過數據卻是比 Mysql 慢一點,可自行測試。

注:執行插入操作時,Insert 最多可插入四條同樣的記錄。

四、執行更改操作

仍舊是先要獲取集合,然後對集合中的內容進行修改。

1. 更新匹配到的第一條數據

from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')
db=client['hw']
coll=db['student']
coll.update_one({'name':'user--10'},{'$set':{'name':'用戶已註銷'}}) 更新匹配到的第一條數據

2. 更新匹配到的所有數據

我們創建四個一樣的數據,將程序執行四次即可:

from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')
db=client['hw']
coll=db['student']
coll.insert({'id':'111','name':'hw','age':43})

可以看到生成了四個同樣的記錄,當然了,只能生成最多 4 條記錄。然後我們全部將它們數據修改。

coll.update({'name':'hw'},{'$set':{'name':'用戶已註冊'}})

五、執行刪除操作


1. 刪除所有符合條件的數據

from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')
db=client['hw']
coll=db['student']
coll.insert({'id':'111','name':'hw','age':43}) 插入數據
coll.remove({'name':'hw'}) 刪除所有name 爲hw的數據,注意不要以id爲條件來刪除,會報錯
coll.delete_many({'name':'hw'}) 跟上者功能一樣

2. 刪除所有符合條件的第一條數據

from pymongo import MongoClient
client=MongoClient('mongodb://hwzjj:123456@localhost:27017/hw')
db=client['hw']
coll=db['student']
coll.insert({'id':'111','name':'hw','age':43})
coll.delete_one({'name':'hw'}) 刪除符合條件的第一條數據

六、執行查詢操作

1. 查詢符合條件的第一條數據

2. 查詢符合條件的所有數據

3. 查找後刪除

4. 查找後替換

5. 查找後更新

6. 統計符合條件的記錄數量

coll.find().count() # 記錄符合條件的數量

7. 符合條件的數據的排序

coll.find().sort('name', pymongo.ASCENDING) # 升序排序 DESCENDING 降序排序
8.符合條件數量中跳過
coll.find().sort('name', pymongo.ASCENDING).skip(1) # 跳過一個記錄
9.限制符合條件輸出數量
coll.find().sort('name', pymongo.ASCENDING).limit(2) # 輸出兩個符合條件的記錄
10.通過Id來查找

每個插入的數據都會生成一個 id,貌似被加密了,前面我們已經和它打過交道了,下面來看下它的使用。

from bson.objectid import ObjectId
find_one({'_id': ObjectId(id_name)})

七、索引操作

1. 創建索引

可以看到有兩個索引,一個是 Mongo 自動創建的在 id 上的索引,另一個是剛剛創建在 name 上的索引。

2. 獲取索引

for y in coll.list_indexes(): # 獲取所有索引
  print(y)

3. 刪除索引

可以看到剛剛的索引 name 已經被刪除了,而且只有一條數據了,那麼有人就問了,爲何不把_id 一起刪除,很抱歉,這個是刪不了的。

八、總結

通過本章對 Pymongo 的學習,相信你已經可以勝任日常一些開發了,Pymongo 中還有很多值得學習的地方,值得你去推敲,在這裏就不一一列舉了,希望本文能帶大家零基礎毫無壓力入門 Pymongo。

本文由 Readfog 進行 AMP 轉碼,版權歸原作者所有。
來源https://mp.weixin.qq.com/s/34t_u-JxL3HFXvEdtgFQEg