当前位置：首页 > article >正文

Python知识点：如何使用MongoDB与PyMongo进行NoSQL数据库操作

article 2025/2/25 9:52:36

使用MongoDB与PyMongo进行NoSQL数据库操作的步骤如下。PyMongo是一个用于与MongoDB交互的Python库，它提供了对MongoDB的完整访问。

1. 安装PyMongo

首先，你需要安装PyMongo库。如果还未安装，可以使用以下命令进行安装：

pip install pymongo

2. 连接到MongoDB数据库

使用MongoClient类来创建一个连接对象，连接到MongoDB实例。

from pymongo import MongoClient

# 创建MongoDB连接
client = MongoClient('localhost', 27017)  # 默认端口27017

# 选择数据库，如果数据库不存在则创建
db = client['your_database_name']

# 选择集合，相当于关系数据库中的表，如果集合不存在则创建
collection = db['your_collection_name']

3. 插入文档

在MongoDB中，数据以文档的形式存储在集合中。文档是一个类似于JSON的结构化数据。

插入单个文档

document = {
    "name": "Alice",
    "age": 25,
    "department": "Engineering"
}

inserted_id = collection.insert_one(document).inserted_id
print(f"Inserted document ID: {inserted_id}")

插入多个文档

documents = [
    {"name": "Bob", "age": 30, "department": "HR"},
    {"name": "Charlie", "age": 28, "department": "Marketing"}
]

inserted_ids = collection.insert_many(documents).inserted_ids
print(f"Inserted document IDs: {inserted_ids}")

4. 查询文档

你可以使用各种查询条件来查找集合中的文档。

查询所有文档

for doc in collection.find():
    print(doc)

查询特定条件的文档

query = {"department": "Engineering"}
result = collection.find(query)

for doc in result:
    print(doc)

查询单个文档

query = {"name": "Alice"}
doc = collection.find_one(query)
print(doc)

5. 更新文档

你可以更新一个或多个文档。

更新单个文档

query = {"name": "Alice"}
new_values = {"$set": {"age": 26}}

collection.update_one(query, new_values)

更新多个文档

query = {"department": "HR"}
new_values = {"$set": {"department": "Human Resources"}}

collection.update_many(query, new_values)

6. 删除文档

你可以删除一个或多个文档。

删除单个文档

query = {"name": "Bob"}

collection.delete_one(query)

删除多个文档

query = {"department": "Human Resources"}

collection.delete_many(query)

7. 关闭连接

在不再需要连接时，可以关闭它，不过在大多数应用中，不显式关闭连接也是可以的。

client.close()

8. 异常处理

在实际应用中，建议使用异常处理来应对连接或操作中的错误。

from pymongo.errors import ConnectionError, OperationFailure

try:
    client = MongoClient('localhost', 27017)
    db = client['your_database_name']
    collection = db['your_collection_name']

    # 执行查询或操作
    document = collection.find_one({"name": "Alice"})
    print(document)

except ConnectionError as conn_err:
    print(f"Connection error: {conn_err}")
except OperationFailure as op_err:
    print(f"Operation failure: {op_err}")
finally:
    client.close()