在python里mysql重构这段代码import sqlite3 class TeacherDatabase: def __init__(self): # 连接数据库 self.conn = sqlite3.connect('teacher.db') # 获取游标 self.cursor = self.conn.cursor() # 创建表 self.cursor.execute(''' CREATE TABLE IF NOT EXISTS scetc_teacher ( teacher_id VARCHAR(32) PRIMARY KEY, teacher_name VARCHAR(16), teacher_profession VARCHAR(64), teacher_tech VARCHAR(64), teacher_post VARCHAR(32) ); ''') self.conn.commit() def add_teacher(self): # 从控制台输入教师信息 teacher_id = input('请输入工号：') teacher_name = input('请输入姓名：') teacher_profession = input('请输入从事专业：') teacher_tech = input('请输入职称：') teacher_post = input('请输入职位：') # 判断工号是否已存在 self.cursor.execute('SELECT * FROM scetc_teacher WHERE teacher_id=?', (teacher_id,)) if self.cursor.fetchone(): print('该工号已存在，请重新输入！') return # 将教师信息写入数据库 self.cursor.execute('INSERT INTO scetc_teacher VALUES (?, ?, ?, ?, ?)', (teacher_id, teacher_name, teacher_profession, teacher_tech, teacher_post)) self.conn.commit() print('教师信息添加成功！') def query_teacher(self): # 查询所有教师信息并在控制台打印显示 self.cursor.execute('SELECT * FROM scetc_teacher') teachers = self.cursor.fetchall() if not teachers: print('暂无教师信息！') else: for teacher in teachers: print('工号：%s，姓名：%s，从事专业：%s，职称：%s，职位：%s' % teacher) def __del__(self): # 关闭连接 self.cursor.close() self.conn.close() if __name__ == '__main__': db = TeacherDatabase() db.add_teacher() db.query_teacher()

可以使用 Python 中的 PyMySQL 模块来重构这段代码，如下所示：

import pymysql

class TeacherDatabase:
    def __init__(self):
        # 连接数据库
        self.conn = pymysql.connect(
            host='localhost',
            user='username',
            password='password',
            db='teacher'
        )
        # 获取游标
        self.cursor = self.conn.cursor()
        # 创建表
        self.cursor.execute('''
            CREATE TABLE IF NOT EXISTS scetc_teacher (
                teacher_id VARCHAR(32) PRIMARY KEY,
                teacher_name VARCHAR(16),
                teacher_profession VARCHAR(64),
                teacher_tech VARCHAR(64),
                teacher_post VARCHAR(32)
            );
        ''')
        self.conn.commit()

    def add_teacher(self):
        # 从控制台输入教师信息
        teacher_id = input('请输入工号：')
        teacher_name = input('请输入姓名：')
        teacher_profession = input('请输入从事专业：')
        teacher_tech = input('请输入职称：')
        teacher_post = input('请输入职位：')

        # 判断工号是否已存在
        self.cursor.execute('SELECT * FROM scetc_teacher WHERE teacher_id=%s', (teacher_id,))
        if self.cursor.fetchone():
            print('该工号已存在，请重新输入！')
            return

        # 将教师信息写入数据库
        self.cursor.execute('INSERT INTO scetc_teacher VALUES (%s, %s, %s, %s, %s)',
                            (teacher_id, teacher_name, teacher_profession, teacher_tech, teacher_post))
        self.conn.commit()
        print('教师信息添加成功！')

    def query_teacher(self):
        # 查询所有教师信息并在控制台打印显示
        self.cursor.execute('SELECT * FROM scetc_teacher')
        teachers = self.cursor.fetchall()
        if not teachers:
            print('暂无教师信息！')
        else:
            for teacher in teachers:
                print('工号：%s，姓名：%s，从事专业：%s，职称：%s，职位：%s' % teacher)

    def __del__(self):
        # 关闭连接
        self.cursor.close()
        self.conn.close()

if __name__ == '__main__':
    db = TeacherDatabase()
    db.add_teacher()
    db.query_teacher()

这里我们使用了 PyMySQL 来连接 MySQL 数据库，对于表的创建和数据的操作与原来的代码基本相同。只需要修改连接数据库的方式和 SQL 语句中的占位符即可。