Python连接MongoDB数据库

Python操作MongoDB

pip install pymongo

一 导入 pymongo

from pymongo import MongoClient

二 链接服务器 端口号 27017

con = MongoClient("localhost")con = MongoClient("localhost",port=27017)

三 选择数据库

db = con.数据库名称选择collection = db.collection_name

四 INSERT 添加数据

(1) 插入一条文档

db.集合名.insert(文档) #返回ID

(2) 插入多条文档

db.集合名.insert([{文档1},{文档2}...]) #以列表的形式 返回ID

(3) 3.X以后的建议

insert_one()
返回对象

obj.inserted_id

insert_many()
obj.inserted_ids

五 FIND 查询

(1) 查询所有

db.collection.find()返回对象 可以使用next方法进行取值

(2) 查询一条数据

db.collection.find_one()将结果直接进行返回

(3) 带条件的查询

db.collection.find({条件})

(4) 带id查询

from bson.objectid import ObjectId

res = db.user.find({'_id': ObjectId('5a601623b961661d6c69df83')})

(5) 模糊查询

导入正则模块import re

res = db.user.find({"name":re.compile("张")})

六 sort limit skip count

(1) sort 排序升序

res = db.user.find().sort("age",1)

降序

res = db.user.find().sort("age",-1)

(2) limit 取值

db.collection.find().limit(num)

res = db.user.find().sort("age",-1).limit(2)

(3) skip 跳过

db.collection.find().skip()

(4) count 统计

cb.collection.find().count()

七 修改

(1) unpdate 修改

db.collection.update(条件,{"$set":{}})db.collection.update(条件,{"$inc":{}})

(2) update_one 修改一条

db.collection.update_one({"
d7e5
name":"张三"},{"$set":{"age":18}})

(3) update_many 修改多条

db.collection.update_one({"name":"张三"},{"$set":{"age":18}})

获取匹配条数和修改条数

obj.matched_count 匹配条数obj.modified_count 修改条数

八 REMOVE 删除

(1) 带条件的删除

db.collection.remove({条件})

db.user.remove({"age":29})

(2) 删除全部

db.collection.remove()

(3) delete_one 删除匹配到的第一条数据

db.collection.delete_one()

(3) delete_many 删除匹配到的第一条数据

db.collection.delete_many()

(4) 获取新版本删除 数据的条数

obj.deleted_count

九 关闭数据库链接

con.close()