Python讀取ini文件/操作mysql/發(fā)送郵件實(shí)例

字號(hào):


    python對(duì)各種數(shù)據(jù)庫(kù)的各種操作滿大街都是,不過,我還是喜歡我這種風(fēng)格的,涉及到其它操作,不過重點(diǎn)還是對(duì)數(shù)據(jù)庫(kù)的操作。呵~~
    Python操作Mysql
    首先,我習(xí)慣將配置信息寫到配置文件,這樣修改時(shí)可以不用源代碼,然后再寫通用的函數(shù)供調(diào)用
    新建一個(gè)配置文件,就命名為conf.ini,可以寫各種配置信息,不過都指明節(jié)點(diǎn)(文件格式要求還是較嚴(yán)格的):
    代碼如下:
    [app_info]
    DATABASE=test
    USER=app
    PASSWORD=123456
    HOST=172.17.1.1
    PORT=3306
    [mail]
    host=smtp.163.com
    mail_from=zhoujie0111@126.com
    password=654321
    send_to=zhoujie0111@139.com;zhoujie0111@163.com
    同目錄下新建文件db.py,精悍的代碼如下,不解釋:
    代碼如下:
    # -*-coding:utf-8 -*-
    import MySQLdb   #首先必須裝這兩個(gè)包
    import ConfigParser
    cf=ConfigParser.ConfigParser()
    cf.read("conf.ini")
    DATABASE=cf.get("app_info","DATABASE")
    USER=cf.get("app_info","USER")
    PASSWORD=cf.get("app_info","PASSWORD")
    HOST=cf.get("app_info","HOST")
    PORT=cf.get("app_info","PORT")
    def mysql(sql):
        try:
            conn=MySQLdb.connect(host=HOST,user=USER,passwd=PASSWORD,db=DATABASE,port=PORT)
            cur = conn.cursor()
            cur.execute(sql)
            rows = cur.fetchall()
            conn.commit()  #這個(gè)對(duì)于增刪改是必須的,否則事務(wù)沒提交執(zhí)行不成功
            cur.close()
            conn.close()
            return rows
        except MySQLdb.Error,e:
            print "Mysql Error %d: %s" % (e.args[0], e.args[1])
    上面是封裝了操作數(shù)據(jù)庫(kù)的方法,只需提供一個(gè)sql語(yǔ)句,CRUD均可操作。下面來(lái)YY一些數(shù)據(jù)來(lái)測(cè)試下增刪改查的具體用法(easy的,我真是閑),接著上面的代碼寫:
    代碼如下:
    def operation():
        #查詢
        select = mysql('select * from test')
        #插入
        '''
        插入這個(gè)地方有2點(diǎn)需要注意:
        1.插入某幾列如下指定,插入全部可以不指定列,但必須后面插入的值要按順序
        2.注意下面的type列兩邊有反斜點(diǎn),這是因?yàn)閠ype在我這個(gè)數(shù)據(jù)庫(kù)里有個(gè)表也叫這個(gè),或者可以把它叫關(guān)鍵字,不加反斜點(diǎn)插入會(huì)失敗
        3.這沒好說的,呵呵,數(shù)字占位符用%d,字符串用%s,且字符串占位符必須用雙引號(hào)括起來(lái)
        '''
        insert = mysql('insert into test (name,number,`type`) values("%s",%d,"%s")'%('jzhou',100,'VIP'))
        #更新
        mysql('update test set number=%d where name="%s"'%(99,'jzhou'))
        #刪除
        delete = mysql('delete from test where number = %d and `type`="%s"'%(100,'jzhou'))
        return select #我返回這個(gè)是為了下面發(fā)送郵件用的,順便增加個(gè)發(fā)送郵件的功能
    我只是想把這個(gè)簡(jiǎn)單的操作搞的復(fù)雜點(diǎn),增加個(gè)發(fā)送郵件的功能,也是接著上面的代碼:
    代碼如下:
    mailto_list=[]
    send_info=cf.get("mail","send_to")
    send_array=send_info.split(";")
    for i in range(len(send_array)):
        mailto_list.append(send_array[i])
    mail_host=cf.get("mail","host")
    mail_from=cf.get("mail","mail_from")
    mail_password=cf.get("mail","password")
    def send_mail(to_list,sub,content):
        me=mail_from
        msg=MIMEText(content,_subtype='html',_charset='utf-8')
        msg['Subject']=sub
        msg['From']=me
        msg['To']=";".join(to_list)
        try:
            s=smtplib.SMTP()
            s.connect(mail_host)
            s.login(mail_from,mail_password)
            s.sendmail(me,to_list,msg.as_string())
            s.close()
            return True
        except Exception,e:
            print str(e)
            return False
    發(fā)送郵件的配置我也是寫在conf.ini里的,在主函數(shù)里調(diào)用一下發(fā)送郵件來(lái)結(jié)束這個(gè)東西:
    代碼如下:
    if __name__ == '__main__':
        sub = u'不要問我為什么寫這篇博客,閑,就是任性!'
        content = operation()
        if send_mail(mailto_list,sub,content):
            print 'send success'
        else:
            print 'send failed'
    其實(shí)我還想說一下python操作postgresql,跟mysql非常類似,下載包psycopg2,不太相同的就是postgresql中執(zhí)行的sql語(yǔ)句都要加雙引號(hào),來(lái)感受一下:
    代碼如下:
    # -*-coding:utf-8 -*-
    import psycopg2
    import ConfigParser
    cf=ConfigParser.ConfigParser()
    cf.read("conf.ini")
    DATABASE=cf.get("cmdb_info","DATABASE")
    USER=cf.get("cmdb_info","USER")
    PASSWORD=cf.get("cmdb_info","PASSWORD")
    HOST=cf.get("cmdb_info","HOST")
    PORT=cf.get("cmdb_info","PORT")
    def psql(sql):
        try:
            conn = psycopg2.connect(database=DATABASE, user=USER, password=PASSWORD, host=HOST, port=PORT)
            cur = conn.cursor()
            cur.execute(sql)
            rows = cur.fetchall()
            conn.commit()
            cur.close()
            conn.close()
            return rows
        except Exception,e:
            print e
    def psql_oper():
        sql="select \"name\",\"type\" from \"test\" where \"name\" = 'jzhou'"
        rows=psql(sql)
        print rows