ok

app/core/tidb_manager.py

@@ -85,7 +85,8 @@ class TiDBInstance:
             self.pool = None
 
     def __repr__(self) -> str:
-        return f"TiDBInstance({self.user}@{self.host}:{self.port}/{self.database})"
+        user_prefix = self.user.split(".")[0] if "." in self.user else self.user
+        return f"TiDBInstance({user_prefix}@...)"
 
 
 class TiDBManager:
@@ -103,12 +104,12 @@ class TiDBManager:
         return self._current_instance_index
 
     async def initialize_pools(self, minsize: int = 1, maxsize: int = 10):
-        for inst in self.instances:
+        for i, inst in enumerate(self.instances, 1):
             try:
                 await inst.create_pool(minsize=minsize, maxsize=maxsize)
-                logger.info("Connected to TiDB: %s", inst)
+                logger.info("Connected to TiDB instance %d/%d", i, len(self.instances))
             except Exception as exc:
-                logger.error("Failed to connect to TiDB %s: %s", inst, exc)
+                logger.error("Failed to connect to TiDB instance %d/%d: %s", i, len(self.instances), exc)
                 inst.is_available = False
 
     async def close_all_pools(self):
@@ -116,7 +117,7 @@ class TiDBManager:
             await inst.close_pool()
 
     async def ensure_tables(self, table_ddls: Dict[str, str]):
-        for inst in self.instances:
+        for i, inst in enumerate(self.instances, 1):
             if not inst.is_available or not inst.pool:
                 continue
             async with inst.pool.acquire() as conn:
@@ -134,11 +135,11 @@ class TiDBManager:
                                     stmt = statement.strip()
                                     if stmt:
                                         await cur.execute(stmt)
-                                logger.info("Created table '%s' on %s", table_name, inst)
+                                logger.info("Created table '%s' (instance %d/%d)", table_name, i, len(self.instances))
                         except Exception as exc:
                             logger.error(
-                                "Failed to create table '%s' on %s: %s",
-                                table_name, inst, exc,
+                                "Failed to create table '%s' (instance %d/%d): %s",
+                                table_name, i, len(self.instances), exc,
                             )
                 await conn.commit()