Python3實現的Mysql數據庫操作封裝類

更新時間：2018年06月06日 08:33:57 作者：除了玩_什么都不會

這篇文章主要介紹了Python3實現的Mysql數據庫操作封裝類,涉及Python針對mysql數據庫的連接、查詢、更新及關閉連接等相關操作技巧,需要的朋友可以參考下

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

#encoding:utf-8
#name:mod_db.py
'''''
使用方法：1.在主程序中先實例化DB Mysql數據庫操作類。
   2.使用方法:db=database() db.fetch_all("sql")
'''
import MySQLdb
import MySQLdb.cursors
import mod_config
import mod_logger
DB = "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是否存在，然后再讀取。

2.數據庫類在初始化的時候，就將游標賦給它，而不是在進行數據庫操作的時候再尋找游標。

PS:在主程序中先實例化DB Mysql數據庫操作類。再進行方法使用！

更多關于Python相關內容感興趣的讀者可查看本站專題：《Python+MySQL數據庫程序設計入門教程》、《Python常見數據庫操作技巧匯總》、《Python數學運算技巧總結》、《Python數據結構與算法教程》、《Python函數使用技巧總結》、《Python字符串操作技巧匯總》、《Python入門與進階經典教程》及《Python文件與目錄操作技巧匯總》

希望本文所述對大家Python程序設計有所幫助。

您可能感興趣的文章: