Added show create pipe/database/topic (#17702)

* ut

* show create

* fix

* Update IoTDBDatabaseIT.java

* Update IoTDBSubscriptionTopicIT.java

* Remove tree model show create topic syntax

* Address show create review comments

* Fixed

Author: Caideyipi

.github/scripts/package-client-cpp-manylinux228.sh

@@ -293,6 +293,66 @@ public void testManageDatabase() {
     }
   }
 
+  @Test
+  public void testShowCreateDatabase() throws SQLException {
+    try (final Connection connection =
+            EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);
+        final Statement statement = connection.createStatement()) {
+      statement.execute(
+          "create database test_show_create_db with (ttl=300, max_schema_region_group_num=DEFAULT, max_data_region_group_num=DEFAULT, time_partition_interval=100000)");
+
+      try (final ResultSet resultSet =
+          statement.executeQuery("show create database test_show_create_db")) {
+        assertTrue(resultSet.next());
+        assertEquals("test_show_create_db", resultSet.getString("Database"));
+        final String createDatabaseSQL = resultSet.getString("Create Database");
+        assertTrue(
+            createDatabaseSQL,
+            createDatabaseSQL.startsWith("CREATE DATABASE \"test_show_create_db\" WITH ("));
+        assertTrue(createDatabaseSQL, createDatabaseSQL.contains("ttl=300"));
+        assertTrue(createDatabaseSQL, createDatabaseSQL.contains("time_partition_interval=100000"));
+        assertTrue(createDatabaseSQL, createDatabaseSQL.contains("max_schema_region_group_num="));
+        assertTrue(createDatabaseSQL, createDatabaseSQL.contains("max_data_region_group_num="));
+        assertFalse(resultSet.next());
+      }
+    }
+  }
+
+  @Test
+  public void testShowCreatePipe() throws SQLException {
+    try (final Connection connection =
+            EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);
+        final Statement statement = connection.createStatement()) {
+      statement.execute("create pipe test_show_create_pipe ('sink'='do-nothing-sink')");
+
+      TestUtils.assertResultSetEqual(
+          statement.executeQuery("show create pipe test_show_create_pipe"),
+          "Pipe,Create Pipe,",
+          Collections.singleton(
+              "test_show_create_pipe,CREATE PIPE \"test_show_create_pipe\" WITH SINK ('sink'='do-nothing-sink'),"));
+    }
+  }
+
+  @Test
+  public void testShowCreateInformationSchemaDatabase() throws SQLException {
+    try (final Connection connection =
+            EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);
+        final Statement statement = connection.createStatement()) {
+      assertShowCreateSystemDatabaseFails(statement, "information_schema");
+      assertShowCreateSystemDatabaseFails(statement, "__audit");
+    }
+  }
+
+  private static void assertShowCreateSystemDatabaseFails(
+      final Statement statement, final String database) throws SQLException {
+    try {
+      statement.executeQuery("show create database " + database);
+      fail("show create database " + database + " shouldn't succeed");
+    } catch (final SQLException e) {
+      assertEquals("701: The system database does not support show create.", e.getMessage());
+    }
+  }
+
   @Test
   public void testDatabaseWithSpecificCharacters() throws SQLException {
     try (final Connection connection =

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

@@ -28,6 +28,7 @@
 import org.apache.iotdb.isession.ITableSession;
 import org.apache.iotdb.it.framework.IoTDBTestRunner;
 import org.apache.iotdb.itbase.category.MultiClusterIT2SubscriptionTableArchVerification;
+import org.apache.iotdb.itbase.env.BaseEnv;
 import org.apache.iotdb.pipe.it.dual.tablemodel.TableModelUtils;
 import org.apache.iotdb.rpc.RpcUtils;
 import org.apache.iotdb.rpc.subscription.config.TopicConstant;
@@ -52,6 +53,9 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.sql.Connection;
+import java.sql.Statement;
+import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
 import java.util.Properties;
@@ -100,6 +104,29 @@ protected void setUpConfig() {
         .setIsPipeEnableMemoryCheck(false);
   }
 
+  @Ignore
+  @Test
+  public void testShowCreateTopic() throws Exception {
+    TableModelUtils.createDataBaseAndTable(
+        senderEnv, "test_show_create_topic_db", "test_show_create_topic_table");
+
+    try (final Connection connection = senderEnv.getConnection(BaseEnv.TABLE_SQL_DIALECT);
+        final Statement statement = connection.createStatement()) {
+      statement.execute(
+          "create topic test_show_create_topic with ('database'='test_show_create_topic_db','table'='test_show_create_topic_table','format'='"
+              + TopicConstant.FORMAT_TS_FILE_VALUE
+              + "')");
+
+      TestUtils.assertResultSetEqual(
+          statement.executeQuery("show create topic test_show_create_topic"),
+          "Topic,Create Topic,",
+          Collections.singleton(
+              "test_show_create_topic,CREATE TOPIC \"test_show_create_topic\" WITH ('database'='test_show_create_topic_db','format'='"
+                  + TopicConstant.FORMAT_TS_FILE_VALUE
+                  + "','table'='test_show_create_topic_table'),"));
+    }
+  }
+
   @Ignore
   @Test
   public void testTabletTopicWithPath() throws Exception {

integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/tablemodel/IoTDBSubscriptionTopicIT.java

@@ -131,6 +131,8 @@ public final class DataNodePipeMessages {
       "Failed to decrease reference count for event {} in PipeRealtimePriorityBlockingQueue";
   public static final String FAILED_TO_GET_PENDINGQUEUE_NO_SUCH_SUBTASK =
       "Failed to get PendingQueue. No such subtask: ";
+  public static final String FAILED_TO_GET_PIPE_INFO_FROM_CONFIG_NODE_STATUS =
+      "Failed to get pipe info from config node, status is %s.";
   public static final String FAILED_TO_GET_PIPE_METAS_WILL_BE =
       "Failed to get pipe metas, will be synced by configNode later...";
   public static final String FAILED_TO_GET_PIPE_PLUGIN_JAR_FROM =
@@ -224,6 +226,10 @@ public final class DataNodePipeMessages {
       "Pipe skipping temporary TsFile which shouldn't be transferred: {}";
   public static final String PULLED_PIPE_META_FROM_CONFIG_NODE_RECOVERING =
       "Pulled pipe meta from config node: {}, recovering ...";
+  public static final String FAILED_TO_SHOW_CREATE_PIPE_NOT_EXIST =
+      "Failed to show create pipe %s, the pipe does not exist.";
+  public static final String FAILED_TO_SHOW_CREATE_TOPIC_NOT_EXIST =
+      "Failed to show create topic %s, the topic does not exist.";
   public static final String RECEIVED_PIPE_HEARTBEAT_REQUEST_FROM_CONFIG_NODE =
       "Received pipe heartbeat request {} from config node.";
   public static final String REGION_NO_TSFILEINSERTIONEVENTS_TO_REPLACE_FOR_SOURCE =

iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java

@@ -301,6 +301,7 @@ public final class DataNodeQueryMessages {
       "select into: the i of ${i} should be an integer.";
   public static final String FAILED_TO_GET_DATABASE_MAP =
       "Failed to get database Map";
+  public static final String UNKNOWN_DATABASE = "Unknown database %s";
   public static final String LOAD_ANALYSIS_STAGE_ALL_TSFILES_HAVE_BEEN_ANALYZED =
       "Load - Analysis Stage: all tsfiles have been analyzed.";
   public static final String ASYNC_LOAD_HAS_FAILED_AND_IS_NOW_TRYING =

iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java

@@ -396,6 +396,8 @@ public final class DataNodeSchemaMessages {
 
   public static final String SYSTEM_VIEW_NOT_SUPPORT_SHOW_CREATE =
       "The system view does not support show create.";
+  public static final String SYSTEM_DATABASE_NOT_SUPPORT_SHOW_CREATE =
+      "The system database does not support show create.";
 
   // ======================== Traverser ========================
 

iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeSchemaMessages.java

@@ -217,6 +217,10 @@ public final class DataNodePipeMessages {
       "Pipe 跳过不应传输的临时 TsFile：{}";
   public static final String PULLED_PIPE_META_FROM_CONFIG_NODE_RECOVERING =
       "已从 config node 拉取 pipe 元数据：{}，正在恢复 ...";
+  public static final String FAILED_TO_SHOW_CREATE_PIPE_NOT_EXIST =
+      "show create pipe %s 失败，该 pipe 不存在。";
+  public static final String FAILED_TO_SHOW_CREATE_TOPIC_NOT_EXIST =
+      "show create topic %s 失败，该 topic 不存在。";
   public static final String RECEIVED_PIPE_HEARTBEAT_REQUEST_FROM_CONFIG_NODE =
       "收到来自 config node 的 pipe 心跳请求 {}。";
   public static final String REGION_NO_TSFILEINSERTIONEVENTS_TO_REPLACE_FOR_SOURCE =

iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java

@@ -299,6 +299,7 @@ public final class DataNodeQueryMessages {
       "SELECT INTO：${i} 中的 i 应为整数。";
   public static final String FAILED_TO_GET_DATABASE_MAP =
       "获取数据库映射失败";
+  public static final String UNKNOWN_DATABASE = "未知数据库 %s";
   public static final String LOAD_ANALYSIS_STAGE_ALL_TSFILES_HAVE_BEEN_ANALYZED =
       "加载 - 分析阶段：所有 TsFile 已分析完毕。";
   public static final String ASYNC_LOAD_HAS_FAILED_AND_IS_NOW_TRYING =

iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java

@@ -395,6 +395,8 @@ public final class DataNodeSchemaMessages {
 
   public static final String SYSTEM_VIEW_NOT_SUPPORT_SHOW_CREATE =
       "系统视图不支持 show create。";
+  public static final String SYSTEM_DATABASE_NOT_SUPPORT_SHOW_CREATE =
+      "系统数据库不支持 show create。";
 
   // ======================== 附加 SchemaRegion 相关消息 ========================
 

iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeSchemaMessages.java

@@ -263,6 +263,18 @@ public static DatasetHeader getShowCreateTableColumnHeader() {
     return new DatasetHeader(ColumnHeaderConstant.showCreateTableColumnHeaders, true);
   }
 
+  public static DatasetHeader getShowCreatePipeColumnHeader() {
+    return new DatasetHeader(ColumnHeaderConstant.showCreatePipeColumnHeaders, true);
+  }
+
+  public static DatasetHeader getShowCreateTopicColumnHeader() {
+    return new DatasetHeader(ColumnHeaderConstant.showCreateTopicColumnHeaders, true);
+  }
+
+  public static DatasetHeader getShowCreateDatabaseColumnHeader() {
+    return new DatasetHeader(ColumnHeaderConstant.showCreateDatabaseColumnHeaders, true);
+  }
+
   public static DatasetHeader getShowTablesHeader() {
     return new DatasetHeader(ColumnHeaderConstant.showTablesColumnHeaders, true);
   }