feat(query): variant support extension types(Decimal, Binary, Date, Timestamp, Interval) (#17835)

* feat: variant type support extension types

* fix

* fix

* wrap i256

* fix

* fix

* fix

* fix

* fix

* fix

* fix

* add i256 comment

* fix

Author: b41sh

Cargo.lock

@@ -306,7 +306,7 @@ enquote = "1.1.0"
 enum-as-inner = "0.6"
 enum_dispatch = "0.3.13"
 enumflags2 = { version = "0.7.7", features = ["serde"] }
-ethnum = { version = "1.5.0" }
+ethnum = { version = "1.5.1" }
 faststr = "0.2"
 feature-set = { version = "0.1.1" }
 flatbuffers = "24" # Must use the same version with arrow-ipc
@@ -350,7 +350,7 @@ jaq-core = "1.5.1"
 jaq-interpret = "1.5.0"
 jaq-parse = "1.0.3"
 jaq-std = "1.6.0"
-jiff = { version = "0.2.1", features = ["serde", "tzdb-bundle-always"] }
+jiff = { version = "0.2.10", features = ["serde", "tzdb-bundle-always"] }
 jsonb = "0.5.1"
 jwt-simple = { version = "0.12.10", default-features = false, features = ["pure-rust"] }
 lenient_semver = "0.4.2"
@@ -637,7 +637,7 @@ backtrace = { git = "https://github.com/rust-lang/backtrace-rs.git", rev = "7226
 color-eyre = { git = "https://github.com/eyre-rs/eyre.git", rev = "e5d92c3" }
 deltalake = { git = "https://github.com/delta-io/delta-rs", rev = "c149502" }
 display-more = { git = "https://github.com/databendlabs/display-more", tag = "v0.1.2" }
-ethnum = { git = "https://github.com/datafuse-extras/ethnum-rs", rev = "4cb05f1" }
+jsonb = { git = "https://github.com/databendlabs/jsonb", rev = "dcaf261" }
 map-api = { git = "https://github.com/databendlabs/map-api", tag = "v0.2.3" }
 openai_api_rust = { git = "https://github.com/datafuse-extras/openai-api", rev = "819a0ed" }
 openraft = { git = "https://github.com/databendlabs/openraft", tag = "v0.10.0-alpha.9" }

Cargo.toml

@@ -18,7 +18,6 @@ bytemuck = { workspace = true }
 byteorder = { workspace = true }
 bytes = { workspace = true }
 env_logger = { workspace = true }
-ethnum = { workspace = true }
 hashbrown_v0_14 = { workspace = true }
 log = { workspace = true }
 lz4 = { workspace = true }

src/common/native/Cargo.toml

@@ -73,7 +73,11 @@ pub fn read_nested_column<R: NativeReadBuf>(
         ),
         Decimal(decimal) if decimal.precision() > MAX_DECIMAL128_PRECISION => {
             init.push(InitNested::Primitive(is_nullable));
-            read_nested_decimal::<databend_common_column::types::i256, ethnum::i256, _>(
+            read_nested_decimal::<
+                databend_common_column::types::i256,
+                databend_common_expression::types::i256,
+                _,
+            >(
                 &mut readers.pop().unwrap(),
                 data_type.clone(),
                 decimal.size(),

src/common/native/src/read/batch_read.rs

@@ -164,7 +164,7 @@ where
             DynIter::new(DecimalNestedIter::<
                 _,
                 databend_common_column::types::i256,
-                ethnum::i256,
+                databend_common_expression::types::i256,
             >::new(
                 readers.pop().unwrap(), data_type.clone(), t.size(), init
             ))

src/common/native/src/read/deserialize.rs

@@ -31,7 +31,7 @@ databend-common-io = { workspace = true }
 educe = { workspace = true }
 either = { workspace = true }
 enum-as-inner = { workspace = true }
-ethnum = { workspace = true, features = ["serde", "macros", "borsh"] }
+ethnum = { workspace = true, features = ["serde", "macros"] }
 futures = { workspace = true }
 geo = { workspace = true }
 geozero = { workspace = true }

src/query/expression/Cargo.toml

@@ -17,8 +17,8 @@ use databend_common_column::bitmap::Bitmap;
 use databend_common_column::buffer::Buffer;
 use databend_common_column::types::Index;
 use databend_common_exception::Result;
-use ethnum::i256;
 
+use crate::types::i256;
 use crate::types::AnyType;
 use crate::types::ArgType;
 use crate::types::BinaryType;

src/query/expression/src/aggregate/group_hash.rs

@@ -14,7 +14,6 @@
 
 use databend_common_exception::Result;
 use databend_common_io::prelude::bincode_deserialize_from_slice;
-use ethnum::i256;
 
 use super::partitioned_payload::PartitionedPayload;
 use super::payload::Payload;
@@ -25,6 +24,7 @@ use crate::types::binary::BinaryColumn;
 use crate::types::binary::BinaryColumnBuilder;
 use crate::types::decimal::Decimal;
 use crate::types::decimal::DecimalType;
+use crate::types::i256;
 use crate::types::nullable::NullableColumn;
 use crate::types::string::StringColumn;
 use crate::types::string::StringColumnBuilder;

src/query/expression/src/aggregate/payload_flush.rs

@@ -16,13 +16,13 @@ use bumpalo::Bump;
 use databend_common_column::bitmap::Bitmap;
 use databend_common_io::prelude::bincode_deserialize_from_slice;
 use databend_common_io::prelude::bincode_serialize_into_buf;
-use ethnum::i256;
 
 use crate::read;
 use crate::store;
 use crate::types::binary::BinaryColumn;
 use crate::types::decimal::DecimalColumn;
 use crate::types::decimal::DecimalType;
+use crate::types::i256;
 use crate::types::AnyType;
 use crate::types::ArgType;
 use crate::types::BinaryType;

src/query/expression/src/aggregate/payload_row.rs

@@ -14,12 +14,12 @@
 
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
-use ethnum::i256;
 
 use crate::arrow::and_validities;
 use crate::filter::SelectOp;
 use crate::filter::SelectStrategy;
 use crate::types::decimal::DecimalType;
+use crate::types::i256;
 use crate::types::nullable::NullableColumn;
 use crate::types::number::*;
 use crate::types::AnyType;