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

hyb

2025-12-05 b436b1fa9bf0011acb547948468627e8cde40c76

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

@@ -76,7 +76,7 @@
            for db_index in range(db_count):
                try:
                    # 切换到指定数据库
                    temp_client = self.redis_client.connection_pool.get_connection('ping')
                    temp_client = self.redis_client.connection_pool.get_connection()
                    await asyncio.to_thread(temp_client.send_command, 'SELECT', db_index)
                    await asyncio.to_thread(temp_client.read_response)

@@ -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)

    # 执行更新任务