fix: mysql扩容单据元数据标志位处理 TencentBlueKing#8493

zfrendo · Dec 10, 2024 · d0d7e4e · d0d7e4e
1 parent b7afb6b
commit d0d7e4e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/dbm-ui/backend/db_meta/api/cluster/tendbcluster/remotedb_node_migrate.py b/dbm-ui/backend/db_meta/api/cluster/tendbcluster/remotedb_node_migrate.py
@@ -149,6 +149,8 @@ def switch_remote_node(cls, cluster_id: int, source: dict, target: dict):
             source_master_obj.status = InstanceStatus.UNAVAILABLE
             source_master_obj.phase = InstancePhase.OFFLINE
             source_master_obj.is_stand_by = False
+            # 新主节点删除tuple关系
+            StorageInstanceTuple.objects.filter(ejector=source_master_obj, receiver=target_master_obj).delete()
             # 移出集群
             cluster.storageinstance_set.remove(source_master_obj)
         if source_slave_obj.ip_port != target_slave_obj.ip_port:

diff --git a/dbm-ui/backend/db_meta/api/cluster/tendbha/switch_slave.py b/dbm-ui/backend/db_meta/api/cluster/tendbha/switch_slave.py
@@ -43,6 +43,8 @@ def switch_slave(cluster_id: int, target_slave_ip: str, source_slave_ip: str, sl
     source_storage_obj.phase = InstancePhase.OFFLINE.value
     source_storage_obj.is_stand_by = False
     source_storage_obj.save()
+    # 移除关系
+    cluster.storageinstance_set.remove(source_storage_obj)
     cluster_entry_list = cluster.clusterentry_set.filter(entry__in=slave_domain)
     for cluster_entry in cluster_entry_list:
         cluster_entry.storageinstance_set.remove(source_storage_obj)