Python3实现的Mysql数据库操作封装类
作者:除了玩_什么都不会 时间:2024-01-20 23:57:36
本文实例讲述了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程序设计有所帮助。
来源:https://blog.csdn.net/m0_37995876/article/details/79991081
标签:Python3,Mysql数据库,封装类
0
投稿
猜你喜欢
Python3 sys.argv[ ]用法详解
2021-08-03 00:16:29
在python里从协程返回一个值的示例
2021-12-30 11:23:17
Python面向对象编程中关于类和方法的学习笔记
2023-07-20 00:13:37
Python中处理unchecked未捕获异常实例
2022-08-03 23:49:54
tensorflow实现KNN识别MNIST
2021-08-10 06:41:50
如何解决ORA-01843与NLS_DATE_FORMAT问题
2023-06-30 20:57:14
vue如何实现动态加载脚本
2024-05-25 15:19:28
python面向对象基础之常用魔术方法
2021-08-20 20:08:59
Python3.x对JSON的一些操作示例
2022-08-09 00:23:54
白鸦:贪守米缸者,饿死灶台
2009-02-23 13:03:00
vue解决跨域问题的几种常用方法(CORS)
2024-04-28 09:32:42
python数据结构之二叉树的统计与转换实例
2023-08-11 07:35:48
MySQL存储IP地址的方法
2024-01-23 06:01:02
golang映射Map的方法步骤
2023-08-28 09:10:22
oracle中commit之后进行数据回滚的方法
2024-01-25 01:00:53
python实现清屏的方法
2021-11-02 04:10:32
对Python3 goto 语句的使用方法详解
2023-10-14 11:32:49
Python Pandas 对列/行进行选择,增加,删除操作
2022-10-29 03:55:52
centos下mysql主从复制设置详解
2024-01-20 23:27:06
Python通过wordcloud库实现将单词生成词云
2022-02-24 20:17:18