Added privilege for information_schema & Removed the privilege requirement for show pipePlugins

Author: Caideyipi

integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBMaintainAuthIT.java

@@ -165,20 +165,10 @@ public void maintainAuthTest() {
         PASSWORD);
 
     // case 12: show queries
-    // user1 with select on information_schema.queries
-    tableAssertTestFail(
-        "SHOW QUERIES",
-        TSStatusCode.NO_PERMISSION.getStatusCode()
-            + ": Access Denied: No permissions for this operation, only root user is allowed",
-        USER_1,
-        PASSWORD);
-    // user2 without select on information_schema.queries
-    tableAssertTestFail(
-        "SHOW QUERIES",
-        TSStatusCode.NO_PERMISSION.getStatusCode()
-            + ": Access Denied: No permissions for this operation, only root user is allowed",
-        USER_2,
-        PASSWORD);
+    // non-root users can access its own queries
+    expectedHeader =
+        new String[] {"query_id", "start_time", "datanode_id", "elapsed_time", "statement", "user"};
+    tableQueryNoVerifyResultTest("show queries", expectedHeader, USER_2, PASSWORD);
 
     // case 13: kill query
     // user2

integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java

@@ -514,12 +514,50 @@ public void testInformationSchema() throws SQLException {
           "ColumnName,DataType,Category,",
           new HashSet<>(Arrays.asList("word,STRING,TAG,", "reserved,INT32,ATTRIBUTE,")));
 
-      // Currently only root can query information_schema
+      // Only root user is allowed
+      Assert.assertThrows(SQLException.class, () -> statement.execute("select * from regions"));
+      Assert.assertThrows(SQLException.class, () -> statement.execute("select * from pipes"));
+      Assert.assertThrows(SQLException.class, () -> statement.execute("select * from topics"));
       Assert.assertThrows(
-          SQLException.class,
-          () -> {
-            statement.execute("select * from databases");
-          });
+          SQLException.class, () -> statement.execute("select * from subscriptions"));
+      Assert.assertThrows(
+          SQLException.class, () -> statement.execute("select * from configurations"));
+
+      // No auth needed
+      TestUtils.assertResultSetEqual(
+          statement.executeQuery(
+              "select * from pipe_plugins where plugin_name = 'IOTDB-THRIFT-SINK'"),
+          "plugin_name,plugin_type,class_name,plugin_jar,",
+          Collections.singleton(
+              "IOTDB-THRIFT-SINK,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftConnector,null,"));
+
+      TestUtils.assertResultSetEqual(
+          statement.executeQuery(
+              "select model_id from information_schema.models where model_type = 'BUILT_IN_FORECAST'"),
+          "model_id,",
+          new HashSet<>(
+              Arrays.asList(
+                  "_timerxl,",
+                  "_STLForecaster,",
+                  "_NaiveForecaster,",
+                  "_ARIMA,",
+                  "_ExponentialSmoothing,")));
+
+      TestUtils.assertResultSetEqual(
+          statement.executeQuery(
+              "select distinct(function_type) from information_schema.functions"),
+          "function_type,",
+          new HashSet<>(
+              Arrays.asList(
+                  "built-in scalar function,",
+                  "built-in aggregate function,",
+                  "built-in table function,")));
+
+      TestUtils.assertResultSetEqual(
+          statement.executeQuery(
+              "select * from information_schema.keywords where reserved > 0 limit 1"),
+          "word,reserved,",
+          Collections.singleton("AINODES,1,"));
     }
 
     try (final Connection connection =
@@ -715,6 +753,8 @@ public void testDBAuth() throws SQLException {
         final Statement adminStmt = adminCon.createStatement()) {
       adminStmt.execute("create user test 'password'");
       adminStmt.execute("create database db");
+      adminStmt.execute(
+          "create pipe a2b with source('double-living'='true') with sink ('sink'='write-back-sink')");
     }
 
     try (final Connection userCon =
@@ -724,6 +764,10 @@ public void testDBAuth() throws SQLException {
           userStmt.executeQuery("show databases"),
           "Database,TTL(ms),SchemaReplicationFactor,DataReplicationFactor,TimePartitionInterval,",
           Collections.singleton("information_schema,INF,null,null,null,"));
+      TestUtils.assertResultSetEqual(
+          userStmt.executeQuery("select * from information_schema.databases"),
+          "database,ttl(ms),schema_replication_factor,data_replication_factor,time_partition_interval,schema_region_group_num,data_region_group_num,",
+          Collections.singleton("information_schema,INF,null,null,null,null,null,"));
     }
 
     try (final Connection adminCon = EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);

integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableIT.java

@@ -636,11 +636,15 @@ public void testTableAuth() throws SQLException {
     try (final Connection userCon =
             EnvFactory.getEnv().getConnection("test", "password", BaseEnv.TABLE_SQL_DIALECT);
         final Statement userStmt = userCon.createStatement()) {
-      Assert.assertThrows(
-          SQLException.class,
-          () -> {
-            userStmt.execute("select * from db.test");
-          });
+      Assert.assertThrows(SQLException.class, () -> userStmt.execute("select * from db.test"));
+      TestUtils.assertResultSetEqual(
+          userStmt.executeQuery("select * from information_schema.tables where database = 'db'"),
+          "database,table_name,ttl(ms),status,comment,table_type,",
+          Collections.emptySet());
+      TestUtils.assertResultSetEqual(
+          userStmt.executeQuery("select * from information_schema.columns where database = 'db'"),
+          "database,table_name,column_name,datatype,category,status,comment,",
+          Collections.emptySet());
     }
 
     try (final Connection adminCon = EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);