代码

# -*- coding: utf-8 -*-
# @Author   : zbz

import pymysql


class OperationMysql:
    def __init__(self, mysql_config: dict):
        self.conn = pymysql.Connection(**mysql_config)
        self.curs = self.conn.cursor()

    def exe_sql(self, sql, args=None, commit=False, value=None):
        try:
            self.conn.ping(reconnect=True)
            self.curs.execute(sql, args=args)
            if commit:
                self.conn.commit()
        except Exception as e:
            self.conn.rollback()
            print("ERROR ==> exe_sql ==> {}".format(e))
            return False
        else:
            if value == 1:
                return self.curs.fetchone()
            elif value == 2:
                return self.curs.fetchall()
            else:
                return True

使用

待续