From 64e046f0488c3fe6605a4e16d6213d29815f965b Mon Sep 17 00:00:00 2001 From: Qihua Hu <100274876+andrehqh@users.noreply.github.com> Date: Tue, 10 Nov 2026 19:33:23 +0800 Subject: [PATCH] [Fix-18776][DAO] Fix @Param name of K8sNamespaceMapper#queryByNamespaceCode - Use @Param("namespaceCode") to match #{namespaceCode} in K8sNamespaceMapper.xml - Add K8sNamespaceMapperTest#testQueryByNamespaceCode --- .../dao/mapper/K8sNamespaceMapper.java | 2 +- .../dao/mapper/K8sNamespaceMapperTest.java | 17 +++++++++++++++++ 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapper.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapper.java index 6c773c3e1da4..9cdb14d10957 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapper.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapper.java @@ -72,5 +72,5 @@ IPage queryK8sNamespacePaging(IPage page, * @param namespaceCode namespaceCode * @return true if exist else return null */ - K8sNamespace queryByNamespaceCode(@Param("clusterCode") Long namespaceCode); + K8sNamespace queryByNamespaceCode(@Param("namespaceCode") Long namespaceCode); } diff --git a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapperTest.java b/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapperTest.java index 90a0ebfe9d16..5b7a8e095efa 100644 --- a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapperTest.java +++ b/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/mapper/K8sNamespaceMapperTest.java @@ -114,6 +114,23 @@ public void testQueryByK8sNamespaceId() { Assertions.assertEquals(entity, k8sNamespace); } + /** + * test query k8s namespace by namespace code + */ + @Test + public void testQueryByNamespaceCode() { + K8sNamespace entity = insertOne(); + + K8sNamespace k8sNamespace = k8sNamespaceMapper.queryByNamespaceCode(entity.getCode()); + Assertions.assertNotNull(k8sNamespace); + Assertions.assertEquals(entity.getId(), k8sNamespace.getId()); + Assertions.assertEquals(entity.getCode(), k8sNamespace.getCode()); + Assertions.assertEquals(entity.getNamespace(), k8sNamespace.getNamespace()); + Assertions.assertEquals(entity.getClusterCode(), k8sNamespace.getClusterCode()); + + Assertions.assertNull(k8sNamespaceMapper.queryByNamespaceCode(entity.getCode() + 1)); + } + /** * test query k8sNamespaces list paging */