Python操作MongoDB的教程详解(插,查,改,排,删)

Python操作MongoDB的教程详解

什么是MongoDB？

MongoDB是一个跨平台的、面向文档的NoSQL数据库。它以JSON文档的形式存储数据，是一种非常灵活的数据库系统，非常适合在处理大量非结构化数据时使用。

安装PyMongo

PyMongo是Python操作MongoDB的官方驱动程序，直接使用以下命令进行安装即可：

pip install pymongo

连接MongoDB

在使用PyMongo进行MongoDB操作之前，需要先与数据库建立连接。使用以下代码可以建立与本地MongoDB数据库的连接：

import pymongo

client = pymongo.MongoClient('mongodb://localhost:27017/')

在上述代码中，首先导入pymongo模块，然后使用MongoClient建立与本地数据库的连接。

如果需要连接远程MongoDB数据库，可以使用以下代码：

import pymongo

client = pymongo.MongoClient('mongodb://<用户名>:<密码>@<主机>:<端口>/<数据库名称>')

在上述代码中，用户名和密码是安全连接到远程服务器所需的凭据，主机和端口是MongoDB服务器的地址，数据库名称是要连接的数据库的名称。

插入数据

使用PyMongo向MongoDB插入数据非常简单。我们只需要先指定要操作的数据库和集合，然后使用insert_one()或insert_many()方法插入数据。例如：

import pymongo

client = pymongo.MongoClient('mongodb://localhost:27017/')

db = client['test']  # test是数据库名称
collection = db['students']  # students是集合名称

# 插入一条数据
student = {'name': '张三', 'age': 21, 'sex': '男'}
result = collection.insert_one(student)
print(result.inserted_id)

# 插入多条数据
students = [
    {'name': '李四', 'age': 22, 'sex': '男'},
    {'name': '王五', 'age': 20, 'sex': '女'}
]
result = collection.insert_many(students)
print(result.inserted_ids)

在上述代码中，首先建立了与本地MongoDB数据库的连接，然后指定了要插入数据的数据库和集合。使用insert_one()方法插入单条数据，使用insert_many()方法插入多条数据。

查询数据

使用PyMongo查询MongoDB数据非常灵活。我们可以运用丰富的查询条件，以及排序、限制数量等操作。例如：

import pymongo

client = pymongo.MongoClient('mongodb://localhost:27017/')

db = client['test']  # test是数据库名称
collection = db['students']  # students是集合名称

# 查询所有数据
result = collection.find()
for record in result:
    print(record)

# 按条件查询数据
query = {'age': {'$gt': 20}}  # 查询年龄大于20的数据
result = collection.find(query)
for record in result:
    print(record)

# 查询单条数据
query = {'name': '张三'}  # 查询姓名为张三的数据
result = collection.find_one(query)
print(result)

在上述代码中，首先建立了与本地MongoDB数据库的连接，然后指定了要查询数据的数据库和集合。使用find()方法查询所有数据，使用find_one()方法查询单条数据，使用query参数查询特定条件下的数据。

更新数据

使用PyMongo更新MongoDB数据非常简单。我们可以根据条件更新一条或多条记录。例如：

import pymongo

client = pymongo.MongoClient('mongodb://localhost:27017/')

db = client['test']  # test是数据库名称
collection = db['students']  # students是集合名称

# 更新单条数据
query = {'name': '张三'}
new_data = {'$set': {'age': 23}}
result = collection.update_one(query, new_data)
print(result.modified_count)

# 更新多条数据
query = {'age': {'$gte': 21}}
new_data = {'$set': {'age': 22}}
result = collection.update_many(query, new_data)
print(result.modified_count)

在上述代码中，首先建立了与本地MongoDB数据库的连接，然后指定了要更新数据的数据库和集合。使用update_one()方法更新单条数据，使用update_many()方法更新多条数据，使用query参数指定更新条件，使用new_data参数指定更新后的数据。

删除数据

使用PyMongo删除MongoDB数据也很简单。我们可以根据条件删除一条或多条记录。例如：

import pymongo

client = pymongo.MongoClient('mongodb://localhost:27017/')

db = client['test']  # test是数据库名称
collection = db['students']  # students是集合名称

# 删除单条数据
query = {'name': '张三'}
result = collection.delete_one(query)
print(result.deleted_count)

# 删除多条数据
query = {'age': {'$lt': 21}}
result = collection.delete_many(query)
print(result.deleted_count)

在上述代码中，首先建立了与本地MongoDB数据库的连接，然后指定了要删除数据的数据库和集合。使用delete_one()方法删除单条数据，使用delete_many()方法删除多条数据，使用query参数指定删除条件。

示例

以下是一个完整的示例，以更好地理解Python操作MongoDB的教程：

import pymongo

client = pymongo.MongoClient('mongodb://localhost:27017/')

# 创建数据库和集合
db = client['test']
collection = db['students']

# 插入数据
student = {'name': '张三', 'age': 21, 'sex': '男'}
result = collection.insert_one(student)
print(result.inserted_id)

students = [
    {'name': '李四', 'age': 22, 'sex': '男'},
    {'name': '王五', 'age': 20, 'sex': '女'}
]
result = collection.insert_many(students)
print(result.inserted_ids)

# 查询数据
result = collection.find()
for record in result:
    print(record)

query = {'age': {'$gt': 20}}
result = collection.find(query)
for record in result:
    print(record)

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

# 更新数据
query = {'name': '张三'}
new_data = {'$set': {'age': 23}}
result = collection.update_one(query, new_data)
print(result.modified_count)

query = {'age': {'$gte': 21}}
new_data = {'$set': {'age': 22}}
result = collection.update_many(query, new_data)
print(result.modified_count)

# 删除数据
query = {'name': '张三'}
result = collection.delete_one(query)
print(result.deleted_count)

query = {'age': {'$lt': 21}}
result = collection.delete_many(query)
print(result.deleted_count)

在上述示例中，我们首先建立了与本地MongoDB数据库的连接，然后创建了一个名为test的数据库和一个名为students的集合。接着使用insert_one()和insert_many()方法向集合中插入数据，使用find()和find_one()方法查询数据，使用update_one()和update_many()方法更新数据，使用delete_one()和delete_many()方法删除数据。