Python3實(shí)現(xiàn)的Mysql數(shù)據(jù)庫操作封裝類

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

這篇文章主要介紹了Python3實(shí)現(xiàn)的Mysql數(shù)據(jù)庫操作封裝類,涉及Python針對(duì)mysql數(shù)據(jù)庫的連接、查詢、更新及關(guān)閉連接等相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了Python3實(shí)現(xiàn)的Mysql數(shù)據(jù)庫操作封裝類。分享給大家供大家參考，具體如下：

#encoding:utf-8
#name:mod_db.py
'''''
使用方法：1.在主程序中先實(shí)例化DB Mysql數(shù)據(jù)庫操作類。
   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)
#數(shù)據(jù)庫操作類
class database:
#注，python的self等于其它語言的this
  def __init__(self, dbname=None, dbhost=None):
    self._logger = logger
    #這里的None相當(dāng)于其它語言的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()
  #數(shù)據(jù)庫連接
  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
  #獲取查詢結(jié)果集
  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
  #關(guān)閉數(shù)據(jù)庫連接
  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)))

這段代碼需要注意幾個(gè)地方：

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

2.數(shù)據(jù)庫類在初始化的時(shí)候，就將游標(biāo)賦給它，而不是在進(jìn)行數(shù)據(jù)庫操作的時(shí)候再尋找游標(biāo)。

PS:在主程序中先實(shí)例化DB Mysql數(shù)據(jù)庫操作類。再進(jìn)行方法使用！

希望本文所述對(duì)大家Python程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: