pip install pymongo

from pymongo import MongoClient
 
# 創(chuàng)建一個(gè)MongoClient對象，該對象用于連接Mongodb數(shù)據(jù)庫服務(wù)器
client = MongoClient('mongodb://admin:password@localhost:27017/')

from mongo_db import client
 
# client.school.teacher.insert_one({"name": "露娜"})
 
# client.school.teacher.insert_many([{"name":"蘭陵王"}, {"name": "百里玄策"}])
 
client.school.teacher.find({})

from mongo_db import client
 
try:
    teachers = client.school.teacher.find()
    # print(teachers)
    for one in teachers:
        print(one["_id"],one["name"])
 
    # 有條件查詢
    teacher = client.school.teacher.find_one({"name":"蘭陵王"})
    print(teacher["_id"],teacher["name"])
 
except Exception  as e:
    print(e)

from mongo_db import client
 
try:
    # 全表修改，表中無此列時(shí)會增加此列
    # client.school.teacher.update_many({}, {'$set': {"role":["班主任"]}})
    # client.school.teacher.update_one({"name": "露娜"},{"$set":{"sex": "女"}})
 
    # push追加(列表)
    client.school.teacher.update_one({"name": "露娜"},{"$push":{"role": "年級王主任"}})
 
except Exception as e:
    print(e)

from mongo_db import client
 
try:
    # 有條件查詢
    # client.school.teacher.delete_one({"name": "露娜"})
    # 刪除多條數(shù)據(jù)
    client.school.teacher.delete_many({})
except Exception as e:
    print(e)

collection.create_index([("name", pymongo.ASCENDING)])

pipeline = [
    {"$match": {"age": {"$gt": 25}}},
    {"$group": {"_id": "$city", "count": {"$sum": 1}}}
]
results = collection.aggregate(pipeline)
for result in results:
    print(result)

with client.start_session() as session:
    with session.start_transaction():
        collection.update_one({"name": "John"}, {"$set": {"age": 32}}, session=session)
        collection.update_one({"name": "Alice"}, {"$set": {"age": 26}}, session=session)
        session.commit_transaction()

client.close()