from pymongo import MongoClient #创建连接
conn = MongoClient('localhost',27017)#创建数据库对象
db = conn.stu #创建集合对象
myset = db.class4 print(dir(myset))# 插入操作
myset.insert({'name':'张铁林','King':'乾隆'})
myset.insert([{'name':'张国立','King':'康熙'},\{'name':'陈道明','King':'康熙'}])
myset.insert_many([{'name':'唐国强','King':'雍正'},\{'name':'陈建斌','King':'雍正'}])
myset.insert_one({'name':'郑少秋','King':'乾隆'})
myset.save({'_id':1,'name':'聂远','King':'乾隆'}) # 查找操作cursor = myset.find({},{'_id':0})# i为每个文档对应的字典
for i in cursor:print(i['name'],'--->',i['King'])myset = db.class1
# 操作符使用引号变为字符串
cursor = myset.find({'age':{'$gt':30}},{'_id':0})cursor.limit(2)#获取前两个文档
cursor.skip(2) #跳过前两个
cursor.sort([('age',-1),('name',1)]) #对游标内容排序for i in cursor:print(i)
print(cursor.next()) #获取下一个文档dic = {'$or':[{'age':{'$gt':35}},{'gender':'w'}]}
data = myset.find_one(dic,{'_id':0})
print(data)# 修改操作
myset.update({'name':'张国立'},\{'$set':{'king_name':'玄烨'}})myset.update({'name':'霍建华'},{'$set':{'King':'乾隆'}},\upsert = True)myset.update({'King':'乾隆'},\{'$set':{'king_name':'弘历'}},multi = True)myset.update_one({'King':'康熙'},\{'$set':{'king_name':'爱新觉罗玄烨'}})myset.update_many({'King':'雍正'},\{'$set':{'king_name':'胤禛'}})# 删除操作myset.remove({'King':'康熙'})
myset.remove({'King':'乾隆'},multi = False)#查找并删除
print(myset.find_one_and_delete({'King':'乾隆'}))#关闭连接
conn.close()

from pymongo import MongoClient #创建连接
conn = MongoClient('localhost',27017)#创建数据库对象
db = conn['stu'] myset = db['class1'] # 删除所有索引
myset.drop_indexes()# 创建索引
index = myset.ensure_index('name')
# 创建复合索引
index = myset.ensure_index([('name',-1),('age',1)])
print(index)# 删除一个索引
myset.drop_index('name_1')# 创建特殊索引
index = myset.ensure_index('name',name = "myIndex",\unique = True,sparse = True)# 查看集合中的索引
for i in myset.list_indexes():print(i)myset = db.class4 l = [{'$group':{'_id':'$King','num':{'$sum':1}}},{'$match':{'num':{'$gt':1}}}
]cursor = myset.aggregate(l)
for i in cursor:print(i)conn.close()

from pymongo import MongoClient
import bson.binary conn = MongoClient('localhost',27017)
db = conn.images
myset = db.img #存储
f = open('file.jpg','rb')#转换为mongodb的二进制数据存储形式
content = bson.binary.Binary(f.read())#插入到数据库
myset.insert({'filename':'file.jpg','data':content})#提取data = myset.find_one({'filename':'file.jpg'})#通过字典获取到数据库内容写入本地
with open(data['filename'],'wb') as f:f.write(data['data'])conn.close()

from pymongo import MongoClient
#pymongo绑定的模块
import gridfsconn = MongoClient('localhost',27017)
db = conn.grid #获取gridfs对象
#fs综合了fs.files  fs.chunks两个集合的属性内容
fs = gridfs.GridFS(db)#查文档生产游标
files = fs.find()#获取每一个文件的对象
for file in files:print(file.filename)if file.filename == 'file.jpg':with open(file.filename,'wb') as f:#从数据库读取出来data = file.read()#写入本地f.write(data)conn.close()