chore(query): parse json support decimal data type (#18282)

* chore(query): parse json support decimal data type

* fix

* fix

* fix copy into

Author: b41sh

Cargo.lock

@@ -233,7 +233,7 @@ deltalake = "0.18"
 derive-visitor = { version = "0.4.0", features = ["std-types-drive"] }
 derive_more = "0.99.17"
 enumflags2 = { version = "0.7.7", features = ["serde"] }
-ethnum = { version = "1.5.0" }
+ethnum = { version = "1.5.1" }
 feature-set = { version = "0.1.1" }
 flatbuffers = "24" # Must use the same version with arrow-ipc
 futures = "0.3.24"
@@ -245,8 +245,8 @@ geozero = { version = "0.13.0", features = ["default", "with-wkb", "with-geos",
 hashbrown = { version = "0.14.3", default-features = false }
 http = "1"
 itertools = "0.10.5"
-jsonb = "0.4.1"
-jwt-simple = "0.11.0"
+jsonb = "0.5.2"
+jwt-simple = { version = "0.12.12", default-features = false, features = ["pure-rust"] }
 match-template = "0.0.1"
 mysql_async = { version = "0.34", default-features = false, features = ["native-tls-tls"] }
 object_store_opendal = "0.46"
@@ -271,7 +271,7 @@ opendal = { version = "0.49.0", features = [
     "services-huggingface",
     "services-redis",
 ] }
-openraft = { git = "https://github.com/drmingdrmer/openraft", tag = "v0.10.0-alpha.6", features = [
+openraft = { git = "https://github.com/databendlabs/openraft", tag = "v0.10.0-alpha.7", features = [
     "serde",
     "tracing-log",
     "loosen-follower-log-revert", # allows removing all data from a follower and restoring from the leader.
@@ -414,7 +414,7 @@ async-recursion = { git = "https://github.com/zhang2014/async-recursion.git", re
 backtrace = { git = "https://github.com/rust-lang/backtrace-rs.git", rev = "72265be" }
 color-eyre = { git = "https://github.com/eyre-rs/eyre.git", rev = "e5d92c3" }
 deltalake = { git = "https://github.com/delta-io/delta-rs", rev = "57795da" }
-ethnum = { git = "https://github.com/ariesdevil/ethnum-rs", rev = "4cb05f1" }
+jsonb = { git = "https://github.com/databendlabs/jsonb.git", rev = "edd714b" }
 openai_api_rust = { git = "https://github.com/datafuse-extras/openai-api", rev = "819a0ed" }
 # patched opendal which categories the XML dersierialization errors as recoverable
 opendal = { git = "https://github.com/datafuse-extras/opendal-for-release-v1.2.636", tag = "v0.49.0-xml-deser-retry" }

Cargo.toml

@@ -16,7 +16,7 @@ databend-common-base = { workspace = true }
 databend-common-exception = { workspace = true }
 hickory-resolver = "0.24"
 hyper = "0.14.20"
-jwt-simple = "0.11.0"
+jwt-simple = { workspace = true }
 log = { workspace = true }
 serde = { workspace = true }
 thiserror = { workspace = true }

src/common/grpc/Cargo.toml

@@ -13,7 +13,7 @@ test = true
 [dependencies]
 databend-common-base = { workspace = true }
 databend-common-exception = { workspace = true }
-jwt-simple = "0.11.0"
+jwt-simple = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
 

src/common/license/Cargo.toml

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

src/query/expression/Cargo.toml

@@ -13,10 +13,10 @@
 // limitations under the License.
 
 use databend_common_base::base::OrderedFloat;
-use ethnum::i256;
 
 use crate::types::decimal::DecimalType;
 use crate::types::geometry::GeometryType;
+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;
@@ -24,6 +23,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::ArgType;

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

@@ -16,13 +16,13 @@ use bumpalo::Bump;
 use databend_common_arrow::arrow::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

@@ -325,7 +325,7 @@ impl Column {
                     let values = unsafe {
                         std::mem::transmute::<
                             Buffer<databend_common_arrow::arrow::types::i256>,
-                            Buffer<ethnum::I256>,
+                            Buffer<crate::types::i256>,
                         >(arrow_col.values().clone())
                     };
                     Column::Decimal(DecimalColumn::Decimal256(values, DecimalSize {

src/query/expression/src/converts/arrow2/from.rs

@@ -285,7 +285,7 @@ impl Column {
             Column::Decimal(DecimalColumn::Decimal256(col, _)) => {
                 let values = unsafe {
                     std::mem::transmute::<
-                        Buffer<ethnum::I256>,
+                        Buffer<crate::types::i256>,
                         Buffer<databend_common_arrow::arrow::types::i256>,
                     >(col.clone())
                 };