public static void createSchema(final Connection conn, final String schemaName) throws Exception {
        if (!checkSchemaExist(conn, schemaName)) {
            final String createSql = SQLServerSqlBuilder.buildCreateSchemaSql(schemaName);
            executeSql(conn, createSql);
            LOG.info("execute sql [{}] success", createSql);
        } else {
            LOG.info("The schemaName [{}] are exists", schemaName);
        }
    }
create SQLServer schema

@param conn JDBC Connection  {@link Connection}
@param schemaName SQLServer schema name
@throws Exception on create schema error
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/sqlserver/SQLServerJdbcUtils.java