mongodb-API

茅山道长 發表於 2019-12-22 17:03:00

<h2 class="md-end-block md-heading">mongodb-API</h2>
<h3 class="md-end-block md-heading">连接mongo（该操作一般在初始化时就执行）</h3>
出现由于目标计算机积极拒绝，无法连接的错误时
<ol class="ol-list" start="">
<li class="md-list-item md-focus-container">
查看是否进行虚拟机的端口转发
</li>
<li class="md-list-item">
将 /etc/ 目录下的mongodb.conf 文件 bind_ip修改为 0.0.0.0, 表示任何主机都可以访问
</li>
<li class="md-list-item">
重启服务 service mongodb restart
</li>
</ol>
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm"> import pymongo    # 1.连接mongodb  client = pymongo.MongoClient(host='127.0.0.1', port=27017)  # client = pymongo.MongoClient('mongodb://127.0.0.1:27017/') # 另一种连接方式    # 2.指定数据库(没有会自动创建)  db = client['db_spider']    # 3.指定集合(没有就自动创建)  collection = db['student']# 这样就声明了一个Collection对象  </pre>
 
<h3 class="md-end-block md-heading">插入数据</h3>
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> # 4.插入数据  官方推荐使用insert_one()插入单条数据， insert_many()插入多条文档  data = {      'name': '夜阑',      'sex': '男',      '年龄': 20  }    res = collection.insert_one(data)  print(res) # 返回InsertOneResult 对象  print(res.inserted_id) # 调用其inserted_id属性获取_id（每条数据都有一个id属性来唯一标识）    data2 = {      'name': '丹丹',      'sex': '女',      '年龄': 18  }  collection.insert_many([data, data2]) # 多条数据以列表的形式传递  </pre>
 
<h3 class="md-end-block md-heading">查询</h3>
<h5 class="md-end-block md-heading">基本使用</h5>
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> from pprint import pprint    # 查询一条;可指定条件（是一个字典）  result = collection.find_one()    # 查看集合中的全部文档  result1 = collection.find() # 返回Cursor类型，相当于一个生成器  pprint(list(result1))  for i in result1:     # 将该对象通过for遍历      print(i)    # 当然我们也可以通过过ObjectId来查询，使用bson库里面的objectid:  from bson.objectid import ObjectId  res = collection.find_one({'_id': ObjectId('5d1b2df85a11e06dab918ec7')})    # 条件查询  collection.find({'name': 'yelan'})  resu = collection.find({'age': {'$gt': 20}}) # 查找年龄大于20的  </pre>
 
<h5 class="md-end-block md-heading">噩梦条件</h5>
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> and条件 {$and: [{expression1}, {expression2}, ...] }  or 条件 {$or: [{expression1}, {expression2}, ...] }  and 和or混用  db.table.find({$or:[{$and:[{sex:'女'}, {age:18}]},{$and:[{sex:'男'}, {age:{$gt:18}}]}]})  </pre>
<h5 class="md-end-block md-heading">比较符号</h5>
<table class="md-table">
<thead>
<tr class="md-end-block"><th>操作符</th><th>描述</th><th>示例</th></tr>
</thead>
<tbody>
<tr class="md-end-block">
<td>$lt</td>
<td>小于 less than</td>
<td>{'age': {'$lt': 24}}</td>
</tr>
<tr class="md-end-block">
<td>$gt</td>
<td>大于 greater than</td>
<td>{'age': {'$gt': 18}}</td>
</tr>
<tr class="md-end-block">
<td>$lte</td>
<td>小于等于 less than or equal to</td>
<td>{'age': {'$lte': 20}}</td>
</tr>
<tr class="md-end-block">
<td>$gte</td>
<td>大于等于 great than or equal to</td>
<td>{'age': {'$gte': 18}}</td>
</tr>
<tr class="md-end-block">
<td>$ne</td>
<td>不等于 not equal to</td>
<td>{'age': {'$ne': 20}}</td>
</tr>
<tr class="md-end-block">
<td>$in</td>
<td>在范围内</td>
<td>{'age': {'$in': }}</td>
</tr>
<tr class="md-end-block">
<td>$nin</td>
<td>不在范围内</td>
<td>{'age': {'$nin': }}</td>
</tr>
</tbody>
</table>
<h5 class="md-end-block md-heading">过滤条件</h5>
支持正则匹配查询
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> res = collection.find({'name': {'$regex': '^y.*'}}) # 查询姓名以y开头的</pre>
 
find()方法支持链式的调用；或者说Collection对象的查询方法支持链式的调用
<h4 class="md-end-block md-heading">计数</h4>
调用count()方法，返回查询结果有多少条数据
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> count = collection.find().count()</pre>
<h4 class="md-end-block md-heading">排序</h4>
调用sort()方法，并在其中传入排序的字段及升降序标志
pymongo.ASCENGING指定升序 || pymongo.DESCENGING指定降序
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> collection.find().sort('name', pymongo.ASCENGING) # 对查询结果升序排列</pre>
<h4 class="md-end-block md-heading">限制</h4>
limit()方法，限制查询的结果。该方法接受一个int型
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> collection.find().sort('name', pymongo.ASCENGING).limit(3)# 截取结果的前3个</pre>
 
<h3 class="md-end-block md-heading">更新</h3>
使用 update()_one 方法，修改一条，指定更新的条件和更新后的数据即可
<pre class="md-fences md-end-block md-fences-with-lineno ty-contain-cm modeLoaded"> condition = {'name': 'yelan'}  res = collection.update_one(condition, {'$set': {'name': 'wang'}})  print(res)# 返回updateResult类型，该类型有以下属性  print(res.matched_count, res.modified_count) # 属性：获取匹配的数据条数；影响的数据条数（被修改的）        # 当然也可以先查找，然后以字典的赋值的方式修改字段即可。如：  student = collection.find_one(condition)  student['name'] = 'wang'  </pre>
update_many()方法，修改满足条件的多条数据
假设我要对某文档中年龄大于18岁的所有成员+1岁。使用操作符：'$inc' 自增1
<pre class="md-fences mock-cm md-end-block md-fences-with-lineno">condition = {'age': {'$gt': 18}}
result = collection.update_many(condition, {'$inc': {'age': 1}})
</pre>
 
<h3 class="md-end-block md-heading">删除</h3>
remove()方法指定删除的条件即可，符合条件的数据都会删除
<pre class="md-fences mock-cm md-end-block md-fences-with-lineno">res = collection.remove({'name': 'yelan'})
res会返回删除的数量
</pre>
推荐使用 delete_one()和delete_many()方法分别删除满足条件的一条和多条数据
<pre class="md-fences mock-cm md-end-block md-fences-with-lineno">collection.delete_one({'age': 20})

# 删除年龄小于18或者年龄大于60的多条数据
collection.delete_many({$or: [{'age': {'$lt': 18}}, {'age': {'$gt': 60}}]})
</pre>
 
<h4 class="md-end-block md-heading">其他操作</h4>
pymongo还提供了一些组合方法，如find_one_delete()、find_one_update()等，查找后删除、查找后更新。
http://api.mongodb.com/python/curent/api/pymongo/collection.html
 
<h4 class="md-end-block md-heading">自定义封装</h4>
<pre class="md-fences mock-cm md-end-block md-fences-with-lineno">class MyMongodb:

def __init__(self, db, collection): # 初始化传入使用的数据库，集合
 self.client = pymongo.MongoClient(host='127.0.0.1', port=27017) # 初始化时连接mongo
 self.db = self.client # 初始化时进入使用的数据库
 self.my_col = self.db # 初始化时进入集合操作

def insert(self, dict, only_one=True):
 if only_one:
 self.my_col.insert_one(dict)
 else:
 self.my_col.insert_many(dict)

def find(self, find_one=True, ):
 if find_one:
 result_one = self.my_col.find_one()
 pprint(result_one)
 # elif find_one and condition:
 # result_con = self.my_col.find_one()
 # pprint(result_con)
 else:
 result_many = self.my_col.find()
 for u in result_many:
 print(u)

def update(self, data, new_data, update_one=True):
 if update_one:
 self.my_col.update_one(data, {'$set': new_data})
 else:
 self.my_col.update_many(data, {'$set': new_data})

def remove(self, data, delete_one=True):
 if delete_one:
 self.my_col.delete_one(data)
 else:
 self.my_col.delete_many(data)

if __name__ == '__main__': # 主程序入口
my_db = MyMongodb('test_db', 'stu') # 传入的数据库和集合，有则使用，无则创建
my_db.insert({'name': '夜阑', 'sex': '男', '年龄': 20})# 1.插入一条文档
my_db.insert([
 {'name': '夜阑', 'sex': '男', 'age': 18},
 {'name': 'liu', 'sex': '男', 'age': 24},
 {'name': 'dan', 'sex': '女', 'age': 24},
], only_one=False) # 插入多条数据

my_db.find(find_one=False) # 查看多条，默认查看一条

my_db.update({'name': '夜阑'}, {'name': '小红', 'age': 22}) # 更新一条
my_db.update({'name': '夜阑'}, {'name': '小红', 'age': 22}, update_one=False) # 更新满足条件的多条数据
my_db.remove(({'name': 'liu'}), delete_one=False) # 删除指定的多条

</pre> 
来源：https://www.cnblogs.com/yelan5222/p/12080292.html

頁: [1]

琼殿技术论坛's Archiver

mongodb-API