public static void addColumns(final Connection conn, final String schemaName, final String tableName,
            final List<PostgreSQLColumnInfo> columns) throws Exception {
        final List<PostgreSQLColumnInfo> columnInfos = new ArrayList<>();

        for (PostgreSQLColumnInfo columnInfo : columns) {
            if (!checkColumnExist(conn, schemaName, tableName, columnInfo.getName())) {
                columnInfos.add(columnInfo);
            }
        }
        final List<String> addColumnSql = PostgreSQLSqlBuilder.buildAddColumnsSql(schemaName, tableName, columnInfos);
        executeSqlBatch(conn, addColumnSql);
        LOG.info("execute add columns sql [{}] success", addColumnSql);
    }
Add columns for Greenpluum table.

@param conn JDBC Connection  {@link Connection}
@param schemaName PostgreSQL schema name
@param tableName PostgreSQL table name
@param columns PostgreSQL columns to be added
@throws Exception on add columns error
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/postgresql/PostgreSQLJdbcUtils.java