Python 访问 MongoDB 集合的方法

在数据处理和存储领域，MongoDB 作为一款流行的非关系型数据库，与 Python 的结合使用十分常见。掌握 Python 访问 MongoDB 集合的方法，能极大提高数据处理的效率和灵活性。

要在 Python 中访问 MongoDB 集合，需安装 pymongo 库。可以使用 pip install pymongo 命令轻松完成安装。

连接到 MongoDB 服务器是第一步。通过以下代码实现：

from pymongo import MongoClient

# 创建连接
client = MongoClient('mongodb://localhost:27017/')

这里假设 MongoDB 运行在本地默认端口 27017。如果服务器地址或端口不同，需相应调整。

连接成功后，就可以访问具体的数据库和集合。例如：

# 选择数据库
db = client['your_database_name']
# 选择集合
collection = db['your_collection_name']

其中，your_database_name 和 your_collection_name 需替换为实际的数据库名和集合名。

插入数据到集合是常用操作。可以插入单条或多条文档。插入单条文档代码如下：

document = {'name': 'John', 'age': 30}
result = collection.insert_one(document)
print(result.inserted_id)

插入多条文档则使用 insert_many 方法：

documents = [
    {'name': 'Alice', 'age': 25},
    {'name': 'Bob', 'age': 35}
]
result = collection.insert_many(documents)
print(result.inserted_ids)

查询集合中的数据也很重要。查询单条文档可使用 find_one 方法：

query = {'name': 'John'}
result = collection.find_one(query)
print(result)

查询多条文档使用 find 方法，它返回一个游标对象，可以遍历获取所有匹配文档：

query = {'age': {'$gt': 30}}
cursor = collection.find(query)
for document in cursor:
    print(document)

更新和删除操作同样不可或缺。更新文档使用 update_one 或 update_many 方法，删除文档使用 delete_one 或 delete_many 方法。例如更新操作：

filter_query = {'name': 'John'}
update_data = {'$set': {'age': 31}}
result = collection.update_one(filter_query, update_data)
print(result.modified_count)

删除操作：

delete_query = {'name': 'Bob'}
result = collection.delete_one(delete_query)
print(result.deleted_count)

通过这些方法，Python 开发者能够在程序中高效地访问和操作 MongoDB 集合，为数据处理和分析提供强大支持。