@Transient
    public String getFlinkTableSql(String catalogName, String flinkConfig) {
        String createSql = getFlinkDDL(getFlinkTableWith(flinkConfig), name);
        return String.format("DROP TABLE IF EXISTS %s;\n%s", name, createSql);
    }
@Test
    void getFlinkTableSql() {
        String result = table.getFlinkTableSql("CatalogName", flinkConfig);
        assertThat(
                result,
                equalTo("DROP TABLE IF EXISTS TableNameOrigin;\n"
                        + "CREATE TABLE IF NOT EXISTS TableNameOrigin (\n"
                        + "    `column1` INT NOT NULL COMMENT 'comment abc',\n"
                        + "    `column2` STRING COMMENT 'comment abc',\n"
                        + "    `column3` DOUBLE NOT NULL COMMENT 'comment abc',\n"
                        + "    PRIMARY KEY ( `column1`,`column2` ) NOT ENFORCED\n"
                        + ") WITH (\n"
                        + "SchemaOrigin=schemaName, TableNameOrigin=tableName, #{abc}=abc,"
                        + " #{}=null, bcd=bcd)\n"));
    }