from pymongo import MongoClient
# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')
db = client['test_database'] # 选择数据库
collection = db['test_collection'] # 选择集合/表
# 插入文档
def insert_document(collection, data):
collection.insert_one(data)
# 查询文档
def query_documents(collection):
for doc in collection.find():
print(doc)
# 更新文档
def update_document(collection, query, new_values):
collection.update_one(query, {'$set': new_values})
# 排序文档
def sort_documents(collection):
for doc in collection.find().sort('field_name', pymongo.ASCENDING):
print(doc)
# 删除文档
def delete_document(collection, query):
collection.delete_one(query)
# 示例数据和操作
data = {'name': 'Alice', 'age': 25}
query = {'name': 'Alice'}
new_values = {'age': 30}
# 插入
insert_document(collection, data)
# 查询
query_documents(collection)
# 更新
update_document(collection, query, new_values)
# 排序
sort_documents(collection)
# 删除
delete_document(collection, query)
这段代码展示了如何使用pymongo
库来连接MongoDB,执行插入、查询、更新、排序和删除操作。在实际应用中,你需要根据自己的需求调整数据库地址、数据库名、集合名以及查询条件等。