partial

Author: Caideyipi

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanVisitor.java

@@ -350,7 +350,7 @@ public R visitRRevokeUserDBPrivilege(
   }
 
   public R visitRRevokeUserTBPrivilege(
-      final AuthorPlan rRevokeUserTBPrivilegePlan, final C context) {
+      final AuthorRelationalPlan rRevokeUserTBPrivilegePlan, final C context) {
     return visitPlan(rRevokeUserTBPrivilegePlan, context);
   }
 

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanTablePatternParseVisitor.java

@@ -23,6 +23,7 @@
 import org.apache.iotdb.commons.utils.PathUtils;
 import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlan;
 import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanVisitor;
+import org.apache.iotdb.confignode.consensus.request.write.auth.AuthorRelationalPlan;
 import org.apache.iotdb.confignode.consensus.request.write.database.DatabaseSchemaPlan;
 import org.apache.iotdb.confignode.consensus.request.write.database.DeleteDatabasePlan;
 import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeCreateTablePlan;
@@ -132,4 +133,57 @@ private boolean matchDatabaseAndTableName(
     return pattern.matchesDatabase(PathUtils.unQualifyDatabaseName(database))
         && pattern.matchesTable(tableName);
   }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRGrantUserDB(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitAuthorDBPlan(plan, pattern);
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRGrantRoleDB(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitAuthorDBPlan(plan, pattern);
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRRevokeUserDBPrivilege(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitAuthorDBPlan(plan, pattern);
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRRevokeRoleDBPrivilege(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitAuthorDBPlan(plan, pattern);
+  }
+
+  private Optional<ConfigPhysicalPlan> visitAuthorDBPlan(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return pattern.matchesDatabase(plan.getDatabaseName()) ? Optional.of(plan) : Optional.empty();
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRGrantUserTB(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitPlan(plan, pattern);
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRGrantRoleTB(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitPlan(plan, pattern);
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRRevokeUserTBPrivilege(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitPlan(plan, pattern);
+  }
+
+  @Override
+  public Optional<ConfigPhysicalPlan> visitRRevokeRoleTBPrivilege(
+      final AuthorRelationalPlan plan, final TablePattern pattern) {
+    return visitPlan(plan, pattern);
+  }
 }