public static void createTable(final Connection conn, final OceanBaseTableInfo tableInfo) throws Exception {
        if (checkTablesExist(conn, tableInfo.getDbName(), tableInfo.getTableName())) {
            LOGGER.info("The table [{}] are exists", tableInfo.getTableName());
        } else {
            final String createTableSql = OceanBaseSqlBuilder.buildCreateTableSql(tableInfo);
            executeSql(conn, createTableSql);
            LOGGER.info("execute sql [{}] success", createTableSql);
        }
    }
Create OceanBase table by OceanBaseTableInfo

@param conn JDBC {@link Connection}
@param tableInfo table info  {@link OceanBaseTableInfo}
@throws Exception on create table error
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java