Solved the compilation problem

Author: Caideyipi

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java

@@ -37,7 +37,6 @@
 import org.apache.iotdb.commons.pipe.sink.payload.thrift.request.PipeTransferFileSealReqV1;
 import org.apache.iotdb.commons.pipe.sink.payload.thrift.request.PipeTransferFileSealReqV2;
 import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
-import org.apache.iotdb.commons.schema.table.Audit;
 import org.apache.iotdb.commons.schema.table.TreeViewSchema;
 import org.apache.iotdb.commons.schema.table.TsTable;
 import org.apache.iotdb.commons.schema.table.column.TsTableColumnSchema;
@@ -345,23 +344,13 @@ private TSStatus checkPermission(final ConfigPhysicalPlan plan) throws IOExcepti
             .getStatus();
       case PipeAlterEncodingCompressor:
         // Judge here in the future
-        if (configManager
-                .checkUserPrivileges(username, new PrivilegeUnion(PrivilegeType.AUDIT))
-                .getStatus()
-                .getCode()
-            != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-          ((PipeAlterEncodingCompressorPlan) plan).setMayAlterAudit(false);
-        }
         if (skipIfNoPrivileges.get()) {
           final PathPatternTree pathPatternTree =
               PathPatternTree.deserialize(
                   ByteBuffer.wrap(
                       configManager
                           .fetchAuthizedPatternTree(username, PrivilegeType.WRITE_SCHEMA.ordinal())
                           .getPathPatternTree()));
-          if (((PipeAlterEncodingCompressorPlan) plan).isMayAlterAudit()) {
-            pathPatternTree.appendPathPattern(Audit.TREE_MODEL_AUDIT_DATABASE_PATH_PATTERN, true);
-          }
           ((PipeAlterEncodingCompressorPlan) plan)
               .setPatternTreeBytes(
                   PathPatternTreeUtils.intersectWithFullPathPrefixTree(

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

@@ -254,7 +254,7 @@ public Optional<ConfigPhysicalPlan> visitPipeDeleteLogicalView(
   @Override
   public Optional<ConfigPhysicalPlan> visitPipeAlterEncodingCompressor(
       final PipeAlterEncodingCompressorPlan pipeAlterEncodingCompressorPlan,
-      final UnionIoTDBTreePattern pattern) {
+      final IoTDBTreePattern pattern) {
     try {
       final PathPatternTree intersectedTree =
           pattern.getIntersection(

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java

@@ -69,7 +69,9 @@ public class AlterEncodingCompressorProcedure
   private boolean ifExists;
   private byte encoding;
   private byte compressor;
-  private boolean mayAlterAudit;
+
+  // Reserved for potential upgrading
+  private boolean mayAlterAudit = false;
 
   private transient ByteBuffer patternTreeBytes;
   private transient String requestMessage;
@@ -149,7 +151,7 @@ protected Flow executeFromState(
 
   private boolean alterEncodingCompressorInSchemaRegion(final ConfigNodeProcedureEnv env) {
     final Map<TConsensusGroupId, TRegionReplicaSet> relatedSchemaRegionGroup =
-        env.getConfigManager().getRelatedSchemaRegionGroup(patternTree, mayAlterAudit);
+        env.getConfigManager().getRelatedSchemaRegionGroup(patternTree);
 
     if (relatedSchemaRegionGroup.isEmpty()) {
       if (!ifExists) {
@@ -167,7 +169,7 @@ private boolean alterEncodingCompressorInSchemaRegion(final ConfigNodeProcedureE
     final DataNodeTSStatusTaskExecutor<TAlterEncodingCompressorReq> alterEncodingCompressorTask =
         new DataNodeTSStatusTaskExecutor<TAlterEncodingCompressorReq>(
             env,
-            env.getConfigManager().getRelatedSchemaRegionGroup(patternTree, mayAlterAudit),
+            env.getConfigManager().getRelatedSchemaRegionGroup(patternTree),
             false,
             CnToDnAsyncRequestType.ALTER_ENCODING_COMPRESSOR,
             ((dataNodeLocation, consensusGroupIdList) ->
@@ -237,9 +239,9 @@ private void collectPayload4Pipe(final ConfigNodeProcedureEnv env) {
                   isGeneratedByPipe
                       ? new PipeEnrichedPlan(
                           new PipeAlterEncodingCompressorPlan(
-                              patternTreeBytes, encoding, compressor, mayAlterAudit))
+                              patternTreeBytes, encoding, compressor, false))
                       : new PipeAlterEncodingCompressorPlan(
-                          patternTreeBytes, encoding, compressor, mayAlterAudit));
+                          patternTreeBytes, encoding, compressor, false));
     } catch (final ConsensusException e) {
       LOGGER.warn(ClusterManager.CONSENSUS_WRITE_ERROR, e);
       result = new TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
@@ -285,7 +287,7 @@ public void serialize(final DataOutputStream stream) throws IOException {
     ReadWriteIOUtils.write(ifExists, stream);
     ReadWriteIOUtils.write(encoding, stream);
     ReadWriteIOUtils.write(compressor, stream);
-    ReadWriteIOUtils.write(mayAlterAudit, stream);
+    ReadWriteIOUtils.write(false, stream);
   }
 
   @Override

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java

@@ -3172,7 +3172,7 @@ public Analysis visitShowTimeSeries(
   }
 
   @Override
-  public Analysis visitShowStorageGroup(
+  public Analysis visitShowDatabase(
       ShowDatabaseStatement showDatabaseStatement, MPPQueryContext context) {
     Analysis analysis = new Analysis();
     analysis.setRealStatement(showDatabaseStatement);

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java

@@ -19,27 +19,38 @@
 
 package org.apache.iotdb.db.queryengine.plan.statement.metadata;
 
+import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.auth.AuthException;
+import org.apache.iotdb.commons.auth.entity.PrivilegeType;
 import org.apache.iotdb.commons.path.PartialPath;
 import org.apache.iotdb.commons.path.PathPatternTree;
+import org.apache.iotdb.commons.path.PathPatternTreeUtils;
+import org.apache.iotdb.commons.utils.StatusUtils;
+import org.apache.iotdb.db.auth.AuthorityChecker;
 import org.apache.iotdb.db.queryengine.plan.analyze.QueryType;
 import org.apache.iotdb.db.queryengine.plan.statement.IConfigStatement;
 import org.apache.iotdb.db.queryengine.plan.statement.Statement;
 import org.apache.iotdb.db.queryengine.plan.statement.StatementType;
 import org.apache.iotdb.db.queryengine.plan.statement.StatementVisitor;
+import org.apache.iotdb.rpc.TSStatusCode;
 
 import org.apache.tsfile.file.metadata.enums.CompressionType;
 import org.apache.tsfile.file.metadata.enums.TSEncoding;
 
 import java.util.List;
 import java.util.Objects;
 
+import static org.apache.iotdb.db.auth.AuthorityChecker.getAuthorizedPathTree;
+
 public class AlterEncodingCompressorStatement extends Statement implements IConfigStatement {
 
   private PathPatternTree patternTree;
   private final TSEncoding encoding;
   private final CompressionType compressor;
   private final boolean ifExists;
   private final boolean ifPermitted;
+
+  // Reserved for upgrading
   private boolean withAudit = false;
 
   public AlterEncodingCompressorStatement(
@@ -109,6 +120,29 @@ public boolean equals(final Object obj) {
         && Objects.equals(this.ifPermitted, that.ifPermitted);
   }
 
+  @Override
+  public TSStatus checkPermissionBeforeProcess(String userName) {
+    if (AuthorityChecker.SUPER_USER.equals(userName)) {
+      return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
+    }
+    if (ifPermitted) {
+      try {
+        final PathPatternTree authTree =
+            getAuthorizedPathTree(userName, PrivilegeType.WRITE_SCHEMA);
+        setPatternTree(
+            PathPatternTreeUtils.intersectWithFullPathPrefixTree(getPatternTree(), authTree));
+        return StatusUtils.OK;
+      } catch (final AuthException e) {
+        return new TSStatus(e.getCode().getStatusCode());
+      }
+    }
+    return AuthorityChecker.getTSStatus(
+        AuthorityChecker.checkFullPathOrPatternListPermission(
+            userName, getPaths(), PrivilegeType.WRITE_SCHEMA),
+        getPaths(),
+        PrivilegeType.WRITE_SCHEMA);
+  }
+
   @Override
   public int hashCode() {
     return Objects.hash(patternTree, encoding, compressor, ifExists, ifPermitted);