python连接mysql数据库执行语句

python3连接数据库，并执行sql简单方法，可以直接使用

#coding=utf-8
import pymysql
class mydb:
    __cursor = ''
    def __init__(self,sql):
        self.db = pymysql.connect(host="localhost", user="root", password="root", database="aa")
        #self.__cursor = self.db.cursor()
        self.__cursor = self.db.cursor(cursor=pymysql.cursors.DictCursor)
        self.sql = sql
    def query(self):
        try:
            # 执行SQL语句
            self.__cursor.execute(self.sql)
            # 获取所有记录列表
            results = self.__cursor.fetchall()
            
            return results
            for row in results:
                fname = row[0]
                lname = row[1]
                age = row[2]
                sex = row[3]
                income = row[4]
                # 打印结果
        except:
            return 0
        # 关闭数据库连接
        self.db.close()
    def insert(self):
        try:
            # 执行sql语句
            self.__cursor.execute(self.sql)
            # 提交到数据库执行
            self.db.commit()
            return self.__cursor.lastrowid
        except:
            # 如果发生错误则回滚
            self.db.rollback()
        # 关闭数据库连接
        self.db.close()
    def update(self):
        try:
            # 执行sql语句
            self.__cursor.execute(self.sql)
            # 提交到数据库执行
            self.db.commit()
        except:
            # 如果发生错误则回滚
            self.db.rollback()
        # 关闭数据库连接
        self.db.close()
    def delete(self):
        try:
            # 执行sql语句
            self.__cursor.execute(self.sql)
            # 提交到数据库执行
            self.db.commit()
        except:
            # 如果发生错误则回滚
            self.db.rollback()
        # 关闭数据库连接
        self.db.close()