public static String buildCreateTableSql(MySQLTableInfo table) {
        final StringBuilder sql = new StringBuilder()
                .append("CREATE TABLE ").append(table.getDbName())
                .append(".")
                .append(table.getTableName())
                .append(buildCreateColumnsSql(table));

        if (StringUtils.isEmpty(table.getEngine())) {
            sql.append(" ENGINE=InnoDB ");
        } else {
            sql.append(" ENGINE=")
                    .append(table.getEngine())
                    .append(" ");
        }

        if (!StringUtils.isEmpty(table.getCharset())) {
            sql.append(" DEFAULT CHARSET=")
                    .append(table.getCharset())
                    .append(" ");
        }

        LOGGER.info("create table sql: {}", sql);
        return sql.toString();
    }
Build create table SQL by MySQLTableInfo.

@param table MySQL table info {@link MySQLTableInfo}
@return the create table SQL String
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/mysql/MySQLSqlBuilder.java