MonetDB: parquet - fix duplicate column names

[Mitchell Weggemans]

Changeset: 0d13fc4def43 for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/0d13fc4def43
Modified Files:
        sql/backends/monet5/vaults/parquet/parquet.c
Branch: parquet
Log Message:

fix duplicate column names


diffs (43 lines):

diff --git a/sql/backends/monet5/vaults/parquet/parquet.c 
b/sql/backends/monet5/vaults/parquet/parquet.c
--- a/sql/backends/monet5/vaults/parquet/parquet.c
+++ b/sql/backends/monet5/vaults/parquet/parquet.c
@@ -144,7 +144,7 @@ parquet_add_types(mvc *sql, sql_subfunc 
 
        guint n_columns = garrow_table_get_n_columns(table);
 
-       list *types = sa_list(sql->sa);
+       // list *types = sa_list(sql->sa);
 
        if (!tname)
                tname = "parquet";
@@ -152,16 +152,16 @@ parquet_add_types(mvc *sql, sql_subfunc 
        for(int col = 0; col < (int)n_columns; col++) {
                GArrowChunkedArray *array = garrow_table_get_column_data(table, 
col);
                GArrowType type = garrow_chunked_array_get_value_type(array);
-               char *name = "column name";
+    char buff[25];
+    snprintf(buff, 100, "name_%i", col);
+    str name = GDKstrdup(buff);
                char* st = parquet_type_map(type);
 
-               printf("%s\n", st);
-
                if(st) {
                        sql_subtype *t = sql_bind_subtype(sql->sa, st, 0, 0);
 
-                       list_append(types, t);
-                       list_append(res_exps, exp_column(sql->sa, tname, name, 
t, CARD_MULTI, 1, 0, 0));
+                       // list_append(types, t);
+                       list_append(res_exps, exp_column(sql->sa, NULL, name, 
t, CARD_MULTI, 1, 0, 0));
                }
                else {
                        throw(SQL, SQLSTATE(42000), "parquet" 
RUNTIME_LOAD_ERROR); // TODO: this should throw a 'unsupported column type' 
error.
@@ -170,7 +170,7 @@ parquet_add_types(mvc *sql, sql_subfunc 
 
        (void)table;
        /* cleanup tbl */
-       f->res = types;
+       f->res = res_exps;
 
        /* close file */
        GDKfree(file);
_______________________________________________
checkin-list mailing list -- checkin-list@monetdb.org
To unsubscribe send an email to checkin-list-le...@monetdb.org