python對各種數(shù)據(jù)庫的各種操作滿大街都是，不過，我還是喜歡我這種風(fēng)格的，涉及到其它操作，不過重點還是對數(shù)據(jù)庫的操作。呵~~

Python操作Mysql

首先，我習(xí)慣將配置信息寫到配置文件，這樣修改時可以不用源代碼，然后再寫通用的函數(shù)供調(diào)用

新建一個配置文件，就命名為conf.ini，可以寫各種配置信息，不過都指明節(jié)點（文件格式要求還是較嚴(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   #首先必須裝這兩個包

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()  #這個對于增刪改是必須的，否則事務(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ù)庫的方法，只需提供一個sql語句，CRUD均可操作。下面來YY一些數(shù)據(jù)來測試下增刪改查的具體用法（easy的，我真是閑），接著上面的代碼寫：

代碼如下:

def operation():

    #查詢

    select = mysql('select * from test')

    #插入

    '''

    插入這個地方有2點需要注意：

    1.插入某幾列如下指定，插入全部可以不指定列，但必須后面插入的值要按順序

    2.注意下面的type列兩邊有反斜點，這是因為type在我這個數(shù)據(jù)庫里有個表也叫這個，或者可以把它叫關(guān)鍵字，不加反斜點插入會失敗

    3.這沒好說的，呵呵，數(shù)字占位符用%d,字符串用%s，且字符串占位符必須用雙引號括起來

    '''

    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 #我返回這個是為了下面發(fā)送郵件用的，順便增加個發(fā)送郵件的功能

我只是想把這個簡單的操作搞的復(fù)雜點，增加個發(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ā)送郵件來結(jié)束這個東西：

代碼如下:

if __name__ == '__main__':

    sub = u'不要問我為什么寫這篇博客，閑，就是任性！'

    content = operation()

    if send_mail(mailto_list,sub,content):

        print 'send success'

    else:

        print 'send failed'

其實我還想說一下python操作postgresql，跟mysql非常類似，下載包psycopg2，不太相同的就是postgresql中執(zhí)行的sql語句都要加雙引號，來感受一下：

代碼如下:

# -*-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

更多信息請查看IT技術(shù)專欄