mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-08-22 00:01:34 +00:00
+1257
-234
File diff suppressed because it is too large
Load Diff
@@ -5,7 +5,7 @@ edition = "2024"
|
||||
|
||||
[dependencies]
|
||||
chrono = "0.4.41"
|
||||
duckdb = { rev = "fe0702529de6ec5a568337726bba9355503157d2", git = "https://github.com/windmill-labs/duckdb-rs.git", features = ["bundled"] }
|
||||
duckdb = { version = "1.4.4", features = ["bundled"] }
|
||||
rust_decimal = "1.37.2"
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
serde_json = { version = "^1", features = ["preserve_order", "raw_value"] }
|
||||
|
||||
@@ -4,7 +4,7 @@ use std::{
|
||||
ptr::null_mut,
|
||||
};
|
||||
|
||||
use duckdb::{Row, params_from_iter, types::TimeUnit};
|
||||
use duckdb::{Row, core::LogicalTypeId, params_from_iter, types::TimeUnit};
|
||||
use rust_decimal::{Decimal, prelude::FromPrimitive};
|
||||
use serde::Deserialize;
|
||||
use serde_json::value::RawValue;
|
||||
@@ -267,7 +267,10 @@ fn do_duckdb_inner(
|
||||
(0..stmt.column_count())
|
||||
.map(|i| {
|
||||
let logical_type = stmt.column_logical_type(i);
|
||||
if logical_type.is_invalid() {
|
||||
let logical_type_id = logical_type.id();
|
||||
let invalid = logical_type_id == LogicalTypeId::Invalid
|
||||
|| logical_type_id == LogicalTypeId::Unsupported;
|
||||
if invalid {
|
||||
None
|
||||
} else {
|
||||
logical_type.get_alias()
|
||||
|
||||
Reference in New Issue
Block a user