From b436b1fa9bf0011acb547948468627e8cde40c76 Mon Sep 17 00:00:00 2001
From: hyb <kk_huangyangbo@163.com>
Date: Fri, 05 Dec 2025 09:28:59 +0000
Subject: [PATCH] 优化各项目数据库地址变更和端口号变更后的数据库获取问题 增加数据库表中的端口字段，获取对应项目的端口号
---
测试组/脚本/Change_password/修改数据库的哈希密码和原始密码做桌面客户端源代码.py | 13 +++++++------
1 files changed, 7 insertions(+), 6 deletions(-)
diff --git "a/\346\265\213\350\257\225\347\273\204/\350\204\232\346\234\254/Change_password/\344\277\256\346\224\271\346\225\260\346\215\256\345\272\223\347\232\204\345\223\210\345\270\214\345\257\206\347\240\201\345\222\214\345\216\237\345\247\213\345\257\206\347\240\201\345\201\232\346\241\214\351\235\242\345\256\242\346\210\267\347\253\257\346\272\220\344\273\243\347\240\201.py" "b/\346\265\213\350\257\225\347\273\204/\350\204\232\346\234\254/Change_password/\344\277\256\346\224\271\346\225\260\346\215\256\345\272\223\347\232\204\345\223\210\345\270\214\345\257\206\347\240\201\345\222\214\345\216\237\345\247\213\345\257\206\347\240\201\345\201\232\346\241\214\351\235\242\345\256\242\346\210\267\347\253\257\346\272\220\344\273\243\347\240\201.py"
index 9574a8d..9ad0e66 100644
--- "a/\346\265\213\350\257\225\347\273\204/\350\204\232\346\234\254/Change_password/\344\277\256\346\224\271\346\225\260\346\215\256\345\272\223\347\232\204\345\223\210\345\270\214\345\257\206\347\240\201\345\222\214\345\216\237\345\247\213\345\257\206\347\240\201\345\201\232\346\241\214\351\235\242\345\256\242\346\210\267\347\253\257\346\272\220\344\273\243\347\240\201.py"
+++ "b/\346\265\213\350\257\225\347\273\204/\350\204\232\346\234\254/Change_password/\344\277\256\346\224\271\346\225\260\346\215\256\345\272\223\347\232\204\345\223\210\345\270\214\345\257\206\347\240\201\345\222\214\345\216\237\345\247\213\345\257\206\347\240\201\345\201\232\346\241\214\351\235\242\345\256\242\346\210\267\347\253\257\346\272\220\344\273\243\347\240\201.py"
@@ -87,7 +87,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()
temp_client.send_command('SELECT', db_index)
temp_client.read_response()
@@ -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,
--
Gitblit v1.9.1