首先引入包:
pip install pymongo
需要用到如下对象:
MongoClient对象:用于与MongoDB服务器建立连接
client=MongoClient(‘主机ip‘,端口)
DataBase对象:对应着MongoDB中的数据库
db=client.数据库名称
Collection对象:对应着MongoDB中的集合
col=db.集合名称
Cursor对象:查询方法find()返回的对象,用于进行多行数据的遍历
当调用集合对象的find()方法时,会返回Cursor对象
结合for...in...遍历cursor对象
主要方法:
insert_one:加入一条文档对象
insert_many:加入多条文档对象
find_one:查找一条文档对象
find:查找多条文档对象
update_one:更新一条文档对象
update_many:更新多条文档对象
delete_one:删除一条文档对象
delete_many:删除多条文档对象
插入方法:
insert_one() 传入一个字典,表示插入一个文档
insert_many() 传入一个列表,列表的元素为字典,插入多条文档
1 from pymongo import *
2 ‘‘‘
3 插入方法:
4 insert_one() 传入一个字典,表示插入一个文档
5 insert_many() 传入一个列表,列表的元素为字典,插入多条文档
6 ‘‘‘
7 def insert():
8 try:
9 # 1 创建连接对象
10 client = MongoClient(host="localhost", port=27017)
11 # 2 获取数据库,
12 # 如果这个数据库不存在,就在内存中虚拟创建
13 # 当在库里创建集合的时候,就会在物理真实创建这个数据库
14 db = client.demo # 使用demo数据库
15 # 向stu集合插入数据
16 # 插入一条
17 db.stu.insert_one({"name": "zs", "age": 20})
18 # 插入多条
19 db.stu.insert_many([{"name": 1}, {"name": 2}])
20 except Exception as e:
21 print(e)
22
23
24 if __name__ == ‘__main__‘:
25 insert()
查询方法:
find_one()返回满足条件的文档集中第一条数据,类型为字典
如果没有查询结果返回None
方法find()返回满足条件的所有文档,类型为Cursor对象,可以使用for...in遍历,每项为字典对象
如果没有查询结果返一个空的Cursor对象
1 from pymongo import *
2 ‘‘‘
3 查询方法:
4 find_one()返回满足条件的文档集中第一条数据,类型为字典
5 如果没有查询结果返回None
6 方法find()返回满足条件的所有文档,类型为Cursor对象,可以使用for...in遍历,每项为字典对象
7 如果没有查询结果返一个空的Cursor对象
8 ‘‘‘
9 def select():
10 try:
11 # 1 创建连接对象
12 client = MongoClient(host="localhost", port=27017)
13 # 2 获取数据库,
14 # 如果这个数据库不存在,就在内存中虚拟创建
15 # 当在库里创建集合的时候,就会在物理真实创建这个数据库
16 db = client.demo # 使用demo数据库
17 # 从stu查询数据
18 # 查询一条,返回一个字典,如果没有结果返回None
19 res = db.stu.find_one({"age": 18})
20 print(res)
21 # 查询全部结果,返回一个Cursor可迭代对象,每一个元素是字典
22 # 如果没有查询结果会返回一个空的Cursor对象
23 res = db.stu.find({"age": {"$gt": 18}})
24 print(res)
25 except Exception as e:
26 print(e)
27
28
29 if __name__ == ‘__main__‘:
30 select()
修改方法:
update_one()修改满足条件的文档集中的第一条文档
update_many()修改满足条件的文档集中的所有文档
注意:使用$set操作符修改特定属性的值,否则会修改整个文档
1 from pymongo import *
2 ‘‘‘
3 修改方法:
4 update_one()修改满足条件的文档集中的第一条文档
5 update_many()修改满足条件的文档集中的所有文档
6 注意:使用$set操作符修改特定属性的值,否则会修改整个文档
7 ‘‘‘
8 def update():
9 try:
10 # 1 创建连接对象
11 client = MongoClient(host="localhost", port=27017)
12 # 2 获取数据库,
13 # 如果这个数据库不存在,就在内存中虚拟创建
14 # 当在库里创建集合的时候,就会在物理真实创建这个数据库
15 db = client.demo # 使用demo数据库
16 # 修改数据
17 # 修改第一条符合条件的数据,传入条件和修改结果
18 db.stu.update_one({"age": 18},{"$set": {"age": 100}}) # 把年龄是18的第一条年龄改成100
19 # 所有符合条件数据都修改
20 # db.stu.update_many({"age": 18},{"$set": {"age": 100}}) # 年龄18的所有数据年龄改成100
21 except Exception as e:
22 print(e)
23
24
25 if __name__ == ‘__main__‘:
26 update()
删除方法:
delete_one()删除满足条件的文档集中第一条文档
delete_many()删除满足条件的所有文档
注意:使用$set操作符修改特定属性的值,否则会修改整个文档
1 from pymongo import *
2 ‘‘‘
3 删除方法:
4 delete_one()删除满足条件的文档集中第一条文档
5 delete_many()删除满足条件的所有文档
6 注意:使用$set操作符修改特定属性的值,否则会修改整个文档
7 ‘‘‘
8 def delete():
9 try:
10 # 1 创建连接对象
11 client = MongoClient(host="localhost", port=27017)
12 # 2 获取数据库,
13 # 如果这个数据库不存在,就在内存中虚拟创建
14 # 当在库里创建集合的时候,就会在物理真实创建这个数据库
15 db = client.demo # 使用demo数据库
16 # 修改数据
17 # 修改第一条符合条件的文档删除
18 db.stu.delete_one({"age": 18}) # 把年龄是18的第一条文档删除
19 # 所有符合条件数据都删除
20 db.stu.delete_many({"age": 18}) # 年龄18的所有文档删除
21 except Exception as e:
22 print(e)
23
24
25 if __name__ == ‘__main__‘:
26 delete()
案例:
使用python向集合t3中插入1000条文档,文档的属性包括_id、name
_id的值为0、1、2、3...999
name的值为‘py0‘、‘py1‘...
查询显示出_id为100的整倍数的文档,如100、200、300...,并将name输出
1 import pymongo
2 if __name__ == ‘__main__‘:
3 try:
4 # 1 获得连接对象
5 client = pymongo.MongoClient(host="localhost", port=27017)
6 # 2 获取数据库
7 db = client.demo
8 # 3 执行业务逻辑 数据库操作
9 # 插入1000条数据
10
11 for id in range(0,1000):
12 db.t3.insert_one({"_id": id, "name": "py%s"% id})
13
14 # 取出符合条件的数据
15 match = {
16 "$where": "function(){return this._id%100 == 0 }",
17 }
18 res = db.t3.find(match, {"_id": 0, "name": 1})
19 for info in res:
20 print(info)
21
22
23 except Exception as e:
24 print(e)