### 如何在 Python 中连接和操作 MongoDB 要在 Python 中连接和操作 MongoDB，通常需要使用 `pymongo` 库。该库提供了与 MongoDB 数据库交互的接口，支持各种数据库操作，例如插入、查询、更新和删除文档等[^1]。 以下是具体的实现方法： #### 安装 pymongo 首先需要安装 `pymongo` 库。可以通过以下命令安装： ```bash pip install pymongo ``` #### 连接 MongoDB 要连接到 MongoDB，可以使用 `MongoClient` 类。以下是一个示例代码，展示如何连接到本地运行的 MongoDB 实例： ```python from pymongo import MongoClient # 创建一个 MongoClient 对象，连接到本地 MongoDB 实例 client = MongoClient('mongodb://localhost:27017/') ``` 如果 MongoDB 实例运行在远程服务器上，则需要将 `'mongodb://localhost:27017/'` 替换为实际的 MongoDB URI[^1]。 #### 选择数据库和集合 连接成功后，可以选择一个数据库和集合（类似于关系型数据库中的表）。以下是一个示例： ```python # 选择数据库 db = client['mydatabase'] # 选择集合 collection = db['mycollection'] ``` #### 插入数据 可以使用 `insert_one` 或 `insert_many` 方法向集合中插入单个或多个文档： ```python # 插入单个文档 post = {"author": "Mike", "text": "My first blog post!", "tags": ["mongodb", "python", "pymongo"]} result = collection.insert_one(post) print("Inserted ID:", result.inserted_id) # 插入多个文档 posts = [ {"author": "Alice", "text": "Hello world!", "tags": ["hello", "world"]}, {"author": "Bob", "text": "Python is great!", "tags": ["python", "programming"]} ] result = collection.insert_many(posts) print("Inserted IDs:", result.inserted_ids) ``` #### 查询数据 可以使用 `find_one` 或 `find` 方法查询集合中的文档： ```python # 查询单个文档 document = collection.find_one({"author": "Mike"}) print("Found Document:", document) # 查询多个文档 documents = collection.find({"tags": "python"}) for doc in documents: print("Document:", doc) ``` #### 更新数据 可以使用 `update_one` 或 `update_many` 方法更新集合中的文档： ```python # 更新单个文档 result = collection.update_one({"author": "Mike"}, {"$set": {"text": "Updated blog post!"}}) print("Modified Count:", result.modified_count) # 更新多个文档 result = collection.update_many({"tags": "python"}, {"$push": {"tags": "new_tag"}}) print("Modified Count:", result.modified_count) ``` #### 删除数据 可以使用 `delete_one` 或 `delete_many` 方法删除集合中的文档： ```python # 删除单个文档 result = collection.delete_one({"author": "Alice"}) print("Deleted Count:", result.deleted_count) # 删除多个文档 result = collection.delete_many({"tags": "world"}) print("Deleted Count:", result.deleted_count) ```