hyb
2026-01-09 4cb426cb3ae31e772a09d4ade5b2f0242aaeefa0
测试组/脚本/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)
    # 执行更新任务