Python3怎么实现的Mysql数据库操作封装类-创新互联
这篇文章主要介绍Python3怎么实现的Mysql数据库操作封装类,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
创新互联公司公司2013年成立,是专业互联网技术服务公司,拥有项目成都网站设计、成都网站制作网站策划,项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命,1280元梁河做网站,已为上家服务,为梁河各地企业和个人服务,联系电话:028-86922220具体如下:
#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数据库操作类。再进行方法使用!
以上是“Python3怎么实现的Mysql数据库操作封装类”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注创新互联成都网站设计公司行业资讯频道!
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
当前标题:Python3怎么实现的Mysql数据库操作封装类-创新互联
当前链接:http://pwwzsj.com/article/hccgd.html