首页 > 数据库技术 > 详细

pymysql简单封装

时间:2019-09-23 15:30:46      阅读:168      评论:0      收藏:0      [点我收藏+]
import pymysql
from Common import dir_config
from Common.readconfig import ReadConfig
import logging
from Common import logger
class DoMysql:
    def __init__(self):
        self.config = ReadConfig().read_config(dir_config.db_config_path, "DB", "Config")
        logging.info("开始连接数据库")
        try:
            self.db = pymysql.connect(**self.config)
            logging.info("连接数据库成功")
        except:
            logging.info("数据库连接失败")
            raise

    def ExecQuery(self, sql):
        ‘‘‘
        执行查询语句
        :param sql:
        :return:
        ‘‘‘
        cursor = self.db.cursor()
        try:
            cursor.execute(sql)  # 执行sql、
            logging.info("执行sql成功")
        except:
            logging.info("执行sql失败")
            raise
        # res=cursor.fetchone() #单  返回的是一个元组
        res = cursor.fetchall()  # 多  返回的是一个嵌套元组的列表
        # 关掉游标 关掉连接
        cursor.close()
        self.db.close()
        logging.info("执行结果返回值:{0}".format(res))
        return res

    def ExecNonQuery(self, sql):
        ‘‘‘
        执行非查询语句
        :param sql:
        :return:
        ‘‘‘
        cursor = self.db.cursor()
        try:
            cursor.execute(sql)
            logging.info("执行sql成功")
        except:
            logging.info("执行sql失败")
            raise
        # commit()方法:在数据库里增、删、改的时候,必须要进行提交,否则插入的数据不生效。
        self.db.commit()
        cursor.close()
        self.db.close()

  

pymysql简单封装

原文:https://www.cnblogs.com/l7planet/p/11572004.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!