基本语法：mongdb语法_郑*杰的博客-CSDN博客
连接服务
import pymongo
conn = pymongo.MongoClient(host='localhost', port=27017)
#也可以直接使用uri
conn = pymongo.MongoClient('mongodb://test:ruqigac123!%40#@127.0.0.1:27017/Analyze?authSource=admin')
# 切换数据库,相当于在终端：use test
db = conn['test']
# 登录该数据库(需要的话)
#db.authenticate("admin", '123456')
# 相当于db.'mongo_test.find()
result = db['mongo_test'].find()
for r in result:print(r)增删改查
from pymongo import MongoClientdef get_db(database): # 传数据库client = MongoClient(host="localhost", port=27017)db = client[database]return dbdef add_one(table, data):db = get_db("test")result = db[table].insert_one(data)return resultdef add_many(table, data_list):db = get_db("test")result = db[table].insert_many(data_list)return result.inserted_idsdef update(table, condition, data): #condition条件db = get_db("test")result = db[table].update_many(condition, {'$set':data})return resultdef delete(table, condition):#condition条件db = get_db("test")result = db[table].delete_many(condition)return result
def select(table,condition:dict):db = get_db('test')dbData = db[table].find(condition)results =[]for result in dbData:results.append(result)return resultsif __name__ == '__main__':r_one = add_one("mongo_test", {"name": "西瓜", "age":18})print(r_ibe.inserted_id) # 可查看idadd_many("mongo_test", [{"name": "嘎嘎"},{"name": "咔咔"}])update("mongo_test", {"name": '西瓜'}, {"age": 100})delete("mongo_test", {"name": "嘎嘎"})r=select('mongo_test',{'name':'朱元璋'})print(r)