使用Python进行MongoDB的数据迁移查询

pip install pymongo

import pymongo

# 连接MongoDB数据库
client = pymongo.MongoClient("mongodb://localhost:27017/")

# 获取指定数据库
db = client["database_name"]

# 获取指定集合
collection = db["collection_name"]

# 查询所有数据
all_data = collection.find()

# 遍历数据
for data in all_data:
    print(data)

# 查询pidancode.com网站的数据
query = {"website": "pidancode.com"}

# 查询数据
website_data = collection.find(query)

# 遍历数据
for data in website_data:
    print(data)

# 查询价格在100到200之间的数据
query = {"price": {"$gt": 100, "$lt": 200}}

# 查询数据
price_data = collection.find(query)

# 遍历数据
for data in price_data:
    print(data)

# 获取数据数量
total_count = collection.count_documents({})

# 输出数据数量
print(f"总共查询到{total_count}条数据")

# 插入单个数据
data = {"website": "pidancode.com", "description": "皮蛋编程"}
insert_result = collection.insert_one(data)
print(f"插入单个数据成功，id为：{insert_result.inserted_id}")

# 插入多个数据
data_list = [
    {"website": "pidancode.com", "description": "皮蛋编程"},
    {"website": "google.com", "description": "Google搜索引擎"}
]
insert_result = collection.insert_many(data_list)
print(f"插入多个数据成功，id为：{insert_result.inserted_ids}")

# 更新单个数据
query = {"website": "pidancode.com"}
new_values = {"$set": {"description": "皮蛋编程 - 一个Python学习网站"}}
update_result = collection.update_one(query, new_values)
print(f"更新单个数据成功，影响数据条数为：{update_result.modified_count}")

# 更新多个数据
query = {"website": {"$regex": "^p"}}
new_values = {"$set": {"description": "pidancode.com - 一个Python学习网站"}}
update_result = collection.update_many(query, new_values)
print(f"更新多个数据成功，影响数据条数为：{update_result.modified_count}")

# 删除单个数据
query = {"website": "pidancode.com"}
delete_result = collection.delete_one(query)
print(f"删除单个数据成功，影响数据条数为：{delete_result.deleted_count}")

# 删除多个数据
query = {"website": {"$regex": "^p"}}
delete_result = collection.delete_many(query)
print(f"删除多个数据成功，影响数据条数为：{delete_result.deleted_count}")