欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Python3实现的Mysql数据库操作封装类

程序员文章站 2022-05-29 18:57:00
本文实例讲述了python3实现的mysql数据库操作封装类。分享给大家供大家参考,具体如下: #encoding:utf-8 #name:mod_db.py...

本文实例讲述了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程序设计有所帮助。

上一篇: 圈子问题

下一篇: 真人呼吸法