pattern-priv

Author: Caideyipi

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java

@@ -332,7 +332,11 @@ public Optional<ConfigPhysicalPlan> visitPipeDeactivateTemplate(
         for (final PartialPath intersectedPath :
             getAllIntersectedPatterns(
                 templateEntry.getKey(), userName, pipeDeactivateTemplatePlan)) {
-          newTemplateSetInfo.put(intersectedPath, templateEntry.getValue());
+          // root.db.device2.measurement -> root.db.device.** = root.db
+          // Note that we cannot take this circumstance into account
+          if (intersectedPath.getNodeLength() == templateEntry.getKey().getNodeLength()) {
+            newTemplateSetInfo.put(intersectedPath, templateEntry.getValue());
+          }
         }
       }
       return !newTemplateSetInfo.isEmpty()
@@ -356,7 +360,7 @@ public Optional<ConfigPhysicalPlan> visitTTL(final SetTTLPlan setTTLPlan, final
               new PartialPath(setTTLPlan.getPathPattern()), userName, setTTLPlan);
       // The intersectionList is either a singleton list or an empty list, because the pipe
       // pattern and TTL path are each either a prefix path or a full path
-      return !paths.isEmpty()
+      return !paths.isEmpty() && paths.get(0).getNodeLength() == setTTLPlan.getPathPattern().length
           ? Optional.of(new SetTTLPlan(paths.get(0).getNodes(), setTTLPlan.getTTL()))
           : Optional.empty();
     } catch (final AuthException e) {

iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitorTest.java

@@ -158,6 +158,8 @@ public void testPatternRelatedPrivilege() throws IOException {
         new PartialPath(new String[] {"root", "db", "device", "measurement"});
     final PartialPath unmatchedPath =
         new PartialPath(new String[] {"root", "db", "device2", "measurement"});
+    final PartialPath intersectPath =
+        new PartialPath(new String[] {"root", "*", "device", "measurement"});
 
     final PathPatternTree originalTree = new PathPatternTree();
     originalTree.appendPathPattern(matchedPath);
@@ -198,10 +200,7 @@ public void testPatternRelatedPrivilege() throws IOException {
                         new PipeDeactivateTemplatePlan(
                             new HashMap<PartialPath, List<Template>>() {
                               {
-                                put(
-                                    new PartialPath(
-                                        new String[] {"root", "*", "device", "measurement"}),
-                                    Collections.singletonList(new Template()));
+                                put(intersectPath, Collections.singletonList(new Template()));
                                 put(unmatchedPath, Collections.singletonList(new Template()));
                               }
                             }),
@@ -210,11 +209,15 @@ public void testPatternRelatedPrivilege() throws IOException {
             .getTemplateSetInfo()
             .keySet());
 
-    Assert.assertTrue(
-        skipVisitor
-            .visitTTL(
-                new SetTTLPlan(new String[] {"root", "db", "device", "measurement"}, 100), null)
-            .isPresent());
+    Assert.assertArrayEquals(
+        new String[] {"root", "db", "device", "measurement"},
+        ((SetTTLPlan)
+                skipVisitor
+                    .visitTTL(
+                        new SetTTLPlan(new String[] {"root", "*", "device", "measurement"}, 100),
+                        null)
+                    .get())
+            .getPathPattern());
     Assert.assertFalse(
         skipVisitor
             .visitTTL(