毕业证书查询系统Access .mdb转 Mysql .sql数据库

import pyodbc
def convert_access_table_to_mysql(access_db, table_name, output_sql_file, database_name):
    # 连接 Access 数据库
    conn_str = r'DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};DBQ=' + access_db
    access_conn = pyodbc.connect(conn_str)
    cursor = access_conn.cursor()
    with open(output_sql_file, 'w', encoding='utf-8') as f:
        # 在文件开头添加 USE 数据库的语句
        f.write(f'USE {database_name};\n\n')
        # 获取指定表的结构
        cursor.execute(f'SELECT * FROM {table_name}')
        columns = [column[0] for column in cursor.description]
        # 创建 MySQL 表的 SQL 语句
        create_table_sql = f'CREATE TABLE {table_name} (\n'
        for column in cursor.description:
            col_name = column[0]
            col_type = column[1]
            mysql_type = 'TEXT'  # 默认为 TEXT
            if col_type == pyodbc.SQL_INTEGER:
                mysql_type = 'INT'
            elif col_type == pyodbc.SQL_VARCHAR:
                mysql_type = 'VARCHAR(255)'
            create_table_sql += f'    {col_name} {mysql_type},\n'
        create_table_sql = create_table_sql.rstrip(',\n') + '\n);\n\n'
        f.write(create_table_sql)
        # 导出数据
        cursor.execute(f'SELECT * FROM {table_name}')
        for row in cursor.fetchall():
            # 处理 ID 字段，确保它是整数类型
            values = []
            for idx, value in enumerate(row):
                # 检查 ID 字段
                if columns[idx] == 'ID' and value is not None:
                    value = str(int(value))  # 强制转换为整数
                elif value is not None:
                    value = f'"{str(value)}"'  # 将其他字段作为字符串处理
                else:
                    value = 'NULL'
                values.append(value)

            column_names = ', '.join(columns)
            insert_sql = f'INSERT INTO {table_name} ({column_names}) VALUES ({", ".join(values)});\n'
            f.write(insert_sql)
        f.write('\n')
    cursor.close()
    access_conn.close()
    print(f'转换完成，SQL 语句已保存至 {output_sql_file}')
# 使用示例
convert_access_table_to_mysql(r'C:\\Users\\Administrator\\Desktop\\zhengshu.mdb', 'XcUserInfo', r'C:\\Users\\Administrator\\Desktop\\zhengshu.sql', '数据库名字')
#这里只从.mdb转了一个表到.sql里。