private void buildSchemaByShowCreateTable(
            JdbcConnection jdbc, TableId tableId, Map<TableId, TableChange> tableChangeMap) {
        final String sql = SHOW_CREATE_TABLE + quote(tableId);
        try {
            jdbc.query(
                    sql,
                    rs -> {
                        if (rs.next()) {
                            final String ddl = rs.getString(2);
                            parseSchemaByDdl(ddl, tableId, tableChangeMap);
                        }
                    });
        } catch (SQLException e) {
            throw new FlinkRuntimeException(
                    String.format("Failed to read schema for table %s by running %s", tableId, sql),
                    e);
        }
    }
Gets table schema for the given table path. It will request to MySQL server by running `SHOW
CREATE TABLE` if cache missed.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/schema/MySqlSchema.java