pip install pymongo==4.3.3

# 導(dǎo)入模塊
from pymongo import *
# 創(chuàng)建客戶端對(duì)象,使用賬號(hào)登錄
# 方式一：
'''
host：連接的主機(jī)名或IP地址，默認(rèn)為localhost
port：連接使用的端口號(hào)，默認(rèn)為27017
username：用于身份驗(yàn)證的用戶名，默認(rèn)為None
password：用于身份驗(yàn)證的密碼，默認(rèn)為None
authSource：用于身份驗(yàn)證的數(shù)據(jù)庫(kù)，默認(rèn)為None，表示使用admin數(shù)據(jù)庫(kù)
'''
client = MongoClient(host="112.74.96.150", port=27017, username="test", password="123456", authSource="demo")
# 方式二：
# url = "mongodb://test:123456@112.74.96.150/demo"
# client = MongoClient(url)
# 斷開與MongoDB的連接
client.close()

# 判斷數(shù)據(jù)庫(kù)是否已存在
dblist = client.list_database_names()
if "demo" in dblist:
  print("demo 數(shù)據(jù)庫(kù)已存在！")
# 創(chuàng)建、獲取數(shù)據(jù)庫(kù)對(duì)象
db = client.demo
db = client['demo']
#  判斷集合是否存在
collist = db . list_collection_names()
if "user" in collist:  
  print("user 集合已存在！")
# 創(chuàng)建、獲取集合
collection = db.user
collection = db["user"]

result = collection.insert_one({"name": "Python", "age": 25})
# 插入操作是否被確認(rèn)
print(result.acknowledged)  # True
# 插入文檔的 _id 字段的值。如果文檔沒(méi)有設(shè)置 _id 字段，則 inserted_id 的值為一個(gè)新生成的 ObjectId。
print(result.inserted_id)  # 63f569b89a8014989e3b53f6
# 批量插入
result = collection.insert_many([{"name": "Java", "age": 55}, {"name": "Vue", "age": 33}])
# 插入操作是否被確認(rèn)
print(result.acknowledged)  # True
# 插入的所有文檔的 _id 值的列表。
print(result.inserted_ids)  # [ObjectId('63f569b89a8014989e3b53f7'), ObjectId('63f569b89a8014989e3b53f8')]

result = collection.insert_many([{"name": "Java", "age": 55}, {"name": "Vue", "age": 33}])
# 插入操作是否被確認(rèn)
print(result.acknowledged)  # True
# 插入的所有文檔的 _id 值的列表。
print(result.inserted_ids)  # [ObjectId('63f569b89a8014989e3b53f7'), ObjectId('63f569b89a8014989e3b53f8')]

result = collection.find_one({"name": "Python"})
print(result)

rows = collection.find({"name": "Python"})
for row in rows:
    print(row)

rows = collection.find({},{ "_id": 0, "name": 1, "age": 1 }):
for x in 
  print(x)

# 查詢年齡大于等于30
query = { "age": { "$gte": 30 } }
result = collection.find(query)
for document in result:
    print(document)

# 查看name 字段中以字母'java'開頭的數(shù)據(jù)
query = { "name": { "$regex": "^java" } }
result = collection.find(query)
for document in result:
    print(document)

result = collection.find().limit(3)
for x in result:
  print(x)

'''
matched_count：符合篩選條件的文檔數(shù)
modified_count：實(shí)際被更新的文檔數(shù)
upserted_id：如果執(zhí)行的是 upsert 操作，則包含新插入文檔的 _id 值
'''
result = collection.update_one({"name": "Python"}, {"$set": {"age": 25}})
print(result.matched_count)
print(result.modified_count)
print(result.upserted_id)
# 不存在就插入
data = {"name": "Python", "age": 25}
client.test.test.update_one({'name': 'Java'}, {'$set': data}, upsert=True)

collection.update_many({"name": "Python"}, {"$set": {"age": 22}})
# 不存在就插入
data = {"name": "Python", "age": 25}
client.test.test.update_one({'name': 'Java'}, {'$set': data}, upsert=True)

'''
acknowledged：一個(gè)布爾值，表示操作是否被確認(rèn)（即是否執(zhí)行成功）
deleted_count：一個(gè)整數(shù)，表示被刪除的文檔數(shù)量
'''
result = collection.delete_one({"name": "Python"})
print(result.acknowledged)
print(result.deleted_count)

collection.delete_many({"age": {"$gt": 20}})

x = user.delete_many({})
print(x.deleted_count, "個(gè)文檔已刪除")
db.user.delete_many({})

# 返回true:刪除成功
# 返回false:刪除失敗(集合不存在)
collection.drop()

result = collection.find().sort("age")
for x in result:
  print(x)

result = collection.find().sort("age", -1)
for x in result:
  print(x)

count = collection.find().count()
query = { "age": { "$gte": 30 } }
count = collection.find(query).count()

# 構(gòu)建聚合管道
pipeline = [
    {"$group": {"_id": "$category", "total_sales": {"$sum": "$amount"}}},
    {"$sort": {"total_sales": -1}},
    {"$limit": 3}
]
# 執(zhí)行聚合查詢
result = collection.aggregate(pipeline)
for document in result:
    print(document)