优化各项目数据库地址变更和端口号变更后的数据库获取问题 增加数据库表中的端口字段，获取对应项目的端口号

hyb

2025-12-05 b436b1fa9bf0011acb547948468627e8cde40c76

优化各项目数据库地址变更和端口号变更后的数据库获取问题
增加数据库表中的端口字段，获取对应项目的端口号

 测试组/脚本/Change_password/__pycache__/修改数据库的哈希密码和原始密码做桌面客户端.cpython-312.pyc

Binary files differ

 测试组/脚本/Change_password/__pycache__/修改数据库的哈希密码和原始密码做桌面客户端源代码.cpython-312.pyc

Binary files differ

 测试组/脚本/Change_password/__pycache__/修改数据库的哈希密码和原始密码做桌面客户端源代码（argon2id）.cpython-312.pyc

Binary files differ

 测试组/脚本/Change_password/__pycache__/异步批量修改数据库的哈希密码和原始密码V2.0.cpython-312.pyc

Binary files differ

 测试组/脚本/Change_password/dbExcel/~$数据库信息.xlsx

 测试组/脚本/Change_password/dbExcel/数据库信息.xlsx

Binary files differ

 测试组/脚本/Change_password/修改数据库的哈希密码和原始密码做桌面客户端.py

@@ -166,9 +166,9 @@
            # 创建数据库更新器实例
            self.updaters = []
            for _, row in df_filtered.iterrows():
                project, host, database, user, password = row[:5]
                self.log_signal.emit(f"准备处理项目：{project} | 数据库：{database}")
                updater = ProjectUpdater(project, host, database, user, password)
                project, host, port, database, user, password = row[:6]
                self.log_signal.emit(f"准备处理项目：{project} | 数据库：{database} | 端口：{port}")
                updater = ProjectUpdater(project, host, database, user, password, port)
                self.updaters.append(updater)

            # 执行更新任务
@@ -254,12 +254,13 @@
class ProjectUpdater:
    """单个项目更新器"""

    def __init__(self, project, host, database, user, password):
    def __init__(self, project, host, database, user, password, port=3306):
        self.project = project
        self.host = host
        self.database = database
        self.db_user = user
        self.db_password = password
        self.port = port
        self.updated_users = []
        self.log_records = []

@@ -268,7 +269,7 @@
        try:
            conn = mysql.connector.connect(
                host=self.host,
                port=3306,
                port=self.port,
                user=self.db_user,
                password=self.db_password,
                database=self.database,

 测试组/脚本/Change_password/修改数据库的哈希密码和原始密码做桌面客户端源代码.py

@@ -166,9 +166,9 @@
            # 创建数据库更新器实例
            self.updaters = []
            for _, row in df_filtered.iterrows():
                project, host, database, user, password = row[:5]
                self.log_signal.emit(f"准备处理项目：{project} | 数据库：{database}")
                updater = ProjectUpdater(project, host, database, user, password)
                project, host, port, database, user, password = row[:6]
                self.log_signal.emit(f"准备处理项目：{project} | 数据库：{database} | 端口：{port}")
                updater = ProjectUpdater(project, host, database, user, password, port)
                self.updaters.append(updater)

            # 执行更新任务
@@ -254,12 +254,13 @@
class ProjectUpdater:
    """单个项目更新器"""

    def __init__(self, project, host, database, user, password):
    def __init__(self, project, host, database, user, password, port=3306):
        self.project = project
        self.host = host
        self.database = database
        self.db_user = user
        self.db_password = password
        self.port = port
        self.updated_users = []
        self.log_records = []

@@ -268,7 +269,7 @@
        try:
            conn = mysql.connector.connect(
                host=self.host,
                port=3306,
                port=self.port,
                user=self.db_user,
                password=self.db_password,
                database=self.database,

 测试组/脚本/Change_password/修改数据库的哈希密码和原始密码做桌面客户端源代码（argon2id）.py

@@ -191,9 +191,9 @@
            # 创建数据库更新器实例
            self.updaters = []
            for _, row in df_filtered.iterrows():
                project, host, database, user, password = row[:5]
                self.log_signal.emit(f"准备处理项目：{project} | 数据库：{database}")
                updater = ProjectUpdater(project, host, database, user, password)
                project, host, port, database, user, password = row[:6]
                self.log_signal.emit(f"准备处理项目：{project} | 数据库：{database} | 端口：{port}")
                updater = ProjectUpdater(project, host, database, user, password, port)
                self.updaters.append(updater)

            # 执行更新任务
@@ -279,12 +279,13 @@
class ProjectUpdater:
    """单个项目更新器"""

    def __init__(self, project, host, database, user, password):
    def __init__(self, project, host, database, user, password, port=3306):
        self.project = project
        self.host = host
        self.database = database
        self.db_user = user
        self.db_password = password
        self.port = port
        self.updated_users = []
        self.log_records = []

@@ -293,7 +294,7 @@
        try:
            conn = mysql.connector.connect(
                host=self.host,
                port=3306,
                port=self.port,
                user=self.db_user,
                password=self.db_password,
                database=self.database,

 测试组/脚本/Change_password/异步批量修改数据库的哈希密码和原始密码V2.0.py

@@ -117,12 +117,13 @@
    """数据库更新器类"""

    def __init__(self, project: str, host: str, database: str,
                 user: str, password: str):
                 user: str, password: str, port: int = 3306):
        self.project = project
        self.host = host
        self.database = database
        self.db_user = user
        self.db_password = password
        self.port = port
        self.updated_users = []  # 存储更新过的用户信息

    async def connect(self) -> Optional[mysql.connector.connection.MySQLConnection]:
@@ -131,7 +132,7 @@
            conn = await asyncio.to_thread(
                mysql.connector.connect,
                host=self.host,
                port=3306,
                port=self.port,
                user=self.db_user,
                password=self.db_password,
                database=self.database,
@@ -416,9 +417,9 @@
    # 创建数据库更新器实例
    updaters = []
    for _, row in df_filtered.iterrows():
        project, host, database, user, password = row[:5]
        print(f"\n🚀 准备处理项目：{project} | 数据库：{database}")
        updater = DatabaseUpdater(project, host, database, user, password)
        project, host, port, database, user, password = row[:6]
        print(f"\n🚀 准备处理项目：{project} | 数据库：{database} | 端口：{port}")
        updater = DatabaseUpdater(project, host, database, user, password, port)
        updaters.append(updater)

    # 执行更新任务

 测试组/脚本/Change_password/更新日志.csv

Diff too large

 测试组/脚本/Change_password/用户信息导出/清华大学生产数据导入测试环境账号密码_20251127.xlsx

Binary files differ

 测试组/脚本/Change_password/用户信息导出/清华大学生产数据导入测试环境账号密码_20251203.xlsx

Binary files differ