Python3实现的Mysql数据库操作封装类
本文实例讲述了Python3实现的Mysql数据库操作封装类。分享给大家供大家参考，具体如下：
#encoding:utf-8
#name:mod_db.py
'''''
使用方法：1.在主程序中先实例化DBMysql数据库操作类。
2.使用方法:db=database()db.fetch_all("sql")
'''
importMySQLdb
importMySQLdb.cursors
importmod_config
importmod_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)
#数据库操作类
classdatabase:
#注，python的self等于其它语言的this
def__init__(self,dbname=None,dbhost=None):
self._logger=logger
#这里的None相当于其它语言的NULL
ifdbnameisNone:
self._dbname=DBNAME
else:
self._dbname=dbname
ifdbhostisNone:
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()
#数据库连接
defconnectMySQL(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,
)
exceptException,data:
self._logger.error("connectdatabasefailed,%s"%data)
conn=False
returnconn
#获取查询结果集
deffetch_all(self,sql):
res=''
if(self._conn):
try:
self._cursor.execute(sql)
res=self._cursor.fetchall()
exceptException,data:
res=False
self._logger.warn("querydatabaseexception,%s"%data)
returnres
defupdate(self,sql):
flag=False
if(self._conn):
try:
self._cursor.execute(sql)
self._conn.commit()
flag=True
exceptException,data:
flag=False
self._logger.warn("updatedatabaseexception,%s"%data)
returnflag
#关闭数据库连接
defclose(self):
if(self._conn):
try:
if(type(self._cursor)=='object'):
self._cursor.close()
if(type(self._conn)=='object'):
self._conn.close()
exceptException,data:
self._logger.warn("closedatabaseexception,%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:在主程序中先实例化DBMysql数据库操作类。再进行方法使用！
更多关于Python相关内容感兴趣的读者可查看本站专题：《Python+MySQL数据库程序设计入门教程》、《Python常见数据库操作技巧汇总》、《Python数学运算技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。