| | |
|---|
| | | 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() |
|---|
| | | temp_client.send_command('SELECT', db_index) |
|---|
| | | temp_client.read_response() |
|---|
| | | |
|---|
| | |
|---|
| | | # 创建数据库更新器实例 |
|---|
| | | 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) |
|---|
| | | |
|---|
| | | # 执行更新任务 |
|---|
| | |
|---|
| | | 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 = [] |
|---|
| | | |
|---|
| | |
|---|
| | | try: |
|---|
| | | conn = mysql.connector.connect( |
|---|
| | | host=self.host, |
|---|
| | | port=3306, |
|---|
| | | port=self.port, |
|---|
| | | user=self.db_user, |
|---|
| | | password=self.db_password, |
|---|
| | | database=self.database, |
|---|
