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

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

孤荷凌寒自學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