kalugin66/windmill
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: temporary fix for duckdb type_aliases causing issues (#7148)

Browse Source
This commit is contained in:
Diego Imbert
2025-11-15 19:10:05 +01:00
committed by GitHub
parent 8b2231c81f
commit c47481da12
1 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
backend/windmill-duckdb-ffi-internal/src/lib.rs
View File

@@ -245,7 +245,7 @@ fn do_duckdb_inner(
}
// Statement needs to be stepped at least once or stmt.column_names() will panic
let mut column_names = None;
let mut type_aliases = None;
// let mut type_aliases = None;
loop {
let row = rows.next();
match row {
@@ -260,17 +260,18 @@ fn do_duckdb_inner(
column_names.as_ref().unwrap()
}
};
let type_aliases = match type_aliases.as_ref() {
Some(type_aliases) => type_aliases,
None => {
type_aliases = Some(
(0..stmt.column_count())
.map(|i| stmt.column_logical_type(i).get_alias())
.collect::<Vec<_>>(),
);
type_aliases.as_ref().unwrap()
}
};
// let type_aliases = match type_aliases.as_ref() {
// Some(type_aliases) => type_aliases,
// None => {
// type_aliases = Some(
// (0..stmt.column_count())
// .map(|i| stmt.column_logical_type(i).get_alias())
// .collect::<Vec<_>>(),
// );
// type_aliases.as_ref().unwrap()
// }
// };
let type_aliases = (0..stmt.column_count()).map(|_| None).collect::<Vec<_>>();
let row = row_to_value(row, &column_names.as_slice(), &type_aliases.as_slice())
.map_err(|e| e.to_string())?;