本文實例講述了Python3實現的Mysql數據庫操作封裝類。分享給大家供大家參考，具體如下：

#encoding:utf-8#name:mod_db.py'''''使用方法：1.在主程序中先實例化DB Mysql數據庫操作類。   2.使用方法:db=database() db.fetch_all("sql")'''import MySQLdbimport MySQLdb.cursorsimport mod_configimport mod_loggerDB = "database"LOGPATH = mod_config.getConfig('path', 'logpath') + 'database.log'DBNAME = mod_config.getConfig(DB, 'dbname')DBHOST = mod_config.getConfig(DB, 'dbhost')DBUSER = mod_config.getConfig(DB, 'dbuser')DBPWD = mod_config.getConfig(DB, 'dbpassword')DBCHARSET = mod_config.getConfig(DB, 'dbcharset')DBPORT = mod_config.getConfig(DB, "dbport")logger = mod_logger.logger(LOGPATH)#數據庫操作類class database:#注，python的self等于其它語言的this  def __init__(self, dbname=None, dbhost=None):    self._logger = logger    #這里的None相當于其它語言的NULL    if dbname is None:      self._dbname = DBNAME    else:      self._dbname = dbname    if dbhost is None:      self._dbhost = DBHOST    else:      self._dbhost = dbhost    self._dbuser = DBUSER    self._dbpassword = DBPWD    self._dbcharset = DBCHARSET    self._dbport = int(DBPORT)    self._conn = self.connectMySQL()    if(self._conn):      self._cursor = self._conn.cursor()  #數據庫連接  def connectMySQL(self):    conn = False    try:      conn = MySQLdb.connect(host=self._dbhost,          user=self._dbuser,          passwd=self._dbpassword,          db=self._dbname,          port=self._dbport,          cursorclass=MySQLdb.cursors.DictCursor,          charset=self._dbcharset,          )    except Exception,data:      self._logger.error("connect database failed, %s" % data)      conn = False    return conn  #獲取查詢結果集  def fetch_all(self, sql):    res = ''    if(self._conn):      try:        self._cursor.execute(sql)        res = self._cursor.fetchall()      except Exception, data:        res = False        self._logger.warn("query database exception, %s" % data)    return res  def update(self, sql):    flag = False    if(self._conn):      try:        self._cursor.execute(sql)        self._conn.commit()        flag = True      except Exception, data:        flag = False        self._logger.warn("update database exception, %s" % data)    return flag  #關閉數據庫連接  def close(self):    if(self._conn):      try:        if(type(self._cursor)=='object'):          self._cursor.close()        if(type(self._conn)=='object'):          self._conn.close()      except Exception, data:        self._logger.warn("close database exception, %s,%s,%s" % (data, type(self._cursor), type(self._conn)))

這段代碼需要注意幾個地方：

1.數據庫配置文件變量放在類外面，只在模塊被載入的時候讀一次，在使用數據庫類時，無需再讀取。這樣有一個好處就是減少了IO的操作。如果是腳本程序需要不停的掃數據庫，放在類初始化的時候讀數據庫配置，那么很有可能造成IO錯誤，或者讀到的section為空，從而導致程序down掉。不好的地方就是如果修改了config，無法及時更新。不過一般程序部署后，不會隨意修改config文件，或者在修改config文件后，重新啟動程序。不過從程序的健壯性考慮，可以在可能會拋出異常的地方try，catch一下，更好的辦法是，在mod_config.py模塊中判斷一下該section和key是否存在，然后再讀取。