介绍 #编码:utf - 8
#名称:mod_db.py
& # 39;& # 39;& # 39;& # 39;& # 39;
使用方法:1 .在主程序中先实例化DB Mysql数据库操作类。
,,2。使用方法:db数据库=(),db.fetch_all (“sql")
& # 39;& # 39;& # 39;
import MySQLdb
import MySQLdb.cursors
import mod_config
import mod_logger
时间=DB “database"
时间=LOGPATH mod_config.getConfig (& # 39; path & # 39;,, & # 39; logpath # 39;), +, & # 39; database.log& # 39;
时间=DBNAME mod_config.getConfig (DB, & # 39; dbname # 39;)
时间=DBHOST mod_config.getConfig (DB, & # 39; dbhost& # 39;)
时间=DBUSER mod_config.getConfig (DB, & # 39; dbuser& # 39;)
时间=DBPWD mod_config.getConfig (DB, & # 39; dbpassword& # 39;)
时间=DBCHARSET mod_config.getConfig (DB, & # 39; dbcharset& # 39;)
时间=DBPORT mod_config.getConfig (DB,“dbport")
时间=logger mod_logger.logger (LOGPATH)
#数据库操作类
class 数据库:
#注,python的自我等于其它语言的
def 才能;__init__(自我,,dbname=没有,dbhost=None):
,,,self._logger =记录器
,,,#这里的没有相当于其它语言的NULL
,,,if dbname is 没有:
,,,,,=,DBNAME self._dbname
,,,:
,,,,,=,dbname self._dbname
,,,if dbhost is 没有:
,,,,,self._dbhost =DBHOST
,,,:
,,,,,self._dbhost =dbhost
,,,self._dbuser =dbus
,,,self._dbpassword =DBPWD
,,,self._dbcharset =DBCHARSET
,,,self._dbport =, int (DBPORT)
,,,self._conn =, self.connectMySQL ()
,,,如果(self._conn):
,,,,,self._cursor =, self._conn.cursor ()
#才能数据库连接
def 才能connectMySQL(自我):
,,,conn =False
,,,试一试:
,,,,,conn =, MySQLdb.connect(主机=self._dbhost,
,,,,,,,,,用户=self._dbuser,
,,,,,,,,,passwd=self._dbpassword,
,,,,,,,,,db=self._dbname,
,,,,,,,,,=self._dbport港
,,,,,,,,,cursorclass=MySQLdb.cursors.DictCursor,
,,,,,,,,,charset=self._dbcharset,
,,,,,,,,,)
,,,except 例外,数据:
,,,,,self._logger.error (“connect database 失败了,,% s", %,数据)
,,,,,conn =False
,,,return 康涅狄格州
#才能获取查询结果集
def 才能fetch_all(自我,sql):
,,,res =, & # 39; & # 39;
,,,如果(self._conn):
,,,,,试一试:
,,,,,,,self._cursor.execute (sql)
,,,,,,,res =, self._cursor.fetchall ()
,,,,,except 例外,,数据:
,,,,,,,res =False
,,,,,,,self._logger.warn (“query database 例外,,% s", %,数据)
,,,return res
def 才能更新(自我,,sql):
,,,flag =False
,,,如果(self._conn):
,,,,,试一试:
,,,,,,,self._cursor.execute (sql)
,,,,,,,self._conn.commit ()
,,,,,,,flag =,真的
,,,,,except 例外,,数据:
,,,,,,,flag =False
,,,,,,,self._logger.warn (“update database 例外,,% s", %,数据)
,,,return 旗帜
#才能关闭数据库连接
def 才能关闭(自我):
,,,如果(self._conn):
,,,,,试一试:
,,,,,,,如果(类型(self._cursor)==& # 39;对象# 39;):
,,,,,,,,,self._cursor.close ()
,,,,,,,如果(类型(self._conn)==& # 39;对象# 39;):
,,,,,,,,,self._conn.close ()
null
null
这篇文章主要介绍Python3怎么实现的Mysql数据库操作封装类,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
具体如下:
