MongoDB学习【四】—pymongo操作mongodb数据库

伟强發表於 2019-7-18 10:00:00

MongoDB学习【四】—pymongo操作mongodb数据库

<h1 class="md-end-block md-heading">一、pymongodb的安装</h1>
Python 要连接 MongoDB 需要 MongoDB 驱动，这里我们使用 PyMongo 驱动来连接。
<h4 class="md-end-block md-heading">pip安装</h4>
pip 是一个通用的 Python 包管理工具，提供了对 Python 包的查找、下载、安装、卸载的功能。
安装 pymongo
<div class="cnblogs_code">
<pre>python3 -m pip3 install pymongo
python3 -m pip3 install pymongo==3.5.1# 指定版本安装</pre>
</div>
<h1 class="md-end-block md-heading">二、pymongodb操作mongodb数据库</h1>
<h2 class="md-end-block md-heading">1.连接数据库</h2>
通过pymongo连接mongodb数据库
<div class="cnblogs_code">
<pre>import pymongo
client = pymongo.MongoClient("127.0.0.1", 27017)
dblist = client.database_names()# 显示服务器上的所有数据库
# 新版本写法
dblist = client.list_database_names()

db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建
# print(db)# 数据库操作对象</pre>
</div>
<h2 class="md-end-block md-heading">2.文档的增加</h2>
集合中插入文档使用 insert_one() 方法，该方法的第一参数是字典 name => value 对。
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建
# print(db)# 数据库操作对象

"""增加"""
# 增加单条
mydict = {"name":"ryxiong","age":99}
res = db.stu.insert_one(mydict)
print(res.inserted_id)# 5d2ed8f865d6b8f1c494ff78 ObjectId对象，不是字符串

# 增加多条
mylist = [{"name":"black"},{"name":"white"}]
res = db.stu.insert_many(mylist)
print(res.inserted_ids)# </pre>
</div>
<h2 class="md-end-block md-heading">3.查询文档</h2>
MongoDB 中使用了 find 和 find_one 方法来查询集合中的数据，它类似于 SQL 中的 SELECT 语句。
<h4 class="md-end-block md-heading">查询一条数据</h4>
我们可以使用 find_one() 方法来查询集合中的一条数据。
<div class="cnblogs_code">
<pre>import pymongo
from bson import ObjectId

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建

res1 = db.stu.find_one({"name": "ryxiong"})
res2 = db.stu.find_one({"_id": ObjectId("5d2f0a052a8ee222edddb297")})# 将字符串的ObjectID转为对象后查询</pre>
</div>
<h4 class="md-end-block md-heading">查询集合中的所有数据或多条</h4>
find() 方法可以查询集合中的所有数据，类似 SQL 中的 SELECT * 操作。
<div class="cnblogs_code">
<pre>import pymongo
from bson import ObjectId

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建

# 查询多个
res3 = db.stu.find({})# 查询所有记录
res4 = db.stu.find({"name": "ryxiong"})# 查询符合条件的所有，生成器</pre>
</div>
<h4 class="md-end-block md-heading">高级查询</h4>
查询的条件语句中，我们还可以使用修饰符。
以下实例用于读取 name 字段中第一个字母 ASCII 值大于 "H" 的数据，大于的修饰符条件为 {"$gt": "H"}
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建

myquery = { "name": { "$gt": "H" } }
res = mycol.find(myquery)</pre>
</div>
<h4 class="md-end-block md-heading">正则表达式查询</h4>
我们还可以使用正则表达式作为修饰符。
正则表达式修饰符只用于搜索字符串的字段。
以下实例用于读取 name 字段中第一个字母为 "R" 的数据，正则表达式修饰符条件为 {"$regex": "^R"}
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建

myquery = { "name": { "$regex": "^R" } }
mydoc = mycol.find(myquery)
for x in mydoc:
print(x)</pre>
</div>
<h4 class="md-end-block md-heading">查询结果排序，跳过，截取条数</h4>
如果我们要对查询结果设置指定条数的记录可以使用 limit() 方法
对结果排序通过sort()方法，对结果忽略某些结果用skip
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建

# 1.查询结果的排序，跳过，和截取
sort_res = list(db.stu.find().sort("age", pymongo.DESCENDING))# 查询所有结果，并根据年龄的降序排序
skip_res = list(db.stu.find().skip(2))# 查询所有结果，并过滤掉前两条
limit_res = list(db.stu.find().limit(2))# 查询所有结果，并截取前两条显示

# 2.分页效果
pagination_res = list(db.stu.find().sort("age", pymongo.ASCENDING).limit(2).skip(2))</pre>
</div>
<h2 class="md-end-block md-heading">4.修改文档</h2>
在 MongoDB 中使用 update_one() 方法修改文档中的记录。该方法第一个参数为查询的条件，第二个参数为要修改的字段。
如果查找到的匹配数据多余一条，则只会修改第一条。
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]# 连接数据库，获取库，如果库名存在，则使用，不存在创建

"""修改"""
# 方式一
# 查询到直接更新设置值
res = db.stu.update_one({"name":"ryxiong"},{"$set":{"age":222}})
print(res.modified_count)

# 方式二.1
# 查到记录，在字典中添加值
res = db.stu.find_one({"name":"ryxiong"})
res["gender"] = "male"
res["hobby"] = "photography"
res["name"] = "ryxiong1"
# 将值更新到记录中去
res = db.stu.update_one({"name":"ryxiong"},{"$set":res})
print(res.modified_count)</pre>
</div>
<h2 class="md-end-block md-heading">5.删除数据</h2>
<h4 class="md-end-block md-heading">删除单挑</h4>
使用 delete_one() 方法来删除一个文档，该方法第一个参数为查询对象，指定要删除哪些数据
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]

del_res1 = db.stu.delete_one({"name": "ryxiong"})# 删除满足条件的结果中的第一条
print(del_res1.deleted_count)</pre>
</div>
<h4 class="md-end-block md-heading">删除多条</h4>
使用 delete_many() 方法来删除多个文档，该方法第一个参数为查询对象，指定要删除哪些数据。
<div class="cnblogs_code">
<pre>import pymongo

client = pymongo.MongoClient("127.0.0.1", 27017)
db = client["practice"]

query = { "name": {"$regex": "^F"} }
del_res = db.stu.delete_many(myquery)# 删除满足条件的多条
print(del_res.deleted_count)

# 删除所有
del_res = db.stu.delete_many({})</pre>
</div>
 

</div>
<div id="MySignature" role="contentinfo">
衣带渐宽终不悔，为伊消得人憔悴！ 
来源：https://www.cnblogs.com/ryxiong-blog/p/11205303.html

頁: [1]

琼殿技术论坛's Archiver

MongoDB学习【四】—pymongo操作mongodb数据库