Python操作MongoDB文檔資料庫

来源:https://www.cnblogs.com/wefeng/archive/2019/09/10/11503102.html
-Advertisement-
Play Games

PyMongo是驅動程式，使python程式能夠使用Mongodb資料庫，使用python編寫而成 ...


1.Pymongo 安裝

安裝pymongo：

pip install pymongo
  • PyMongo是驅動程式，使python程式能夠使用Mongodb資料庫，使用python編寫而成；

2.Pymongo 方法

  • insert_one()：插入一條記錄；
  • insert()：插入多條記錄；
  • find_one()：查詢一條記錄，不帶任何參數返回第一條記錄，帶參數則按條件查找返回；
  • find()：查詢多條記錄，不帶參數返回所有記錄，帶參數按條件查找返回；
  • count()：查看記錄總數；
  • create_index()：創建索引；
  • update_one()：更新匹配到的第一條數據；
  • update()：更新匹配到的所有數據；
  • remove()：刪除記錄，不帶參表示刪除全部記錄，帶參則表示按條件刪除；
  • delete_one()：刪除單條記錄；
  • delete_many()：刪除多條記錄；

3.Pymongo 中的操作

  • 查看資料庫
from pymongo import MongoClient

connect = MongoClient(host='localhost', port=27017, username="root", password="123456")
connect = MongoClient('mongodb://localhost:27017/', username="root", password="123456")

print(connect.list_database_names())
  • 獲取資料庫實例
test_db = connect['test']
  • 獲取collection實例
collection = test_db['students']
  • 插入一行document, 查詢一行document，取出一行document的值
from pymongo import MongoClient
from datetime import datetime

connect = MongoClient(host='localhost', port=27017, username="root", password="123456",)
# 獲取db
test_db = connect['test']
# 獲取collection
collection = test_db['students']
# 構建document
document = {"author": "Mike",  "text": "My first blog post!", "tags": ["mongodb", "python", "pymongo"], "date": datetime.now()}
# 插入document
one_insert = collection.insert_one(document=document)
print(one_insert.inserted_id)

# 通過條件過濾出一條document
one_result = collection.find_one({"author": "Mike"})
# 解析document欄位
print(one_result, type(one_result))
print(one_result['_id'])
print(one_result['author'])

註意：如果需要通過id查詢一行document，需要將id包裝為ObjectId類的實例對象
from bson.objectid import ObjectId
collection.find_one({'_id': ObjectId('5c2b18dedea5818bbd73b94c')})
  • 插入多行documents, 查詢多行document， 查看collections有多少行document
from pymongo import MongoClient
from datetime import datetime
connect = MongoClient(host='localhost', port=27017, username="root", password="123456",)

# 獲取db
test_db = connect['test']

# 獲取collection
collection = test_db['students']
documents = [{"author": "Mike","text": "Another post!","tags": ["bulk", "insert"], "date": datetime(2009, 11, 12, 11, 14)},
{"author": "Eliot", "title": "MongoDB is fun", "text": "and pretty easy too!", "date": datetime(2009, 11, 10, 10, 45)}]
collection.insert_many(documents=documents)

# 通過條件過濾出多條document
documents = collection.find({"author": "Mike"})

# 解析document欄位
print(documents, type(documents))
print('*'*300)
for document in documents:
    print(document)
print('*'*300)
result = collection.count_documents({'author': 'Mike'})
print(result)
  • 範圍比較查詢
from pymongo import MongoClient
from datetime import datetime

connect = MongoClient(host='localhost', port=27017, username="root", password="123456",)

# 獲取db
test_db = connect['test']

# 獲取collection
collection = test_db['students']

# 通過條件過濾時間小於datetime(2019, 1,1,15,40,3) 的document
documents = collection.find({"date": {"$lt": datetime(2019, 1,1,15,40,3)}}).sort('date')

# 解析document欄位
print(documents, type(documents))
print('*'*300)
for document in documents:
    print(document)
  • 創建索引
from pymongo import MongoClient
import pymongo
from datetime import datetime

connect = MongoClient(host='localhost', port=27017, username="root", password="123456",)
# 獲取db
test_db = connect['test']
# 獲取collection
collection = test_db['students']
# 創建欄位索引
collection.create_index(keys=[("name", pymongo.DESCENDING)], unique=True)
# 查詢索引
result = sorted(list(collection.index_information()))
print(result)
  • document修改
from pymongo import MongoClient
connect = MongoClient(host='localhost', port=27017, username="root", password="123456",)

# 獲取db
test_db = connect['test']

# 獲取collection
collection = test_db['students']
result = collection.update({'name': 'robby'}, {'$set': {"name": "Petter"}})
print(result)
註意：還有update_many()方法
  • document刪除
from pymongo import MongoClient
connect = MongoClient(host='localhost', port=27017, username="root", password="123456",)

# 獲取db
test_db = connect['test']

# 獲取collection
collection = test_db['students']
result = collection.delete_one({'name': 'Petter'})
print(result.deleted_count)
註意：還有delete_many()方法

4.MongoDB ODM 詳解

  • MongoDB ODM 與 Django ORM使用方法類似；
  • MongoEngine是一個對象文檔映射器，用Python編寫，用於處理MongoDB；
  • MongoEngine提供的抽象是基於類的，創建的所有模型都是類；
# 安裝mongoengine
pip install mongoengine
  • mongoengine使用的欄位類型
BinaryField
BooleanField
ComplexDateTimeField
DateTimeField
DecimalField
DictField
DynamicField
EmailField
EmbeddedDocumentField
EmbeddedDocumentListField
FileField
FloatField
GenericEmbeddedDocumentField
GenericReferenceField
GenericLazyReferenceField
GeoPointField
ImageField
IntField
ListField:可以將自定義的文檔類型嵌套
MapField
ObjectIdField
ReferenceField
LazyReferenceField
SequenceField
SortedListField
StringField
URLField
UUIDField
PointField
LineStringField
PolygonField
MultiPointField
MultiLineStringField
MultiPolygonField

5.使用mongoengine創建資料庫連接

from mongoengine import connect

conn = connect(db='test', host='localhost', port=27017, username='root', password='123456', authentication_source='admin')
print(conn)

connect（db = None，alias ='default'，** kwargs ）；

  • db：要使用的資料庫的名稱，以便與connect相容；
  • host ：要連接的mongod實例的主機名；
  • port ：運行mongod實例的埠；
  • username：用於進行身份驗證的用戶名；
  • password：用於進行身份驗證的密碼；
  • authentication_source ：要進行身份驗證的資料庫；

構建文檔模型，插入數據

from mongoengine import connect, \
                        Document, \
                        StringField,\
                        IntField, \
                        FloatField,\
                        ListField, \
                        EmbeddedDocumentField,\
                        DateTimeField, \
                        EmbeddedDocument
from datetime import datetime

# 嵌套文檔
class Score(EmbeddedDocument):
    name = StringField(max_length=50, required=True)
    value = FloatField(required=True)

class Students(Document):
    choice =  (('F', 'female'),
               ('M', 'male'),)
    name = StringField(max_length=100, required=True, unique=True)
    age = IntField(required=True)
    hobby = StringField(max_length=100, required=True, )
    gender = StringField(choices=choice, required=True)
    # 這裡使用到了嵌套文檔，這個列表中的每一個元素都是一個字典，因此使用嵌套類型的欄位
    score = ListField(EmbeddedDocumentField(Score))
    time = DateTimeField(default=datetime.now())

if __name__ == '__main__':
    connect(db='test', host='localhost', port=27017, username='root', password='123456', authentication_source='admin')
    math_score = Score(name='math', value=94)
    chinese_score = Score(name='chinese', value=100)
    python_score = Score(name='python', value=99)

    for i in range(10):
        students = Students(name='robby{}'.format(i), age=int('{}'.format(i)), hobby='read', gender='M', score=[math_score, chinese_score, python_score])
        students.save()

查詢數據

from mongoengine import connect, \
                        Document, \
                        StringField,\
                        IntField, \
                        FloatField,\
                        ListField, \
                        EmbeddedDocumentField,\
                        DateTimeField, \
                        EmbeddedDocument
from datetime import datetime

# 嵌套文檔
class Score(EmbeddedDocument):
    name = StringField(max_length=50, required=True)
    value = FloatField(required=True)

class Students(Document):
    choice =  (('F', 'female'),
               ('M', 'male'),)

    name = StringField(max_length=100, required=True, unique=True)
    age = IntField(required=True)
    hobby = StringField(max_length=100, required=True, )
    gender = StringField(choices=choice, required=True)
    # 這裡使用到了嵌套文檔，這個列表中的每一個元素都是一個字典，因此使用嵌套類型的欄位
    score = ListField(EmbeddedDocumentField(Score))
    time = DateTimeField(default=datetime.now())

if __name__ == '__main__':
    connect(db='test', host='localhost', port=27017, username='root', password='123456', authentication_source='admin')

    first_document = Students.objects.first()

    all_document = Students.objects.all()

    # 如果只有一條，也可以使用get
    specific_document = Students.objects.filter(name='robby3')

    print(first_document.name, first_document.age, first_document.time)

    for document in all_document:
        print(document.name)

    for document in specific_document:
        print(document.name, document.age)

修改、更新、刪除數據

from mongoengine import connect, \
                        Document, \
                        StringField,\
                        IntField, \
                        FloatField,\
                        ListField, \
                        EmbeddedDocumentField,\
                        DateTimeField, \
                        EmbeddedDocument
from datetime import datetime

# 嵌套文檔
class Score(EmbeddedDocument):
    name = StringField(max_length=50, required=True)
    value = FloatField(required=True)

class Students(Document):
    choice =  (('F', 'female'),
               ('M', 'male'),)

    name = StringField(max_length=100, required=True, unique=True)
    age = IntField(required=True)
    hobby = StringField(max_length=100, required=True, )
    gender = StringField(choices=choice, required=True)
    # 這裡使用到了嵌套文檔，這個列表中的每一個元素都是一個字典，因此使用嵌套類型的欄位
    score = ListField(EmbeddedDocumentField(Score))
    time = DateTimeField(default=datetime.now())

if __name__ == '__main__':
    connect(db='test', host='localhost', port=27017, username='root', password='123456', authentication_source='admin')

    specific_document = Students.objects.filter(name='robby3')
    specific_document.update(set__age=100)
    specific_document.update_one(set__age=100)

    for document in specific_document:
        document.name = 'ROBBY100'
        document.save()

    for document in specific_document:
        document.delete()
  • all()：返回所有文檔；
  • all_fields()：包括所有欄位；
  • as_pymongo()：返回的不是Document實例 而是pymongo值；
  • average()：平均值超過指定欄位的值；
  • batch_size()：限制單個批次中返回的文檔數量；
  • clone()：創建當前查詢集的副本；
  • comment()：在查詢中添加註釋；
  • count()：計算查詢中的選定元素；
  • create()：創建新對象，返回保存的對象實例；
  • delete()：刪除查詢匹配的文檔；
  • distinct()：返回給定欄位的不同值列表；

嵌入式文檔查詢的方法

  • count()：列表中嵌入文檔的數量，列表的長度；
  • create()：創建新的嵌入式文檔並將其保存到資料庫中；
  • delete()：從資料庫中刪除嵌入的文檔；
  • exclude(** kwargs )：通過使用給定的關鍵字參數排除嵌入的文檔來過濾列表；
  • first()：返回列表中的第一個嵌入文檔；
  • get()：檢索由給定關鍵字參數確定的嵌入文檔；
  • save()：保存祖先文檔；
  • update()：使用給定的替換值更新嵌入的文檔；

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Linux RedHat 7 配置本地 YUM源
    儘管RPM安裝方法能夠幫助用戶查詢軟體相關的依賴關係，但是還是需要安裝人員自己來解決，而且有些大型軟體可能與數十個程式都有依賴關係，在這種情況下安裝軟體事件非常痛苦和耗費事件的事情，而Yum軟體倉庫可以根據用戶的要求分析出所需軟體包及相互的依賴關係，然後自動從Yum源中下載、安裝到系統中。 RedH ...
  • windows操作系統更改 <遠程桌面> 埠號
    windows遠程桌面連接預設使用的是3389埠,為了避免被他人掃描從而暴力破解遠程伺服器或者病毒入侵。可以將預設埠修改為其它埠，如8888，11111等。最好修改為10000以後的埠，這樣可以避免和系統內的其它程式埠衝突。 1、點擊【開始】菜單中的【運行】輸入regedit 2、在【註冊 ...
  • 一個APACHE TOMCAT漏洞修複
    這種情況加個SSL證書就行了 就是HTTPS協議 ...
  • Linux之iptables
    ...
  • Linux 網路基礎
    本篇寫一些關於 網路相關的基礎命令、配置等。 hostname 1.查看主機名 2.臨時修改主機名 3.永久修改主機名 ifconfig 1.查看已啟用的網路介面信息 ：第一塊乙太網卡的名稱。 中的 是`EtherNet s`表示熱插拔插槽上的設備 ，數字 表示插槽編號。 ：迴環網路介面， 是`lo ...
  • MySQL數據的導入與導出
    本文針對window操作系統與mysql8.0的版本。 1.mysql導出sql文件 這裡直接使用mysql提供的mysqlpump工具，以下是mysqlpump說明 mysqlpump客戶實用程式執行邏輯備份，產生一組能夠被執行以再現原始資料庫對象定義和表數據的SQL語句。它轉儲一個或多個MySQ ...
  • [20190910]索引分支塊中TERM使用什麼字元表示.txt
    [20190910]索引分支塊中TERM使用什麼字元表示.txt--//做索引塊轉儲，一些root,分支節點出現TERM，從來沒有關註使用字元表示，簡單探究看看。1.環境：SCOTT@test01p> @ ver1PORT_STRING VERSION BANNER CON_ID IBMPC/WIN ...
  • mssql sqlserver 數據類型sql_variant簡介說明
    轉自： http://www.maomao365.com/?p=9712 摘要： 下文講述sqlserver中sql_variant數據類型定義、賦值、應用的相關說明，如下所示： 實驗環境:sql server 2008 R2 數據類型sql_variant簡介sql_variant是自sqlser ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類