1. 程式人生 > >孤荷淩寒自學python第六十六天學習mongoDB的基本操作並進行簡單封裝5

孤荷淩寒自學python第六十六天學習mongoDB的基本操作並進行簡單封裝5

isf 過程 文件 入門 大於等於 txt 行處理 記憶 實踐

孤荷淩寒自學python第六十六天學習mongoDB的基本操作並進行簡單封裝5並學習權限設置

(完整學習過程屏幕記錄視頻地址在文末)

今天是學習mongoDB數據庫的第十二天。

今天繼續學習mongoDB的簡單操作,並繼續對一些可能反復經常使用的操作進行簡單的封裝。同時通過搜索了解了如何對本地Mongo數據庫進行權限設置(沒有實踐本地數據庫的用戶權限設置。)

按個人規劃,今天是初步了解學習MongoDb數據庫的最後一個學習日,後續將在真正使用此數據庫時,再對其進行深入研究。

一、今天完成了兩個可能會經常使用的函數。

```

#將傳入的cursor對象中的全部記錄的_id值提取出來存入一個列表中返回

def getAll_idInCurSorGhlh(cursor,isShowMsg=False):

‘‘‘

將傳入的cursor對象中的全部記錄的_id值提取出來存入一個列表中返回

‘‘‘

lstR=[]

try:

for i in cursor:

strid=i.get(‘_id‘)

if strid!=None:

lstR.append(strid)

return lstR

#---------------------------------------------------------------------------

except Exception as e:

mmongoErrString=‘獲取mongoDb數據記錄集(cursor)的所有記錄中的_id值列表時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

lstR=[]

return lstR

else:

pass

finally:

pass

#將只有一個字段篩選條件的查詢結果的所有記錄中的_id值提出出來存入一個列表中返回

def findDataAndReturn_idListGhlh(objjh,strkeynm,value,strbijiao=‘‘,isShowMsg=False):

‘‘‘

將只有一個字段篩選條件的查詢結果的所有記錄中的_id值提出出來存入一個列表中返回

‘‘‘

try:

data=findDataGhlh(objjh,strkeynm,value,strbijiao,False,isShowMsg)

return getAll_idInCurSorGhlh(data,isShowMsg)

#-------------------------------------------

except Exception as e:

mmongoErrString=‘獲取mongoDb數據庫中符合單一篩選條件的所有記錄中的_id值列表時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

lstR=[]

return lstR

else:

pass

finally:

pass

```

這所以要創建這兩個函數,我的設想是,因為在修改和查詢時使用標識操作字符加到字典對象中,由於mongoDB的標識操作關鍵字特別多,不好記憶,容易寫錯,因此,如果我能分散這些步驟,當然這會降低程序的執行效率,但更便於理解 ,相比非常復雜且書寫得很長的各種嵌套的字典對象來說,更不容易出錯。

這兩個函數的核心理念是,因為任何一條記錄(就是document對象)其中唯一標識的字段是【_id】,所以,為了簡化操作,把所有查詢得到的記錄集或其它方法得到的記錄集,都歸集到只使用這個唯一標識的字段【_id】來進行識別和定位,那麽將大大減輕理解難度和書寫復雜度,當然會降低執行效率。

這是我的想法。

二、今天的測試文檔

【ceshi.py】

```

from pymongo import MongoClient

import datetime

import _mty

import _mf

import _mre

import _cl

import _mmongo

def msgbox(info,titletext=‘孤荷淩寒的對話框QQ578652607‘,style=0,isShowErrMsg=False):

return _mty.msgboxGhlh(info,titletext,style,isShowErrMsg)

def thirdConnect():

#--獲取授權用戶和密碼:

#stru=_mf.readAllTextFromTxtFileGhlh(‘u.txt‘)

#strp=_mf.readAllTextFromTxtFileGhlh(‘p.txt‘)

#得到連接對象

client=_mmongo.conMongoDbGhlh("localhost")

#-- 獲取數據庫的命名標識

db=client.ghlhsecond

#--獲取其中的一個集合對象

jh=db.onejh

#----添加記錄

dicA={

u‘姓名‘:u‘張三3‘,

u‘性別‘:u‘男‘,

u‘年齡‘:36,

u‘婚否‘:True

}

dicB={

u‘姓名‘:u‘李四3‘,

u‘性別‘:u‘女‘,

u‘年齡‘:32,

u‘婚否‘:False

}

lstA=[dicA,dicB]

#------

#isok=_mmongo.addNewDataGhlh(jh,lstA)

#msgbox(str(isok))

#刪除記錄的操作

#isok=_mmongo.delDataGhlh(jh,‘體重‘,98,">=")

#msgbox(str(isok))

#--查詢這個集合其中的記錄

#data=jh.find()

#for i in data:

# msgbox(str(i))

#data=_mmongo.findDataGhlh(jh,‘姓名‘,‘張三.?‘,‘正則‘,True,True)

#print(data)

#for i in data:

# msgbox(str(i))

#lstA=_mmongo.getAll_idInCurSorGhlh(data)

lstA=_mmongo.findDataAndReturn_idListGhlh(jh,‘姓名‘,‘張三.?‘,‘正則‘)

for i in lstA:

msgbox(i)

#data=_mmongo.modifyValueGhlh(jh,‘姓名‘,‘李四.?‘,{‘體重‘:98,‘婚否‘:True},‘正則‘,False,True)

#print(data)

#for i in data:

# msgbox(str(i))

thirdConnect()

```

三、今天修改了自定義的模塊中存放自己簡單封裝的一些函數等:

【_mmongo.py】

```

#!/usr/bin/env python3

# -*- coding: utf-8 -*-

#此模塊用於封閉mongodb數據庫操作的一些方法

import string

import pymongo

import _mty

import _cl #常用常量模塊

import _mre

mmongoErrString=‘‘ #供其它模塊使用的全局變量了,實時保存了各函數執行時的錯誤信息

def msgbox(info,titletext=‘孤荷淩寒的mongodb模塊對話框QQ578652607‘,style=0,isShowErrMsg=False):

return _mty.msgboxGhlh(info,titletext,style,isShowErrMsg)

#獲取一個針對mongodb數據庫服務的client對象的方法函數

def conMongoDbGhlh(serveraddress,strusername=‘‘,strpassword=‘‘,strauthMechanism=‘SCRAM-SHA-1‘,isconnect=False,isShowMsg=False):

‘‘‘

根據傳遞進函數的mongoDB數據服務器地址來連接,並返回一個client對象

‘‘‘

try:

client=None

if strusername==‘‘ or strpassword==‘‘:

#無驗證連接方式:

client=pymongo.MongoClient(serveraddress)

else:

#有驗證的連接:

client=pymongo.MongoClient(serveraddress,username=strusername,password=strpassword,authMechanism=strauthMechanism,connect=isconnect)

#-----------------------------------

return client

except Exception as e:

mmongoErrString=‘連接MongoDB數據庫【‘ + serveraddress + ‘】時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return None

else:

pass

finally:

pass

#向指定的集合中添加記錄

def addNewDataGhlh(objjh,objdata,isShowMsg=False):

‘‘‘

通過指定要添加記錄的集合對象和要添加的數據對象(字典或字典組成的列表)來向指定集合添加記錄

#objjh 要操作的集合對象

#objdata 要添加的數據,如果傳入一個字典對象則是添加一條記錄;如果傳入一個由多個字典組合成的列表對象,就是同時添加多條記錄。

‘‘‘

try:

r=objjh.insert(objdata)

if r==None:

return False

else:

return True

except Exception as e:

mmongoErrString=‘向集合中添加記錄時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return False

else:

pass

finally:

pass

#----簡化查詢記錄的書寫----

def findDataGhlh(objjh,strkeynm,value,strbijiao=‘‘,isReturnList=True,isShowMsg=False):

‘‘‘

用於指定一個key鍵名符合條件value的簡單查詢,只能針對一個鍵名的值作為篩選條件

*如果是字符串使用大於小於等比較運算則會被 忽略

*value支持使用正則表達式

‘‘‘

try:

if strkeynm==‘‘ or value==‘‘:

mmongoErrString=‘查詢集合中符合指定一個條件的記錄時出錯:必須指明要篩選的鍵名和鍵值\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return None

#----------------------------------------------------------

dic=None

if strbijiao==‘>‘:

#--大於比較---------------

dic={strkeynm:{‘$gt‘:value}}

elif strbijiao==‘>=‘:

#--大於等於------

dic={strkeynm:{‘$gte‘:value}}

elif strbijiao==‘<‘:

#---小於--------------

dic={strkeynm:{‘$lt‘:value}}

elif strbijiao==‘<=‘:

#---小於等於--------------

dic={strkeynm:{‘$lte‘:value}}

elif strbijiao==‘<>‘ or strbijiao==‘!=‘:

#---不等於--------------

dic={strkeynm:{‘$ne‘:value}}

elif strbijiao==‘in‘ or strbijiao==‘within‘ or strbijiao==‘包含‘ or strbijiao==‘包括‘:

#---in--------------只包含如字符串的一部分的情況,還不能處理

dic={strkeynm:{‘$in‘:value}}

elif strbijiao==‘nin‘ or strbijiao==‘without‘ or strbijiao==‘不包含‘ or strbijiao==‘不包括‘:

#---不等於--------------

dic={strkeynm:{‘$nin‘:value}}

elif strbijiao==‘正則‘ or strbijiao==‘正則表達式‘ or strbijiao==‘reg‘ or strbijiao==‘regex‘:

#---value是一個正則表達式----

dic={strkeynm:{‘$regex‘:value}}

else:

#===等於

dic={strkeynm:value}

#--------------------------------------------

r=objjh.find(dic)

if r==None:

return None

else:

#---現在得到的是一個生成器

#---進行處理,返回為一個列表(可以在參數中加一個開關,看是否返回為一個列表,或直接返回為生成器)

if isReturnList==False:

return r

else:

#----改成列表後再返回 ====

return list(r)

#---------------------------------------------------------------------------

except Exception as e:

mmongoErrString=‘查詢集合中符合指定一個條件的記錄時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return None

else:

pass

finally:

pass

#根據指定的唯一 的一個篩選Key對應的value查找到記錄,並進行值的更改

def modifyValueGhlh(objjh,strkeynm,value,dictnewvalue,strbijiao=‘‘,isfugai=False,isaddnew=True,isReturnList=True,isShowMsg=False):

‘‘‘

根據指定的唯一 的一個篩選Key對應的value查找到記錄,並進行值的更改

此函數默認進行全部符合條件的記錄的修改。

#objjh 集合對象

#strkeynm 要作為篩選條件的那個key字段名,

#value 要篩選的值或表達式

#dictnewvalue 要向此記錄(文檔)中修改或添加的新內容

#strbijiao 查詢時要進行的比較運算符號

#isfugai 如果設置為True,則會先刪除文檔舊的全部記錄,只加入dictnewvalue列出記錄

#isaddnew 如果設置為True,則原文檔沒有的字段,而dictnewvalue中有的字段會被新增到文檔記錄中。

‘‘‘

try:

data=findDataGhlh(objjh,strkeynm,value,strbijiao,False,isShowMsg)

if data!=None:

#先取出_id

lstid=[]

for i in data:

strid=i.get(‘_id‘)

if strid!=None:

lstid.append(strid)

if isfugai==True:

objjh.update({‘_id‘:strid},dictnewvalue,isfugai)

else:

objjh.update({‘_id‘:strid},{"$set":dictnewvalue},isaddnew)

#------重新取出修改過的那些記錄並返回----

return findDataGhlh(objjh,‘_id‘,lstid,‘in‘,isReturnList,isShowMsg)

else:

mmongoErrString=‘修改集合中符合指定一個條件的記錄時出錯:沒有找到符合條件的記錄\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return None

#---------------------------------------------------------------------------

except Exception as e:

mmongoErrString=‘修改集合中符合指定一個條件的記錄時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return None

else:

pass

finally:

pass

#----簡化查詢記錄並刪除----

def delDataGhlh(objjh,strkeynm,value,strbijiao=‘‘,isShowMsg=False):

‘‘‘

查詢符合條件的記錄並刪除掉。

用於指定一個key鍵名符合條件value的簡單查詢,只能針對一個鍵名的值作為篩選條件

*如果是字符串使用大於小於等比較運算則會被 忽略

*value支持使用正則表達式

‘‘‘

try:

if strkeynm==‘‘ or value==‘‘:

mmongoErrString=‘查詢集合中符合指定一個條件的記錄並刪除記錄時出錯:必須指明要篩選的鍵名和鍵值\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return False

#----------------------------------------------------------

if strbijiao==‘>‘:

#--大於比較---------------

dic={strkeynm:{‘$gt‘:value}}

elif strbijiao==‘>=‘:

#--大於等於------

dic={strkeynm:{‘$gte‘:value}}

elif strbijiao==‘<‘:

#---小於--------------

dic={strkeynm:{‘$lt‘:value}}

elif strbijiao==‘<=‘:

#---小於等於--------------

dic={strkeynm:{‘$lte‘:value}}

elif strbijiao==‘<>‘ or strbijiao==‘!=‘:

#---不等於--------------

dic={strkeynm:{‘$ne‘:value}}

elif strbijiao==‘in‘ or strbijiao==‘within‘ or strbijiao==‘包含‘ or strbijiao==‘包括‘:

#---in--------------只包含如字符串的一部分的情況,還不能處理

dic={strkeynm:{‘$in‘:value}}

elif strbijiao==‘nin‘ or strbijiao==‘without‘ or strbijiao==‘不包含‘ or strbijiao==‘不包括‘:

#---不等於--------------

dic={strkeynm:{‘$nin‘:value}}

elif strbijiao==‘正則‘ or strbijiao==‘正則表達式‘ or strbijiao==‘reg‘ or strbijiao==‘regex‘:

#---value是一個正則表達式----

dic={strkeynm:{‘$regex‘:value}}

else:

#===等於

dic={strkeynm:value}

#--------------------------------------------

objjh.remove(dic)

return True

#---------------------------------------------------------------------------

except Exception as e:

mmongoErrString=‘查詢集合中符合指定一個條件的記錄並刪除時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

return False

else:

pass

finally:

pass

#將傳入的cursor對象中的全部記錄的_id值提取出來存入一個列表中返回

def getAll_idInCurSorGhlh(cursor,isShowMsg=False):

‘‘‘

將傳入的cursor對象中的全部記錄的_id值提取出來存入一個列表中返回

‘‘‘

lstR=[]

try:

for i in cursor:

strid=i.get(‘_id‘)

if strid!=None:

lstR.append(strid)

return lstR

#---------------------------------------------------------------------------

except Exception as e:

mmongoErrString=‘獲取mongoDb數據記錄集(cursor)的所有記錄中的_id值列表時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

lstR=[]

return lstR

else:

pass

finally:

pass

#將只有一個字段篩選條件的查詢結果的所有記錄中的_id值提出出來存入一個列表中返回

def findDataAndReturn_idListGhlh(objjh,strkeynm,value,strbijiao=‘‘,isShowMsg=False):

‘‘‘

將只有一個字段篩選條件的查詢結果的所有記錄中的_id值提出出來存入一個列表中返回

‘‘‘

try:

data=findDataGhlh(objjh,strkeynm,value,strbijiao,False,isShowMsg)

return getAll_idInCurSorGhlh(data,isShowMsg)

#-------------------------------------------

except Exception as e:

mmongoErrString=‘獲取mongoDb數據庫中符合單一篩選條件的所有記錄中的_id值列表時出錯:‘ + str(e) + ‘\n此函數由【孤荷淩寒】創建,QQ578652607‘

if isShowMsg==True:

msgbox(mmongoErrString)

lstR=[]

return lstR

else:

pass

finally:

pass

```

——————————

今天整理的學習筆記完成,最後例行說明下我的自學思路:

根據過去多年我自學各種編程語言的經歷,認為只有真正體驗式,解決實際問題式的學習才會有真正的效果,即讓學習實際發生。在2004年的時候我開始在一個鄉村小學自學電腦 並學習vb6編程語言,沒有學習同伴,也沒有高師在上,甚至電腦都是孤島(鄉村那時還沒有網絡),有的只是一本舊書,在痛苦的自學摸索中,我找到適應自己零基礎的學習方法:首先是每讀書的一小節就作相應的手寫筆記,第二步就是上機測試每一個筆記內容是否實現,其中會發現書中講的其實有出入或錯誤,第三步就是在上機測試之後,將筆記改為電子版,形成最終的修訂好的正確無誤的學習筆記 。

通過反復嘗試錯誤,在那個沒有分享與交流的黑暗時期我摸黑學會了VB6,爾後接觸了其它語言,也曾聽過付費視頻課程,結果發現也許自己學歷果然太低,就算是零基礎的入門課程,其實也難以跟上進度,講師的教學多數出現對初學者的實際情況並不了解的情況,況且學習者的個體也存在差異呢?當然更可怕的是收費課程的價格往往是自己難以承受的。

於是我的所有編程學習都改為了自學,繼續自己的三步學習筆記法的學習之路。

當然自學的最大問題是會走那麽多的彎路,沒有導師直接輸入式的教學來得直接,好在網絡給我們帶來無限搜索的機會,大家在網絡上的學習日誌帶給我們共享交流的機會,而QQ群等交流平臺、網絡社區的成立,我們可以一起自學,互相批評交流,也可以獲得更有效,更自主的自學成果。

於是我以人生已過半的年齡,決定繼續我的編程自學之路,開始學習python,只希望與大家共同交流,一個人的獨行是可怕的,只有一群人的共同前進才是有希望的。

誠摯期待您的交流分享批評指點!歡迎聯系我加入從零開始的自學聯盟。

這個時代互聯網成為了一種基礎設施的存在,於是本來在孤獨學習之路上的我們變得不再孤獨,因為網絡就是一個新的客廳,我們時刻都可以進行沙龍活動。

非常樂意能與大家一起交流自己自學心得和發現,更希望大家能夠對我學習過程中的錯誤給予指點——是的,這樣我就能有許多免費的高師了——這也是分享時代,社區時代帶來的好福利,我相信大家會的,是吧!

根據完全共享的精神,開源互助的理念,我的個人自學錄制過程是全部按4K高清視頻錄制的,從手寫筆記到驗證手寫筆記的上機操作過程全程錄制,但因為4K高清文件太大均超過5G以上,所以無法上傳至網絡,如有需要可聯系我QQ578652607對傳,樂意分享。上傳分享到百度網盤的只是壓縮後的720P的視頻。

我的學習過程錄像百度盤地址分享如下:(清晰度:1280x720)

鏈接:https://pan.baidu.com/s/1AYprOjG3owTEKJA1hwXKUw

提取碼:foht

Bilibili:

https://www.bilibili.com/video/av40255775/

喜馬拉雅語音筆記:

https://www.ximalaya.com/keji/19103006/152105278

孤荷淩寒自學python第六十六天學習mongoDB的基本操作並進行簡單封裝5