孤荷凌寒自学python第五十九天尝试使用python来读访问远端MongoDb数据服务
(完整学习过程屏幕记录视频地址在文末)
今天是学习mongoDB数据库的第五天。今天的感觉是,mongoDB数据库我似乎根本就很难掌控呵!
一、首先系统学习了读写mongoDB数据库的方法
以下笔记来自官方文档整理:
(官方文档:https://api.mongodb.com/python/current/index.html )
(一)指定数据库
MongoDB中还分为一个个数据库,我们接下来的一步就是指定要操作哪个数据库,在这里我以test数据库为例进行说明,所以下一步我们需要在程序中指定要使用的数据库。
db = client.test
调用client的test属性即可返回test数据库,当然也可以这样来指定:
db = client['test']
两种方式是等价的。
(二)指定集合
MongoDB的每个数据库又包含了许多集合Collection,也就类似与关系型数据库中的表,下一步我们需要指定要操作的集合,在这里我们指定一个集合名称为students,学生集合。还是和指定数据库类似,指定集合也有两种方式。
collection = db.students
#collection = db['students']
(三)插入数据
接下来我们便可以进行数据插入了,对于students这个Collection,我们新建一条学生数据,以字典的形式表示:
student = {
'id': '20170101',
'name': 'Jordan',
'age': 20,
'gender': 'male'
}
在这里我们指定了学生的学号、姓名、年龄和性别,然后接下来直接调用collection的insert()方法即可插入数据。
result = collection.insert(student)
print(result)
在MongoDB中,每条数据其实都有一个_id属性来唯一标识,如果没有显式指明_id,MongoDB会自动产生一个ObjectId类型的_id属性。insert()方法会在执行后返回的_id值。
运行结果:
5932a68615c2606814c91f3d
当然我们也可以同时插入多条数据,只需要以列表形式传递即可,示例如下:
student1 = {
'id': '20170101',
'name': 'Jordan',
'age': 20,
'gender': 'male'
}
student2 = {
'id': '20170202',
'name': 'Mike',
'age': 21,
'gender': 'male'
}
result = collection.insert([student1, student2])
print(result)
返回的结果是对应的_id的集合,运行结果:
[ObjectId('5932a80115c2606a59e8a048'), ObjectId('5932a80115c2606a59e8a049')]
实际上在PyMongo 3.X版本中,insert()方法官方已经不推荐使用了,当然继续使用也没有什么问题,官方推荐使用insert_one()和insert_many()方法将插入单条和多条记录分开。
student = {
'id': '20170101',
'name': 'Jordan',
'age': 20,
'gender': 'male'
}
result = collection.insert_one(student)
print(result)
print(result.inserted_id)
运行结果:
<pymongo.results.InsertOneResult object at 0x10d68b558>
5932ab0f15c2606f0c1cf6c5
返回结果和insert()方法不同,这次返回的是InsertOneResult对象,我们可以调用其inserted_id属性获取_id。
对于insert_many()方法,我们可以将数据以列表形式传递即可,示例如下:
student1 = {
'id': '20170101',
'name': 'Jordan',
'age': 20,
'gender': 'male'
}
student2 = {
'id': '20170202',
'name': 'Mike',
'age': 21,
'gender': 'male'
}
result = collection.insert_many([student1, student2])
print(result)
print(result.inserted_ids)
insert_many()方法返回的类型是InsertManyResult,调用inserted_ids属性可以获取插入数据的_id列表,运行结果:
<pymongo.results.InsertManyResult object at 0x101dea558>
[ObjectId('5932abf415c2607083d3b2ac'), ObjectId('5932abf415c2607083d3b2ad')]
(四)查询记录
插入数据后我们可以利用find_one()或find()方法进行查询,find_one()查询得到是单个结果,find()则返回多个结果。
result = collection.find_one({'name': 'Mike'})
print(type(result))
print(result)
在这里我们查询name为Mike的数据,它的返回结果是字典类型,运行结果:
<class 'dict'>
{'_id': ObjectId('5932a80115c2606a59e8a049'), 'id': '20170202', 'name': 'Mike', 'age': 21, 'gender': 'male'}
可以发现它多了一个_id属性,这就是MongoDB在插入的过程中自动添加的。
我们也可以直接根据ObjectId来查询,这里需要使用bson库里面的ObjectId。
from bson.objectid import ObjectId
result = collection.find_one({'_id': ObjectId('593278c115c2602667ec6bae')})
print(result)
其查询结果依然是字典类型,运行结果:
{'_id': ObjectId('593278c115c2602667ec6bae'), 'id': '20170101', 'name': 'Jordan', 'age': 20, 'gender': 'male'}
当然如果查询结果不存在则会返回None。
对于多条数据的查询,我们可以使用find()方法,例如在这里查找年龄为20的数据,示例如下:
results = collection.find({'age': 20})
print(results)
for result in results:
print(result)
运行结果:
<pymongo.cursor.Cursor object at 0x1032d5128>
{'_id': ObjectId('593278c115c2602667ec6bae'), 'id': '20170101', 'name': 'Jordan', 'age': 20, 'gender': 'male'}
{'_id': ObjectId('593278c815c2602678bb2b8d'), 'id': '20170102', 'name': 'Kevin', 'age': 20, 'gender': 'male'}
{'_id': ObjectId('593278d815c260269d7645a8'), 'id': '20170103', 'name': 'Harden', 'age': 20, 'gender': 'male'}
返回结果是Cursor类型,相当于一个生成器,我们需要遍历取到所有的结果,每一个结果都是字典类型。
如果要查询年龄大于20的数据,则写法如下:
results = collection.find({'age': {'$gt': 20}})
在这里查询的条件键值已经不是单纯的数字了,而是一个字典,其键名为比较符号$gt,意思是大于,键值为20,这样便可以查询出所有年龄大于20的数据。
比较符号的含义归纳:
$lt 小于 示例:{'age': {'$lt': 20}}
$gt 大于 示例:{'age': {'$gt': 20}}
$lte 小于等于 示例:{'age': {'$lte': 20}}
$gte 大于等于 示例: {'age': {'$gte': 20}}
$ne 不等于 示例: {'age': {'$ne': 20}}
$in 在范围内 示例: {'age': {'$in': [20, 23]}}
$nin 不在范围内 示例:{'age': {'$nin': [20, 23]}}
二、根据上面的系统学习,感觉很轻松搞定,于是开始测试
```
from pymongo import MongoClient
import _mty
import _mf
import _mre
import _cl
def msgbox(info,titletext='孤荷凌寒的对话框QQ578652607',style=0,isShowErrMsg=False):
return _mty.msgboxGhlh(info,titletext,style,isShowErrMsg)
def secondConnect():
#--指明数据库服务器的地址与端口号:
stru=_mf.readAllTextFromTxtFileGhlh('u.txt')
strp=_mf.readAllTextFromTxtFileGhlh('p.txt')
strhost='mongodb://' + stru + ':' + strp + '@cluster0-zr7xj.mongodb.net/?authMechanism=SCRAM-SHA-256'
#--建立连接
client=MongoClient(strhost,tz_aware=True,connect=True)
#client=MongoClient("cluster0-zr7xj.mongodb.net",username=stru,password=strp,authMechanism='SCRAM-SHA-256',connect=False)
#-- 获取数据库的命名标识
#print(client.admin.command('ismaster'))
db2=client.ghlhfirst
#--获取其中的一个集合对象
jh=db2.ghlhone
#msgbox(str(jh.info))
#--查询这个集合其中的记录
print(jh.find_one({"姓名":"张三"}))
secondConnect()
```
每次前面都执行正常,总是到了:
print(jh.find_one({"姓名":"张三"}))
这句时要等大概一分钟,然后报错:
pymongo.errors.ServerSelectionTimeoutError: cluster0-zr7xj.mongodb.net:27017: [Errno 11001] getaddrinfo failed
于是我就开始不停的搜索,前后花了至少3个多小时,反复测试,到底为什么连接上了却不能读出(查询)出任何内容来呢,真的弄得自己筋疲力尽。
后来想到是不是一开始就没有连接上呢?
经过认真思考,发现还真的是一开始就没有连接上MongoDB的远端服务器,这才明白昨天并没有根本上解决问题!!
真是个莫大的乌龙!
原来前面的语句只是将连接信息等存储起来罢了(详细见Mongo_Client.py文件(就是Pip安装的那个pymongodb模块中的文件))
直到:
jh.find_one({"姓名":"张三"})
这一语句时才真正去连接服务器,这就是为什么这个语句要执行等待一分钟左右才最终报错的原因。真是个大坑。
这意味着,mongoDB远端服务器其实根本就没有被连接上,始终没有解决问题。
决定明天只好开始布置本地MongoDB数据库服务了。
因为学习时间有限,今天的学习只能搁到这儿,还恳请高手能够指点迷津,万分感激。
——————————
今天整理的学习笔记完成,最后例行说明下我的自学思路:
根据过去多年我自学各种编程语言的经历,认为只有真正体验式,解决实际问题式的学习才会有真正的效果,即让学习实际发生。在2004年的时候我开始在一个乡村小学自学电脑 并学习vb6编程语言,没有学习同伴,也没有高师在上,甚至电脑都是孤岛(乡村那时还没有网络),有的只是一本旧书,在痛苦的自学摸索中,我找到适应自己零基础的学习方法:首先是每读书的一小节就作相应的手写笔记,第二步就是上机测试每一个笔记内容是否实现,其中会发现书中讲的其实有出入或错误,第三步就是在上机测试之后,将笔记改为电子版,形成最终的修订好的正确无误的学习笔记 。
通过反复尝试错误,在那个没有分享与交流的黑暗时期我摸黑学会了VB6,尔后接触了其它语言,也曾听过付费视频课程,结果发现也许自己学历果然太低,就算是零基础的入门课程,其实也难以跟上进度,讲师的教学多数出现对初学者的实际情况并不了解的情况,况且学习者的个体也存在差异呢?当然更可怕的是收费课程的价格往往是自己难以承受的。
于是我的所有编程学习都改为了自学,继续自己的三步学习笔记法的学习之路。
当然自学的最大问题是会走那么多的弯路,没有导师直接输入式的教学来得直接,好在网络给我们带来无限搜索的机会,大家在网络上的学习日志带给我们共享交流的机会,而QQ群等交流平台、网络社区的成立,我们可以一起自学,互相批评交流,也可以获得更有效,更自主的自学成果。
于是我以人生已过半的年龄,决定继续我的编程自学之路,开始学习python,只希望与大家共同交流,一个人的独行是可怕的,只有一群人的共同前进才是有希望的。
诚挚期待您的交流分享批评指点!欢迎联系我加入从零开始的自学联盟。
这个时代互联网成为了一种基础设施的存在,于是本来在孤独学习之路上的我们变得不再孤独,因为网络就是一个新的客厅,我们时刻都可以进行沙龙活动。
非常乐意能与大家一起交流自己自学心得和发现,更希望大家能够对我学习过程中的错误给予指点——是的,这样我就能有许多免费的高师了——这也是分享时代,社区时代带来的好福利,我相信大家会的,是吧!
根据完全共享的精神,开源互助的理念,我的个人自学录制过程是全部按4K高清视频录制的,从手写笔记到验证手写笔记的上机操作过程全程录制,但因为4K高清文件太大均超过5G以上,所以无法上传至网络,如有需要可联系我QQ578652607对传,乐意分享。上传分享到百度网盘的只是压缩后的720P的视频。
我的学习过程录像百度盘地址分享如下:(清晰度:1280x720)
链接:https://pan.baidu.com/s/1pxsntZ5bMRs1vr9uHSW7Fg
提取码:u6mu
喜马拉雅语音笔记:
https://www.ximalaya.com/keji/19103006/150385573
bilibili: