diff --git a/Cargo.lock b/Cargo.lock
index 1273c8193532..50049c413c20 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -611,7 +611,7 @@ source = "git+https://github.com/datafuse-extras/async-backtrace.git?rev=dea4553
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -712,7 +712,7 @@ source = "git+https://github.com/datafuse-extras/async-recursion.git?rev=a353334
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -734,7 +734,7 @@ checksum = "16e62a023e7c117e27523144c5d2459f4397fcc3cab0085af8e2224f643a0193"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -751,7 +751,7 @@ checksum = "d556ec1359574147ec0c4fc5eb525f3f23263a592b1a9c07e0a75b427de55c97"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -1322,7 +1322,7 @@ dependencies = [
  "regex",
  "rustc-hash 1.1.0",
  "shlex",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -1510,7 +1510,7 @@ dependencies = [
  "proc-macro-crate 3.1.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "syn_derive",
 ]
 
@@ -1652,7 +1652,7 @@ checksum = "1ee891b04274a59bd38b412188e24b849617b2e45a0fd8d057deb63e7403761b"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -2081,7 +2081,7 @@ dependencies = [
  "heck 0.5.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -2725,7 +2725,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "edb49164822f3ee45b17acd4a208cfc1251410cf0cad9a833234c9890774dd9f"
 dependencies = [
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -2768,7 +2768,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "strsim 0.11.1",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -2779,7 +2779,7 @@ checksum = "d336a2a514f6ccccaa3e09b02d41d35330c07ddf03a62165fcec10bb561c7806"
 dependencies = [
  "darling_core",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -3203,7 +3203,7 @@ dependencies = [
  "hex",
  "hyper-util",
  "itertools 0.13.0",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "jsonb",
  "lexical-core",
  "log",
@@ -3250,7 +3250,7 @@ dependencies = [
  "geozero",
  "goldenfile",
  "hex",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "jsonb",
  "lexical-core",
  "match-template",
@@ -3292,7 +3292,6 @@ dependencies = [
  "databend-functions-scalar-math",
  "databend-functions-scalar-numeric-basic-arithmetic",
  "divan",
- "ethnum",
  "geo",
  "geohash",
  "geozero",
@@ -3305,7 +3304,7 @@ dependencies = [
  "jaq-interpret",
  "jaq-parse",
  "jaq-std",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "jsonb",
  "lexical-core",
  "libm",
@@ -3398,7 +3397,7 @@ dependencies = [
  "geo",
  "geozero",
  "hex",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "lexical-core",
  "micromarshal",
  "rmp-serde",
@@ -3810,7 +3809,6 @@ dependencies = [
  "databend-common-column",
  "databend-common-expression",
  "env_logger 0.11.5",
- "ethnum",
  "hashbrown 0.14.5",
  "log",
  "lz4",
@@ -4372,7 +4370,6 @@ dependencies = [
  "databend-storages-common-pruner",
  "databend-storages-common-stage",
  "databend-storages-common-table-meta",
- "ethnum",
  "futures",
  "log",
  "opendal 0.53.1",
@@ -4461,7 +4458,6 @@ dependencies = [
  "databend-storages-common-stage",
  "databend-storages-common-table-meta",
  "enum-as-inner",
- "ethnum",
  "futures",
  "jsonb",
  "lexical-core",
@@ -4528,7 +4524,7 @@ dependencies = [
  "databend-storages-common-cache",
  "futures",
  "itertools 0.13.0",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "jsonb",
  "log",
  "once_cell",
@@ -4859,7 +4855,6 @@ version = "0.1.0"
 dependencies = [
  "databend-common-expression",
  "databend-functions-scalar-decimal",
- "ethnum",
  "lexical-core",
  "match-template",
  "num-traits",
@@ -4874,7 +4869,7 @@ dependencies = [
  "databend-common-exception",
  "databend-common-expression",
  "dtparse",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "num-traits",
 ]
 
@@ -4884,7 +4879,6 @@ version = "0.1.0"
 dependencies = [
  "databend-common-base",
  "databend-common-expression",
- "ethnum",
  "match-template",
  "num-traits",
 ]
@@ -5147,7 +5141,7 @@ dependencies = [
  "hyper-util",
  "indicatif",
  "itertools 0.13.0",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "jsonb",
  "jwt-simple",
  "log",
@@ -5251,7 +5245,7 @@ dependencies = [
  "derive-visitor",
  "ethnum",
  "itertools 0.13.0",
- "jiff 0.2.1",
+ "jiff 0.2.10",
  "jsonb",
  "rand 0.8.5",
  "reqwest",
@@ -5434,7 +5428,7 @@ dependencies = [
  "enum-ordinalize",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -5536,7 +5530,7 @@ checksum = "0c8e41236d5a9f04da3072d7186a76aba734e7bfd2cd05f7877fde172b65fb11"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -5674,7 +5668,7 @@ dependencies = [
  "darling",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -5684,7 +5678,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "206868b8242f27cecce124c19fd88157fbd0dd334df2587f36417bafbc85097b"
 dependencies = [
  "derive_builder_core",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -5705,7 +5699,7 @@ dependencies = [
  "convert_case 0.6.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "unicode-xid",
 ]
 
@@ -5791,7 +5785,7 @@ checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -5816,7 +5810,7 @@ checksum = "9556bc800956545d6420a640173e5ba7dfa82f38d3ea5a167eb555bc69ac3323"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -5929,7 +5923,7 @@ dependencies = [
  "enum-ordinalize",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6013,7 +6007,7 @@ dependencies = [
  "heck 0.4.1",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6033,7 +6027,7 @@ checksum = "0d28318a75d4aead5c4db25382e8ef717932d0346600cacae6357eb5941bc5ff"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6045,7 +6039,7 @@ dependencies = [
  "once_cell",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6066,7 +6060,7 @@ checksum = "de0d48a183585823424a4ce1aa132d174a6a81bd540895822eb4c8373a8e49e8"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6132,7 +6126,7 @@ checksum = "3bf679796c0322556351f287a51b49e48f7c4986e727b5dd78c972d30e2e16cc"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6186,10 +6180,10 @@ dependencies = [
 
 [[package]]
 name = "ethnum"
-version = "1.5.0"
-source = "git+https://github.com/datafuse-extras/ethnum-rs?rev=4cb05f1#4cb05f1e407f76b193d81eef71b5dd0b73216856"
+version = "1.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0939f82868b77ef93ce3c3c3daf2b3c526b456741da5a1a4559e590965b6026b"
 dependencies = [
- "borsh",
  "serde",
 ]
 
@@ -6284,7 +6278,7 @@ dependencies = [
  "proc-macro-error2",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6530,7 +6524,7 @@ checksum = "b0fa992f1656e1707946bbba340ad244f0814009ef8c0118eb7b658395f19a2e"
 dependencies = [
  "frunk_proc_macro_helpers",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6542,7 +6536,7 @@ dependencies = [
  "frunk_core",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6554,7 +6548,7 @@ dependencies = [
  "frunk_core",
  "frunk_proc_macro_helpers",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6652,7 +6646,7 @@ checksum = "5ac45ed0bddbd110eb68862768a194f88700f5b91c39931d2f432fab67a16d08"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -6717,7 +6711,7 @@ checksum = "162ee34ebcb7c64a8abebc059ce0fee27c2262618d7b60ed8faf72fef13c3650"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -7389,7 +7383,7 @@ checksum = "999ce923619f88194171a67fb3e6d613653b8d4d6078b529b15a765da0edcc17"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -8681,7 +8675,7 @@ checksum = "1ec89e9337638ecdc08744df490b221a7399bf8d164eb52a665454e60e075ad6"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -9129,10 +9123,11 @@ dependencies = [
 
 [[package]]
 name = "jiff"
-version = "0.2.1"
+version = "0.2.10"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3590fea8e9e22d449600c9bbd481a8163bef223e4ff938e5f55899f8cf1adb93"
+checksum = "5a064218214dc6a10fbae5ec5fa888d80c45d611aba169222fc272072bf7aef6"
 dependencies = [
+ "jiff-static",
  "jiff-tzdb",
  "jiff-tzdb-platform",
  "log",
@@ -9142,17 +9137,28 @@ dependencies = [
  "windows-sys 0.59.0",
 ]
 
+[[package]]
+name = "jiff-static"
+version = "0.2.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "199b7932d97e325aff3a7030e141eafe7f2c6268e1d1b24859b753a627f45254"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 2.0.100",
+]
+
 [[package]]
 name = "jiff-tzdb"
-version = "0.1.2"
+version = "0.1.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "cf2cec2f5d266af45a071ece48b1fb89f3b00b2421ac3a5fe10285a6caaa60d3"
+checksum = "c1283705eb0a21404d2bfd6eef2a7593d240bc42a0bdb39db0ad6fa2ec026524"
 
 [[package]]
 name = "jiff-tzdb-platform"
-version = "0.1.2"
+version = "0.1.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a63c62e404e7b92979d2792352d885a7f8f83fd1d0d31eea582d77b2ceca697e"
+checksum = "875a5a69ac2bab1a891711cf5eccbec1ce0341ea805560dcd90b7a2e925132e8"
 dependencies = [
  "jiff-tzdb",
 ]
@@ -9178,12 +9184,13 @@ dependencies = [
 [[package]]
 name = "jsonb"
 version = "0.5.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e7e7eadf220028b2482ef22189ee7ce946665874dcc1040d82c827ff06963fbe"
+source = "git+https://github.com/databendlabs/jsonb?rev=dcaf261#dcaf261df0f2a41ce9029a91444611c1d401e390"
 dependencies = [
  "byteorder",
+ "ethnum",
  "fast-float2",
  "itoa",
+ "jiff 0.2.10",
  "nom 8.0.0",
  "num-traits",
  "ordered-float 5.0.0",
@@ -10082,7 +10089,7 @@ dependencies = [
  "proc-macro-error 1.0.4",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "termcolor",
  "thiserror 1.0.65",
 ]
@@ -10269,7 +10276,7 @@ dependencies = [
  "proc-macro-error 1.0.4",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -10382,7 +10389,7 @@ checksum = "ed3955f1a9c7c0c15e092f9c887db08b1fc683305fdf6eb6684f22555355e202"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -10464,7 +10471,7 @@ dependencies = [
  "proc-macro-crate 3.1.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -10680,7 +10687,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "semver",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -10722,7 +10729,7 @@ checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11083,7 +11090,7 @@ dependencies = [
  "regex",
  "regex-syntax 0.8.4",
  "structmeta",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11235,7 +11242,7 @@ checksum = "2f38a4412a78282e09a2cf38d195ea5420d15ba0602cb375210efbc877243965"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11354,7 +11361,7 @@ dependencies = [
  "proc-macro-crate 3.1.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11488,7 +11495,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8d3928fb5db768cb86f891ff014f0144589297e3c6a1aba6ed7cecfdace270c7"
 dependencies = [
  "proc-macro2",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11588,7 +11595,7 @@ dependencies = [
  "proc-macro-error-attr2",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11599,9 +11606,9 @@ checksum = "dc375e1527247fe1a97d8b7156678dfe7c1af2fc075c9a4db3690ecd2a148068"
 
 [[package]]
 name = "proc-macro2"
-version = "1.0.92"
+version = "1.0.95"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "37d3544b3f2748c54e147655edb5025752e2303145b5aefb3c3ea2c78b973bb0"
+checksum = "02b3e5e68a3a1a02aad3ec490a98007cbc13c37cbe84a3cd7b8e406d76e7f778"
 dependencies = [
  "unicode-ident",
 ]
@@ -11689,7 +11696,7 @@ checksum = "440f724eba9f6996b75d63681b0a92b06947f1457076d503a4d2e2c8f56442b8"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11746,7 +11753,7 @@ dependencies = [
  "prost",
  "prost-types",
  "regex",
- "syn 2.0.95",
+ "syn 2.0.100",
  "tempfile",
 ]
 
@@ -11760,7 +11767,7 @@ dependencies = [
  "itertools 0.14.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11965,7 +11972,7 @@ dependencies = [
  "proc-macro2",
  "pyo3-macros-backend",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -11978,7 +11985,7 @@ dependencies = [
  "proc-macro2",
  "pyo3-build-config",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -12083,9 +12090,9 @@ dependencies = [
 
 [[package]]
 name = "quote"
-version = "1.0.36"
+version = "1.0.40"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0fa76aaf39101c457836aec0ce2316dbdc3ab723cdda1c6bd4e6ad4208acaca7"
+checksum = "1885c039570dc00dcb4ff087a89e185fd56bae234ddc7f056a945bf36467248d"
 dependencies = [
  "proc-macro2",
 ]
@@ -12229,7 +12236,7 @@ checksum = "8b86292cf41ccfc96c5de7165c1c53d5b4ac540c5bab9d1857acbe9eba5f1a0b"
 dependencies = [
  "proc-macro-hack",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -12282,7 +12289,7 @@ version = "0.1.1"
 source = "git+https://github.com/datafuse-extras/recursive.git?rev=6af35a1#6af35a1e59e7050f86ee19fbd0a79535d016c87d"
 dependencies = [
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -12727,7 +12734,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "rquickjs-core",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -13220,7 +13227,7 @@ checksum = "243902eda00fad750862fc144cea25caca5e20d615af0a81bee94ca738f1df1f"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -13262,7 +13269,7 @@ checksum = "6c64451ba24fc7a6a2d60fc75dd9c83c90903b19028d4eff35e88fc1e86564e9"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -13332,7 +13339,7 @@ dependencies = [
  "darling",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -13590,7 +13597,7 @@ dependencies = [
  "heck 0.5.0",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -13802,7 +13809,7 @@ dependencies = [
  "quote",
  "sqlx-core",
  "sqlx-macros-core",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -13825,7 +13832,7 @@ dependencies = [
  "sqlx-mysql",
  "sqlx-postgres",
  "sqlx-sqlite",
- "syn 2.0.95",
+ "syn 2.0.100",
  "tempfile",
  "tokio",
  "url",
@@ -14029,7 +14036,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "structmeta-derive",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14040,7 +14047,7 @@ checksum = "152a0b65a590ff6c3da95cabe2353ee04e6167c896b28e3b14478c2636c922fc"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14081,7 +14088,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "rustversion",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14237,9 +14244,9 @@ dependencies = [
 
 [[package]]
 name = "syn"
-version = "2.0.95"
+version = "2.0.100"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "46f71c0377baf4ef1cc3e3402ded576dccc315800fbc62dfc7fe04b009773b4a"
+checksum = "b09a44accad81e1ba1cd74a32461ba89dee89095ba17b32f5d03683b1b1fc2a0"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -14266,7 +14273,7 @@ dependencies = [
  "proc-macro-error 1.0.4",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14292,7 +14299,7 @@ checksum = "c8af7666ab7b6390ab78131fb5b0fce11d6b7a6951602017c35fa82800708971"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14577,7 +14584,7 @@ checksum = "ae861f7d521762a2e5524ceeb3a518fab2c06c25e217a1d7270b8c5e158c141b"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14644,7 +14651,7 @@ checksum = "ae71770322cbd277e69d762a16c444af02aa0575ac0d174f0b9562d3b37f8602"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14655,7 +14662,7 @@ checksum = "7f7cf42b4507d8ea322120659672cf1b9dbb93f8f2d4ecfd6e51350ff5b17a1d"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -14805,7 +14812,7 @@ checksum = "6e06d43f1345a3bcd39f6a56dbb7dcab2ba47e68e8ac134855e7e2bdbaf8cab8"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15015,7 +15022,7 @@ dependencies = [
  "prost-build",
  "prost-types",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15097,7 +15104,7 @@ checksum = "34704c8d6ebcbc939824180af020566b01a7c01f80641264eba0999f6c2b6be7"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15231,7 +15238,7 @@ checksum = "f9534daa9fd3ed0bd911d462a37f172228077e7abf18c18a5f67199d959205f8"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15242,7 +15249,7 @@ checksum = "560b82d656506509d43abe30e0ba64c56b1953ab3d4fe7ba5902747a7a3cedd5"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15278,7 +15285,7 @@ checksum = "70b20a22c42c8f1cd23ce5e34f165d4d37038f5b663ad20fb6adbdf029172483"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15599,7 +15606,7 @@ checksum = "d674d135b4a8c1d7e813e2f8d1c9a58308aee4a680323066025e53132218bd91"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -15762,7 +15769,7 @@ dependencies = [
  "once_cell",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "wasm-bindgen-shared",
 ]
 
@@ -15796,7 +15803,7 @@ checksum = "afc340c74d9005395cf9dd098506f7f44e38f2b4a21c6aaacf9a105ea5e1e836"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "wasm-bindgen-backend",
  "wasm-bindgen-shared",
 ]
@@ -15971,7 +15978,7 @@ dependencies = [
  "anyhow",
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "wasmtime-component-util",
  "wasmtime-wit-bindgen",
  "wit-parser",
@@ -16087,7 +16094,7 @@ checksum = "df09be00c38f49172ca9936998938476e3f2df782673a39ae2ef9fb0838341b6"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16233,7 +16240,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "shellexpand",
- "syn 2.0.95",
+ "syn 2.0.100",
  "witx",
 ]
 
@@ -16245,7 +16252,7 @@ checksum = "9b8eb1a5783540696c59cefbfc9e52570c2d5e62bd47bdf0bdcef29231879db2"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "wiggle-generate",
 ]
 
@@ -16374,7 +16381,7 @@ checksum = "9107ddc059d5b6fbfbffdfa7a7fe3e22a226def0b2608f72e9d552763d3e1ad7"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16385,7 +16392,7 @@ checksum = "2bbd5b46c938e506ecbce286b6628a02171d56153ba733b6c741fc627ec9579b"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16396,7 +16403,7 @@ checksum = "29bee4b38ea3cde66011baa44dba677c432a78593e202392d1e9070cf2a7fca7"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16407,7 +16414,7 @@ checksum = "053c4c462dc91d3b1504c6fe5a726dd15e216ba718e84a0e46a88fbe5ded3515"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16863,7 +16870,7 @@ checksum = "2380878cad4ac9aac1e2435f3eb4020e8374b5f13c296cb75b4620ff8e229154"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "synstructure",
 ]
 
@@ -16900,7 +16907,7 @@ checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16911,7 +16918,7 @@ checksum = "6352c01d0edd5db859a63e2605f4ea3183ddbd15e2c4a9e7d32184df75e4f154"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
@@ -16931,7 +16938,7 @@ checksum = "d71e5d6e06ab090c67b5e44993ec16b72dcbaabc526db883a360057678b48502"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
  "synstructure",
 ]
 
@@ -16960,7 +16967,7 @@ checksum = "6eafa6dfb17584ea3e2bd6e76e0cc15ad7af12b09abdd1ca55961bed9b1063c6"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.95",
+ "syn 2.0.100",
 ]
 
 [[package]]
diff --git a/Cargo.toml b/Cargo.toml
index 62d55cd097e3..96571a0af960 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -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" }
diff --git a/src/common/native/Cargo.toml b/src/common/native/Cargo.toml
index 3359efeb05e5..ccd1e249c91b 100644
--- a/src/common/native/Cargo.toml
+++ b/src/common/native/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 }
diff --git a/src/common/native/src/read/batch_read.rs b/src/common/native/src/read/batch_read.rs
index 095d9cc735e5..5371ff553041 100644
--- a/src/common/native/src/read/batch_read.rs
+++ b/src/common/native/src/read/batch_read.rs
@@ -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(),
diff --git a/src/common/native/src/read/deserialize.rs b/src/common/native/src/read/deserialize.rs
index 8e3e982c8f73..d6cf0e53033c 100644
--- a/src/common/native/src/read/deserialize.rs
+++ b/src/common/native/src/read/deserialize.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
             ))
diff --git a/src/query/expression/Cargo.toml b/src/query/expression/Cargo.toml
index 94bcc0e83ee4..9715ad3fef2d 100644
--- a/src/query/expression/Cargo.toml
+++ b/src/query/expression/Cargo.toml
@@ -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 }
diff --git a/src/query/expression/src/aggregate/group_hash.rs b/src/query/expression/src/aggregate/group_hash.rs
index ebf5828b54a5..95378c27705c 100644
--- a/src/query/expression/src/aggregate/group_hash.rs
+++ b/src/query/expression/src/aggregate/group_hash.rs
@@ -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;
diff --git a/src/query/expression/src/aggregate/payload_flush.rs b/src/query/expression/src/aggregate/payload_flush.rs
index 4fe9f3583022..59906620afdf 100644
--- a/src/query/expression/src/aggregate/payload_flush.rs
+++ b/src/query/expression/src/aggregate/payload_flush.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;
diff --git a/src/query/expression/src/aggregate/payload_row.rs b/src/query/expression/src/aggregate/payload_row.rs
index ce8b908e0b5a..06308ba9be6f 100644
--- a/src/query/expression/src/aggregate/payload_row.rs
+++ b/src/query/expression/src/aggregate/payload_row.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;
diff --git a/src/query/expression/src/filter/select.rs b/src/query/expression/src/filter/select.rs
index 3d39b2a1ec59..ed5f1b842b2a 100644
--- a/src/query/expression/src/filter/select.rs
+++ b/src/query/expression/src/filter/select.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;
diff --git a/src/query/expression/src/kernels/concat.rs b/src/query/expression/src/kernels/concat.rs
index 9883daffd886..ab61a79b491c 100644
--- a/src/query/expression/src/kernels/concat.rs
+++ b/src/query/expression/src/kernels/concat.rs
@@ -20,12 +20,12 @@ use databend_common_column::bitmap::Bitmap;
 use databend_common_column::buffer::Buffer;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
-use ethnum::i256;
 use itertools::Itertools;
 
 use crate::types::array::ArrayColumnBuilder;
 use crate::types::decimal::Decimal;
 use crate::types::decimal::DecimalColumn;
+use crate::types::i256;
 use crate::types::map::KvColumnBuilder;
 use crate::types::nullable::NullableColumn;
 use crate::types::number::NumberColumn;
diff --git a/src/query/expression/src/kernels/group_by_hash/method.rs b/src/query/expression/src/kernels/group_by_hash/method.rs
index 2e69c1b73ce3..a6b259da4aa4 100644
--- a/src/query/expression/src/kernels/group_by_hash/method.rs
+++ b/src/query/expression/src/kernels/group_by_hash/method.rs
@@ -21,11 +21,11 @@ use databend_common_exception::Result;
 use databend_common_hashtable::DictionaryKeys;
 use databend_common_hashtable::FastHash;
 use either::Either;
-use ethnum::i256;
 use ethnum::u256;
 
 use crate::types::binary::BinaryColumn;
 use crate::types::decimal::Decimal;
+use crate::types::i256;
 use crate::types::DataType;
 use crate::types::DecimalDataType;
 use crate::types::NumberDataType;
diff --git a/src/query/expression/src/kernels/group_by_hash/method_fixed_keys.rs b/src/query/expression/src/kernels/group_by_hash/method_fixed_keys.rs
index 177b542be7d9..7608a328f404 100644
--- a/src/query/expression/src/kernels/group_by_hash/method_fixed_keys.rs
+++ b/src/query/expression/src/kernels/group_by_hash/method_fixed_keys.rs
@@ -20,7 +20,6 @@ use databend_common_column::buffer::Buffer;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_hashtable::FastHash;
-use ethnum::i256;
 use ethnum::u256;
 use ethnum::U256;
 use micromarshal::Marshal;
@@ -28,6 +27,7 @@ use micromarshal::Marshal;
 use crate::types::boolean::BooleanType;
 use crate::types::decimal::Decimal;
 use crate::types::decimal::DecimalColumn;
+use crate::types::i256;
 use crate::types::nullable::NullableColumn;
 use crate::types::number::Number;
 use crate::types::number::NumberColumn;
diff --git a/src/query/expression/src/row/fixed.rs b/src/query/expression/src/row/fixed.rs
index 24f2d712faf2..e98a27deac17 100644
--- a/src/query/expression/src/row/fixed.rs
+++ b/src/query/expression/src/row/fixed.rs
@@ -14,10 +14,10 @@
 
 use databend_common_column::bitmap::Bitmap;
 use databend_common_column::types::months_days_micros;
-use ethnum::i256;
 
 use super::row_converter::null_sentinel;
 use crate::types::binary::BinaryColumnBuilder;
+use crate::types::i256;
 use crate::types::F32;
 use crate::types::F64;
 
diff --git a/src/query/expression/src/row/row_converter.rs b/src/query/expression/src/row/row_converter.rs
index f39ad0763e18..8af10d312d06 100644
--- a/src/query/expression/src/row/row_converter.rs
+++ b/src/query/expression/src/row/row_converter.rs
@@ -17,7 +17,6 @@ use std::sync::Arc;
 use databend_common_column::types::months_days_micros;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
-use ethnum::i256;
 
 use super::fixed;
 use super::fixed::FixedLengthEncoding;
@@ -25,6 +24,7 @@ use super::variable;
 use crate::types::binary::BinaryColumn;
 use crate::types::binary::BinaryColumnBuilder;
 use crate::types::decimal::DecimalColumn;
+use crate::types::i256;
 use crate::types::DataType;
 use crate::types::DecimalDataType;
 use crate::types::NumberColumn;
diff --git a/src/query/expression/src/types/decimal.rs b/src/query/expression/src/types/decimal.rs
index 04ba37c64ea6..c006a03f06ca 100644
--- a/src/query/expression/src/types/decimal.rs
+++ b/src/query/expression/src/types/decimal.rs
@@ -15,7 +15,17 @@
 use std::cmp::Ordering;
 use std::fmt::Debug;
 use std::marker::PhantomData;
+use std::num::TryFromIntError;
+use std::ops::Add;
+use std::ops::AddAssign;
+use std::ops::Div;
+use std::ops::DivAssign;
+use std::ops::Mul;
+use std::ops::MulAssign;
+use std::ops::Neg;
 use std::ops::Range;
+use std::ops::Sub;
+use std::ops::SubAssign;
 
 use arrow_data::ArrayData;
 use arrow_data::ArrayDataBuilder;
@@ -27,10 +37,10 @@ use databend_common_exception::Result;
 use databend_common_io::display_decimal_128;
 use databend_common_io::display_decimal_256;
 use enum_as_inner::EnumAsInner;
-use ethnum::i256;
 use ethnum::u256;
 use ethnum::AsI256;
 use itertools::Itertools;
+use micromarshal::Marshal;
 use num_bigint::BigInt;
 use num_traits::FromBytes;
 use num_traits::NumCast;
@@ -498,12 +508,12 @@ impl Decimal for i128 {
     fn do_round_mul(self, rhs: Self, shift_scale: u32) -> Option<Self> {
         let div = i256::e(shift_scale);
         let res = if self.is_negative() == rhs.is_negative() {
-            (i256::from(self) * i256::from(rhs) + div / 2) / div
+            (i256::from(self) * i256::from(rhs) + div / i256::from(2)) / div
         } else {
-            (i256::from(self) * i256::from(rhs) - div / 2) / div
+            (i256::from(self) * i256::from(rhs) - div / i256::from(2)) / div
         };
 
-        if !(i128::MIN..=i128::MAX).contains(&res) {
+        if !(i256::from(i128::MIN)..=i256::from(i128::MAX)).contains(&res) {
             None
         } else {
             Some(res.as_i128())
@@ -513,10 +523,10 @@ impl Decimal for i128 {
     fn do_round_div(self, rhs: Self, mul_scale: u32) -> Option<Self> {
         let mul = i256::e(mul_scale);
         if self.is_negative() == rhs.is_negative() {
-            let res = (i256::from(self) * i256::from(mul) + i256::from(rhs) / 2) / i256::from(rhs);
+            let res = (i256::from(self) * mul + i256::from(rhs) / i256::from(2)) / i256::from(rhs);
             Some(*res.low())
         } else {
-            let res = (i256::from(self) * i256::from(mul) - i256::from(rhs) / 2) / i256::from(rhs);
+            let res = (i256::from(self) * mul - i256::from(rhs) / i256::from(2)) / i256::from(rhs);
             Some(*res.low())
         }
     }
@@ -716,7 +726,7 @@ impl Decimal for i256 {
     }
 
     fn e(n: u32) -> Self {
-        (i256::ONE * 10).pow(n)
+        (i256::ONE * i256::from(10)).pow(n)
     }
 
     fn mem_size() -> usize {
@@ -724,31 +734,33 @@ impl Decimal for i256 {
     }
 
     fn checked_add(self, rhs: Self) -> Option<Self> {
-        self.checked_add(rhs)
+        self.0.checked_add(rhs.0).map(Self)
     }
 
     fn checked_sub(self, rhs: Self) -> Option<Self> {
-        self.checked_sub(rhs)
+        self.0.checked_sub(rhs.0).map(Self)
     }
 
     fn checked_div(self, rhs: Self) -> Option<Self> {
-        self.checked_div(rhs)
+        self.0.checked_div(rhs.0).map(Self)
     }
 
     fn checked_mul(self, rhs: Self) -> Option<Self> {
-        self.checked_mul(rhs)
+        self.0.checked_mul(rhs.0).map(Self)
     }
 
     fn checked_rem(self, rhs: Self) -> Option<Self> {
-        self.checked_rem(rhs)
+        self.0.checked_rem(rhs.0).map(Self)
     }
 
     fn do_round_mul(self, rhs: Self, shift_scale: u32) -> Option<Self> {
         let div = i256::e(shift_scale);
         let ret: Option<i256> = if self.is_negative() == rhs.is_negative() {
-            self.checked_mul(rhs).map(|x| (x + div / 2) / div)
+            self.checked_mul(rhs)
+                .map(|x| (x + div / i256::from(2)) / div)
         } else {
-            self.checked_mul(rhs).map(|x| (x - div / 2) / div)
+            self.checked_mul(rhs)
+                .map(|x| (x - div / i256::from(2)) / div)
         };
 
         ret.or_else(|| {
@@ -781,9 +793,11 @@ impl Decimal for i256 {
 
         let mul = i256::e(mul_scale);
         let ret: Option<i256> = if self.is_negative() == rhs.is_negative() {
-            self.checked_mul(mul).map(|x| (x + rhs / 2) / rhs)
+            self.checked_mul(mul)
+                .map(|x| (x + rhs / i256::from(2)) / rhs)
         } else {
-            self.checked_mul(mul).map(|x| (x - rhs / 2) / rhs)
+            self.checked_mul(mul)
+                .map(|x| (x - rhs / i256::from(2)) / rhs)
         };
 
         ret.or_else(fallback)
@@ -805,7 +819,7 @@ impl Decimal for i256 {
     }
 
     fn from_float(value: f64) -> Self {
-        value.as_i256()
+        i256(value.as_i256())
     }
 
     fn from_i128<U: Into<i128>>(value: U) -> Self {
@@ -851,7 +865,7 @@ impl Decimal for i256 {
     }
 
     fn display(self, scale: u8) -> String {
-        display_decimal_256(self, scale)
+        display_decimal_256(self.0, scale)
     }
 
     fn to_float32(self, scale: u8) -> f32 {
@@ -865,7 +879,7 @@ impl Decimal for i256 {
     }
 
     fn to_int<U: NumCast>(self, scale: u8, rounding_mode: bool) -> Option<U> {
-        if !(i128::MIN..=i128::MAX).contains(&self) {
+        if !(i256::from(i128::MIN)..=i256::from(i128::MAX)).contains(&self) {
             None
         } else {
             let val = self.as_i128();
@@ -936,12 +950,12 @@ impl Decimal for i256 {
         }))
     }
 
-    const MIN: i256 = ethnum::int!(
+    const MIN: i256 = i256(ethnum::int!(
         "-9999999999999999999999999999999999999999999999999999999999999999999999999999"
-    );
-    const MAX: i256 = ethnum::int!(
+    ));
+    const MAX: i256 = i256(ethnum::int!(
         "9999999999999999999999999999999999999999999999999999999999999999999999999999"
-    );
+    ));
     fn to_column_from_buffer(value: Buffer<Self>, size: DecimalSize) -> DecimalColumn {
         DecimalColumn::Decimal256(value, size)
     }
@@ -2120,3 +2134,390 @@ pub const MIN_DECIMAL_FOR_EACH_PRECISION: [i128; 38] = [
     -9999999999999999999999999999999999999,
     -99999999999999999999999999999999999999,
 ];
+
+/// The wrapper of `ethnum::I256`, used to implement the `BorshSerialize` and `BorshDeserialize` traits.
+#[derive(Clone, Copy, Default, Eq, Serialize, Deserialize)]
+#[allow(non_camel_case_types)]
+#[repr(C)]
+pub struct i256(pub ethnum::I256);
+
+impl i256 {
+    /// The additive identity for this integer type, i.e. `0`.
+    pub const ZERO: Self = Self(ethnum::I256([0; 2]));
+
+    /// The multiplicative identity for this integer type, i.e. `1`.
+    pub const ONE: Self = Self(ethnum::I256::new(1));
+
+    /// The multiplicative inverse for this integer type, i.e. `-1`.
+    pub const MINUS_ONE: Self = Self(ethnum::I256::new(-1));
+
+    /// Creates a new 256-bit integer value from a primitive `i128` integer.
+    #[inline]
+    pub const fn new(value: i128) -> Self {
+        Self(ethnum::I256::new(value))
+    }
+
+    /// Returns a new [`i256`] from two `i128`.
+    pub fn from_words(hi: i128, lo: i128) -> Self {
+        Self(ethnum::I256::from_words(hi, lo))
+    }
+
+    pub fn from_str_radix(
+        src: &str,
+        radix: u32,
+    ) -> std::result::Result<Self, std::num::ParseIntError> {
+        ethnum::I256::from_str_radix(src, radix).map(Self)
+    }
+
+    #[inline]
+    pub const fn to_le_bytes(&self) -> [u8; 32] {
+        self.0.to_le_bytes()
+    }
+
+    #[inline]
+    pub const fn to_be_bytes(&self) -> [u8; 32] {
+        self.0.to_be_bytes()
+    }
+
+    #[inline]
+    pub const fn from_be_bytes(bytes: [u8; 32]) -> Self {
+        Self(ethnum::I256::from_be_bytes(bytes))
+    }
+
+    #[inline]
+    pub const fn from_le_bytes(bytes: [u8; 32]) -> Self {
+        Self(ethnum::I256::from_le_bytes(bytes))
+    }
+
+    #[inline]
+    pub const fn is_positive(self) -> bool {
+        self.0.is_positive()
+    }
+
+    #[inline]
+    pub const fn is_negative(self) -> bool {
+        self.0.is_negative()
+    }
+
+    #[inline]
+    pub fn saturating_abs(self) -> Self {
+        Self(self.0.saturating_abs())
+    }
+
+    #[inline]
+    pub fn leading_zeros(self) -> u32 {
+        self.0.leading_zeros()
+    }
+
+    /// Cast to a primitive `i8`.
+    #[inline]
+    pub const fn as_i8(self) -> i8 {
+        self.0.as_i8()
+    }
+
+    /// Cast to a primitive `i16`.
+    #[inline]
+    pub const fn as_i16(self) -> i16 {
+        self.0.as_i16()
+    }
+
+    /// Cast to a primitive `i32`.
+    #[inline]
+    pub const fn as_i32(self) -> i32 {
+        self.0.as_i32()
+    }
+
+    /// Cast to a primitive `i64`.
+    #[inline]
+    pub const fn as_i64(self) -> i64 {
+        self.0.as_i64()
+    }
+
+    /// Cast to a primitive `i128`.
+    #[inline]
+    pub const fn as_i128(self) -> i128 {
+        self.0.as_i128()
+    }
+
+    /// Cast to a primitive `u8`.
+    #[inline]
+    pub const fn as_u8(self) -> u8 {
+        self.0.as_u8()
+    }
+
+    /// Cast to a primitive `u16`.
+    #[inline]
+    pub const fn as_u16(self) -> u16 {
+        self.0.as_u16()
+    }
+
+    /// Cast to a primitive `u32`.
+    #[inline]
+    pub const fn as_u32(self) -> u32 {
+        self.0.as_u32()
+    }
+
+    /// Cast to a primitive `u64`.
+    #[inline]
+    pub const fn as_u64(self) -> u64 {
+        self.0.as_u64()
+    }
+
+    /// Cast to a primitive `u128`.
+    #[inline]
+    pub const fn as_u128(self) -> u128 {
+        self.0.as_u128()
+    }
+
+    /// Cast to a primitive `u256`.
+    #[inline]
+    pub const fn as_u256(self) -> u256 {
+        self.0.as_u256()
+    }
+
+    /// Cast to a primitive `isize`.
+    #[inline]
+    pub const fn as_isize(self) -> isize {
+        self.0.as_isize()
+    }
+
+    /// Cast to a primitive `usize`.
+    #[inline]
+    pub const fn as_usize(self) -> usize {
+        self.0.as_usize()
+    }
+
+    /// Cast to a primitive `f32`.
+    #[inline]
+    pub fn as_f32(self) -> f32 {
+        self.0.as_f32()
+    }
+
+    /// Cast to a primitive `f64`.
+    #[inline]
+    pub fn as_f64(self) -> f64 {
+        self.0.as_f64()
+    }
+
+    /// Get the low 128-bit word for this signed integer.
+    #[inline]
+    pub fn low(&self) -> &i128 {
+        self.0.low()
+    }
+
+    /// Get the high 128-bit word for this signed integer.
+    #[inline]
+    pub fn high(&self) -> &i128 {
+        self.0.high()
+    }
+
+    #[allow(unused_attributes)]
+    #[inline]
+    pub fn abs(self) -> Self {
+        Self(self.0.abs())
+    }
+
+    #[inline]
+    pub fn checked_neg(self) -> Option<Self> {
+        self.0.checked_neg().map(Self)
+    }
+
+    #[inline]
+    pub fn pow(self, exp: u32) -> Self {
+        Self(self.0.pow(exp))
+    }
+}
+
+impl std::fmt::Debug for i256 {
+    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
+        write!(f, "{:?}", self.0)
+    }
+}
+
+impl std::fmt::Display for i256 {
+    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
+        write!(f, "{}", self.0)
+    }
+}
+
+impl Neg for i256 {
+    type Output = Self;
+
+    #[inline]
+    fn neg(self) -> Self::Output {
+        Self(self.0.checked_neg().expect("i256 overflow"))
+    }
+}
+
+impl AddAssign for i256 {
+    fn add_assign(&mut self, rhs: Self) {
+        self.0 += rhs.0;
+    }
+}
+
+impl SubAssign for i256 {
+    fn sub_assign(&mut self, rhs: Self) {
+        self.0 -= rhs.0;
+    }
+}
+
+impl MulAssign for i256 {
+    fn mul_assign(&mut self, rhs: Self) {
+        self.0 *= rhs.0;
+    }
+}
+
+impl DivAssign for i256 {
+    fn div_assign(&mut self, rhs: Self) {
+        self.0 /= rhs.0;
+    }
+}
+
+impl Add for i256 {
+    type Output = Self;
+
+    fn add(self, rhs: Self) -> Self::Output {
+        Self(self.0 + rhs.0)
+    }
+}
+
+impl Sub for i256 {
+    type Output = Self;
+
+    fn sub(self, rhs: Self) -> Self::Output {
+        Self(self.0 - rhs.0)
+    }
+}
+
+impl Mul for i256 {
+    type Output = Self;
+
+    fn mul(self, rhs: Self) -> Self::Output {
+        Self(self.0 * rhs.0)
+    }
+}
+
+impl Div for i256 {
+    type Output = Self;
+
+    fn div(self, rhs: Self) -> Self::Output {
+        Self(self.0 / rhs.0)
+    }
+}
+
+macro_rules! impl_from {
+    ($($t:ty),* $(,)?) => {$(
+        impl From<$t> for i256 {
+            #[inline]
+            fn from(value: $t) -> Self {
+                i256(value.as_i256())
+            }
+        }
+    )*};
+}
+
+impl_from! {
+    bool,
+    i8, i16, i32, i64, i128,
+    u8, u16, u32, u64, u128,
+}
+
+impl TryFrom<u256> for i256 {
+    type Error = TryFromIntError;
+
+    fn try_from(value: u256) -> std::result::Result<Self, Self::Error> {
+        let i256_value = ethnum::i256::try_from(value)?;
+        Ok(i256(i256_value))
+    }
+}
+
+impl BorshSerialize for i256 {
+    fn serialize<W: borsh::io::Write>(&self, writer: &mut W) -> borsh::io::Result<()> {
+        BorshSerialize::serialize(&self.0 .0, writer)
+    }
+}
+
+impl BorshDeserialize for i256 {
+    fn deserialize_reader<R: borsh::io::Read>(reader: &mut R) -> borsh::io::Result<Self> {
+        let value: [i128; 2] = BorshDeserialize::deserialize_reader(reader)?;
+        Ok(Self(ethnum::I256(value)))
+    }
+}
+
+impl Marshal for i256 {
+    fn marshal(&self, scratch: &mut [u8]) {
+        self.0.marshal(scratch);
+    }
+}
+
+macro_rules! impl_into_float {
+    ($($t:ty => $f:ident),* $(,)?) => {$(
+        impl From<i256> for $t {
+            #[inline]
+            fn from(x: i256) -> $t {
+                x.0.$f()
+            }
+        }
+    )*};
+}
+
+impl_into_float! {
+    f32 => as_f32, f64 => as_f64,
+}
+
+impl core::hash::Hash for i256 {
+    #[inline]
+    fn hash<H>(&self, hasher: &mut H)
+    where H: core::hash::Hasher {
+        core::hash::Hash::hash(&self.0, hasher);
+    }
+}
+
+impl PartialEq for i256 {
+    #[inline]
+    fn eq(&self, other: &Self) -> bool {
+        self.0.eq(&other.0)
+    }
+}
+
+impl PartialEq<i128> for i256 {
+    #[inline]
+    fn eq(&self, other: &i128) -> bool {
+        *self == i256::new(*other)
+    }
+}
+
+impl PartialEq<i256> for i128 {
+    #[inline]
+    fn eq(&self, other: &i256) -> bool {
+        i256::new(*self) == *other
+    }
+}
+
+impl PartialOrd for i256 {
+    #[inline]
+    fn partial_cmp(&self, other: &Self) -> Option<core::cmp::Ordering> {
+        Some(self.cmp(other))
+    }
+}
+
+impl PartialOrd<i128> for i256 {
+    #[inline]
+    fn partial_cmp(&self, rhs: &i128) -> Option<core::cmp::Ordering> {
+        Some(self.cmp(&i256::new(*rhs)))
+    }
+}
+
+impl PartialOrd<i256> for i128 {
+    #[inline]
+    fn partial_cmp(&self, rhs: &i256) -> Option<core::cmp::Ordering> {
+        Some(i256::new(*self).cmp(rhs))
+    }
+}
+
+impl Ord for i256 {
+    #[inline]
+    fn cmp(&self, other: &Self) -> Ordering {
+        self.0.cmp(&other.0)
+    }
+}
diff --git a/src/query/expression/src/types/variant.rs b/src/query/expression/src/types/variant.rs
index ea41d79890e0..2f856e780392 100644
--- a/src/query/expression/src/types/variant.rs
+++ b/src/query/expression/src/types/variant.rs
@@ -31,11 +31,11 @@ use super::date::date_to_string;
 use super::number::NumberScalar;
 use super::timestamp::timestamp_to_string;
 use crate::property::Domain;
-use crate::types::interval::interval_to_string;
 use crate::types::map::KvPair;
 use crate::types::AnyType;
 use crate::types::ArgType;
 use crate::types::DataType;
+use crate::types::DecimalScalar;
 use crate::types::DecimalSize;
 use crate::types::GenericMap;
 use crate::types::ValueType;
@@ -225,13 +225,37 @@ pub fn cast_scalar_to_variant(scalar: ScalarRef, tz: &TimeZone, buf: &mut Vec<u8
             NumberScalar::Float32(n) => n.0.into(),
             NumberScalar::Float64(n) => n.0.into(),
         },
-        ScalarRef::Decimal(x) => x.to_float64().into(),
+        ScalarRef::Decimal(x) => match x {
+            DecimalScalar::Decimal128(value, size) => {
+                let dec = jsonb::Decimal128 {
+                    precision: size.precision,
+                    scale: size.scale,
+                    value,
+                };
+                jsonb::Value::Number(jsonb::Number::Decimal128(dec))
+            }
+            DecimalScalar::Decimal256(value, size) => {
+                let dec = jsonb::Decimal256 {
+                    precision: size.precision,
+                    scale: size.scale,
+                    value: value.0,
+                };
+                jsonb::Value::Number(jsonb::Number::Decimal256(dec))
+            }
+        },
         ScalarRef::Boolean(b) => jsonb::Value::Bool(b),
-        ScalarRef::Binary(s) => jsonb::Value::String(hex::encode_upper(s).into()),
+        ScalarRef::Binary(s) => jsonb::Value::Binary(s),
         ScalarRef::String(s) => jsonb::Value::String(s.into()),
-        ScalarRef::Timestamp(ts) => timestamp_to_string(ts, tz).to_string().into(),
-        ScalarRef::Date(d) => date_to_string(d, tz).to_string().into(),
-        ScalarRef::Interval(i) => interval_to_string(&i).to_string().into(),
+        ScalarRef::Timestamp(ts) => jsonb::Value::Timestamp(jsonb::Timestamp { value: ts }),
+        ScalarRef::Date(d) => jsonb::Value::Date(jsonb::Date { value: d }),
+        ScalarRef::Interval(i) => {
+            let interval = jsonb::Interval {
+                months: i.months(),
+                days: i.days(),
+                micros: i.microseconds(),
+            };
+            jsonb::Value::Interval(interval)
+        }
         ScalarRef::Array(col) => {
             let items = cast_scalars_to_variants(col.iter(), tz);
             let owned_jsonb = OwnedJsonb::build_array(items.iter().map(RawJsonb::new))
diff --git a/src/query/expression/src/utils/display.rs b/src/query/expression/src/utils/display.rs
index 4edbee460165..a6b76360a1b6 100755
--- a/src/query/expression/src/utils/display.rs
+++ b/src/query/expression/src/utils/display.rs
@@ -357,7 +357,7 @@ impl Debug for DecimalScalar {
                 write!(
                     f,
                     "{}_d256({},{})",
-                    display_decimal_256(*val, size.scale),
+                    display_decimal_256(val.0, size.scale),
                     size.precision,
                     size.scale
                 )
@@ -373,7 +373,7 @@ impl Display for DecimalScalar {
                 write!(f, "{}", display_decimal_128(*val, size.scale))
             }
             DecimalScalar::Decimal256(val, size) => {
-                write!(f, "{}", display_decimal_256(*val, size.scale))
+                write!(f, "{}", display_decimal_256(val.0, size.scale))
             }
         }
     }
@@ -425,7 +425,7 @@ impl Debug for DecimalColumn {
                 .field(&format_args!(
                     "[{}]",
                     &val.iter()
-                        .map(|x| display_decimal_256(*x, size.scale))
+                        .map(|x| display_decimal_256(x.0, size.scale))
                         .join(", ")
                 ))
                 .finish(),
@@ -1117,8 +1117,8 @@ impl Display for DecimalDomain {
             }
             DecimalDomain::Decimal256(SimpleDomain { min, max }, size) => {
                 write!(f, "{}", SimpleDomain {
-                    min: display_decimal_256(*min, size.scale),
-                    max: display_decimal_256(*max, size.scale),
+                    min: display_decimal_256(min.0, size.scale),
+                    max: display_decimal_256(max.0, size.scale),
                 })
             }
         }
diff --git a/src/query/expression/src/utils/mod.rs b/src/query/expression/src/utils/mod.rs
index f452eb651922..cf398207e936 100644
--- a/src/query/expression/src/utils/mod.rs
+++ b/src/query/expression/src/utils/mod.rs
@@ -28,11 +28,11 @@ pub mod visitor;
 use databend_common_ast::Span;
 use databend_common_column::bitmap::Bitmap;
 use databend_common_exception::Result;
-use ethnum::i256;
 
 pub use self::column_from::*;
 use crate::types::decimal::DecimalScalar;
 use crate::types::decimal::MAX_DECIMAL256_PRECISION;
+use crate::types::i256;
 use crate::types::AnyType;
 use crate::types::DataType;
 use crate::types::DecimalDataType;
diff --git a/src/query/expression/src/values.rs b/src/query/expression/src/values.rs
index 13a87d6f8019..07e4af159384 100755
--- a/src/query/expression/src/values.rs
+++ b/src/query/expression/src/values.rs
@@ -33,7 +33,6 @@ use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_io::prelude::BinaryRead;
 use enum_as_inner::EnumAsInner;
-use ethnum::i256;
 use geo::Geometry;
 use geo::Point;
 use geozero::CoordDimensions;
@@ -68,6 +67,7 @@ use crate::types::geography::GeographyColumn;
 use crate::types::geography::GeographyRef;
 use crate::types::geometry::compare_geometry;
 use crate::types::geometry::GeometryType;
+use crate::types::i256;
 use crate::types::nullable::NullableColumn;
 use crate::types::nullable::NullableColumnBuilder;
 use crate::types::nullable::NullableColumnVec;
diff --git a/src/query/expression/tests/it/decimal.rs b/src/query/expression/tests/it/decimal.rs
index bd8a87701a0e..9c84eed27c3c 100644
--- a/src/query/expression/tests/it/decimal.rs
+++ b/src/query/expression/tests/it/decimal.rs
@@ -18,10 +18,10 @@ use databend_common_expression::serialize::read_decimal_with_size;
 use databend_common_expression::type_check::common_super_type;
 use databend_common_expression::types::decimal::Decimal;
 use databend_common_expression::types::decimal::DecimalSize;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::DataType;
 use databend_common_expression::types::DecimalDataType;
 use databend_common_expression::types::NumberDataType;
-use ethnum::i256;
 use num_bigint::BigInt;
 use pretty_assertions::assert_eq;
 
diff --git a/src/query/expression/tests/it/row.rs b/src/query/expression/tests/it/row.rs
index 4c42d0fc630f..85c444a95534 100644
--- a/src/query/expression/tests/it/row.rs
+++ b/src/query/expression/tests/it/row.rs
@@ -20,13 +20,13 @@ use databend_common_base::base::OrderedFloat;
 use databend_common_column::bitmap::MutableBitmap;
 use databend_common_expression::types::binary::BinaryColumnBuilder;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::nullable::NullableColumn;
 use databend_common_expression::types::*;
 use databend_common_expression::Column;
 use databend_common_expression::FromData;
 use databend_common_expression::RowConverter;
 use databend_common_expression::SortField;
-use ethnum::i256;
 use itertools::Itertools;
 use jsonb::parse_value;
 use jsonb::RawJsonb;
diff --git a/src/query/functions/Cargo.toml b/src/query/functions/Cargo.toml
index 9b3dbe4e9a0f..7a79946245e9 100644
--- a/src/query/functions/Cargo.toml
+++ b/src/query/functions/Cargo.toml
@@ -30,7 +30,6 @@ databend-functions-scalar-geo = { workspace = true }
 databend-functions-scalar-integer-basic-arithmetic = { workspace = true }
 databend-functions-scalar-math = { workspace = true }
 databend-functions-scalar-numeric-basic-arithmetic = { workspace = true }
-ethnum = { workspace = true }
 geo = { workspace = true }
 geohash = { workspace = true }
 geozero = { workspace = true }
diff --git a/src/query/functions/src/aggregates/aggregate_array_agg.rs b/src/query/functions/src/aggregates/aggregate_array_agg.rs
index 1d555171bd7a..0911b6f32473 100644
--- a/src/query/functions/src/aggregates/aggregate_array_agg.rs
+++ b/src/query/functions/src/aggregates/aggregate_array_agg.rs
@@ -22,6 +22,7 @@ use borsh::BorshDeserialize;
 use borsh::BorshSerialize;
 use databend_common_exception::Result;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::*;
 use databend_common_expression::types::Bitmap;
 use databend_common_expression::types::DataType;
@@ -35,7 +36,6 @@ use databend_common_expression::ColumnBuilder;
 use databend_common_expression::InputColumns;
 use databend_common_expression::Scalar;
 use databend_common_expression::ScalarRef;
-use ethnum::i256;
 
 use super::aggregate_function_factory::AggregateFunctionDescription;
 use super::aggregate_scalar_state::ScalarStateFunc;
diff --git a/src/query/functions/src/aggregates/aggregate_array_moving.rs b/src/query/functions/src/aggregates/aggregate_array_moving.rs
index 9231662bc48e..4e77587ed498 100644
--- a/src/query/functions/src/aggregates/aggregate_array_moving.rs
+++ b/src/query/functions/src/aggregates/aggregate_array_moving.rs
@@ -22,6 +22,7 @@ use borsh::BorshSerialize;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::Number;
 use databend_common_expression::types::ArgType;
 use databend_common_expression::types::Bitmap;
@@ -43,7 +44,6 @@ use databend_common_expression::ColumnBuilder;
 use databend_common_expression::InputColumns;
 use databend_common_expression::Scalar;
 use databend_common_expression::ScalarRef;
-use ethnum::i256;
 use num_traits::AsPrimitive;
 
 use super::aggregate_function::AggregateFunction;
diff --git a/src/query/functions/src/aggregates/aggregate_bitmap.rs b/src/query/functions/src/aggregates/aggregate_bitmap.rs
index a69fa50b9529..eb7725aa7663 100644
--- a/src/query/functions/src/aggregates/aggregate_bitmap.rs
+++ b/src/query/functions/src/aggregates/aggregate_bitmap.rs
@@ -25,6 +25,7 @@ use std::sync::Arc;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::types::decimal::DecimalType;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::Bitmap;
 use databend_common_expression::types::MutableBitmap;
 use databend_common_expression::types::*;
@@ -35,7 +36,6 @@ use databend_common_expression::ColumnBuilder;
 use databend_common_expression::InputColumns;
 use databend_common_expression::Scalar;
 use databend_common_io::prelude::BinaryWrite;
-use ethnum::i256;
 use roaring::RoaringTreemap;
 
 use super::aggregate_function_factory::AggregateFunctionDescription;
diff --git a/src/query/functions/src/aggregates/aggregate_histogram.rs b/src/query/functions/src/aggregates/aggregate_histogram.rs
index 778e48e4ee34..750bf21062f5 100644
--- a/src/query/functions/src/aggregates/aggregate_histogram.rs
+++ b/src/query/functions/src/aggregates/aggregate_histogram.rs
@@ -23,12 +23,12 @@ use borsh::BorshSerialize;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::*;
 use databend_common_expression::types::*;
 use databend_common_expression::with_number_mapped_type;
 use databend_common_expression::AggregateFunctionRef;
 use databend_common_expression::Scalar;
-use ethnum::i256;
 use serde::Deserialize;
 use serde::Serialize;
 use string::StringColumnBuilder;
diff --git a/src/query/functions/src/aggregates/aggregate_min_max_any.rs b/src/query/functions/src/aggregates/aggregate_min_max_any.rs
index 52d37617cbcc..ba775e1af477 100644
--- a/src/query/functions/src/aggregates/aggregate_min_max_any.rs
+++ b/src/query/functions/src/aggregates/aggregate_min_max_any.rs
@@ -21,13 +21,13 @@ use borsh::BorshSerialize;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::*;
 use databend_common_expression::types::Bitmap;
 use databend_common_expression::types::*;
 use databend_common_expression::with_number_mapped_type;
 use databend_common_expression::Scalar;
 use databend_common_expression::SELECTIVITY_THRESHOLD;
-use ethnum::i256;
 
 use super::aggregate_function_factory::AggregateFunctionDescription;
 use super::aggregate_function_factory::AggregateFunctionSortDesc;
diff --git a/src/query/functions/src/aggregates/aggregate_quantile_cont.rs b/src/query/functions/src/aggregates/aggregate_quantile_cont.rs
index 9c5fcacbef09..7be60f43e8c2 100644
--- a/src/query/functions/src/aggregates/aggregate_quantile_cont.rs
+++ b/src/query/functions/src/aggregates/aggregate_quantile_cont.rs
@@ -23,13 +23,13 @@ use databend_common_exception::Result;
 use databend_common_expression::types::array::ArrayColumnBuilder;
 use databend_common_expression::types::decimal::Decimal;
 use databend_common_expression::types::decimal::DecimalType;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::*;
 use databend_common_expression::types::*;
 use databend_common_expression::with_number_mapped_type;
 use databend_common_expression::Column;
 use databend_common_expression::Scalar;
 use databend_common_expression::ScalarRef;
-use ethnum::i256;
 use num_traits::AsPrimitive;
 
 use super::AggregateUnaryFunction;
diff --git a/src/query/functions/src/aggregates/aggregate_quantile_disc.rs b/src/query/functions/src/aggregates/aggregate_quantile_disc.rs
index 49a35517f0df..985f9b7ee729 100644
--- a/src/query/functions/src/aggregates/aggregate_quantile_disc.rs
+++ b/src/query/functions/src/aggregates/aggregate_quantile_disc.rs
@@ -20,11 +20,11 @@ use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::types::array::ArrayColumnBuilder;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::*;
 use databend_common_expression::types::*;
 use databend_common_expression::with_number_mapped_type;
 use databend_common_expression::Scalar;
-use ethnum::i256;
 
 use super::get_levels;
 use super::AggregateUnaryFunction;
diff --git a/src/query/functions/src/aggregates/aggregate_range_bound.rs b/src/query/functions/src/aggregates/aggregate_range_bound.rs
index 30e2121a04cf..75c89c1c1507 100644
--- a/src/query/functions/src/aggregates/aggregate_range_bound.rs
+++ b/src/query/functions/src/aggregates/aggregate_range_bound.rs
@@ -21,12 +21,12 @@ use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::compare_columns;
 use databend_common_expression::types::array::ArrayColumnBuilder;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::Bitmap;
 use databend_common_expression::types::*;
 use databend_common_expression::with_number_mapped_type;
 use databend_common_expression::AggregateFunctionRef;
 use databend_common_expression::Scalar;
-use ethnum::i256;
 use rand::prelude::SliceRandom;
 use rand::rngs::SmallRng;
 use rand::thread_rng;
diff --git a/src/query/functions/src/scalars/arithmetic/Cargo.toml b/src/query/functions/src/scalars/arithmetic/Cargo.toml
index e9dac253ce7c..8b78af97ee69 100644
--- a/src/query/functions/src/scalars/arithmetic/Cargo.toml
+++ b/src/query/functions/src/scalars/arithmetic/Cargo.toml
@@ -6,7 +6,6 @@ edition = "2021"
 [dependencies]
 databend-common-expression = { workspace = true }
 databend-functions-scalar-decimal = { workspace = true }
-ethnum = { workspace = true }
 lexical-core = { workspace = true }
 match-template = { workspace = true }
 num-traits = { workspace = true }
diff --git a/src/query/functions/src/scalars/arithmetic/src/arithmetic.rs b/src/query/functions/src/scalars/arithmetic/src/arithmetic.rs
index 7647cb606869..a38539361007 100644
--- a/src/query/functions/src/scalars/arithmetic/src/arithmetic.rs
+++ b/src/query/functions/src/scalars/arithmetic/src/arithmetic.rs
@@ -23,6 +23,7 @@ use std::sync::Arc;
 use databend_common_expression::serialize::read_decimal_with_size;
 use databend_common_expression::types::decimal::DecimalDomain;
 use databend_common_expression::types::decimal::DecimalType;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::nullable::NullableColumn;
 use databend_common_expression::types::nullable::NullableDomain;
 use databend_common_expression::types::number::Number;
@@ -32,6 +33,7 @@ use databend_common_expression::types::string::StringColumnBuilder;
 use databend_common_expression::types::AnyType;
 use databend_common_expression::types::Bitmap;
 use databend_common_expression::types::DataType;
+use databend_common_expression::types::Decimal;
 use databend_common_expression::types::DecimalDataType;
 use databend_common_expression::types::NullableType;
 use databend_common_expression::types::NumberClass;
@@ -62,7 +64,6 @@ use databend_common_expression::FunctionSignature;
 use databend_functions_scalar_decimal::register_decimal_to_float;
 use databend_functions_scalar_decimal::register_decimal_to_int;
 use databend_functions_scalar_decimal::register_decimal_to_string;
-use ethnum::i256;
 use lexical_core::FormattedSize;
 use num_traits::AsPrimitive;
 
diff --git a/src/query/functions/src/scalars/decimal/Cargo.toml b/src/query/functions/src/scalars/decimal/Cargo.toml
index dcf99820fe16..4542396fad59 100644
--- a/src/query/functions/src/scalars/decimal/Cargo.toml
+++ b/src/query/functions/src/scalars/decimal/Cargo.toml
@@ -6,7 +6,6 @@ edition = "2021"
 [dependencies]
 databend-common-base = { workspace = true }
 databend-common-expression = { workspace = true }
-ethnum = { workspace = true }
 match-template = { workspace = true }
 num-traits = { workspace = true }
 
diff --git a/src/query/functions/src/scalars/decimal/src/arithmetic.rs b/src/query/functions/src/scalars/decimal/src/arithmetic.rs
index 1e4b0a8776ba..cc2850cfcb7a 100644
--- a/src/query/functions/src/scalars/decimal/src/arithmetic.rs
+++ b/src/query/functions/src/scalars/decimal/src/arithmetic.rs
@@ -16,6 +16,7 @@ use std::ops::*;
 use std::sync::Arc;
 
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::*;
 use databend_common_expression::vectorize_2_arg;
 use databend_common_expression::vectorize_with_builder_2_arg;
@@ -26,7 +27,6 @@ use databend_common_expression::FunctionDomain;
 use databend_common_expression::FunctionEval;
 use databend_common_expression::FunctionRegistry;
 use databend_common_expression::FunctionSignature;
-use ethnum::i256;
 
 use super::convert_to_decimal;
 use super::convert_to_decimal_domain;
diff --git a/src/query/functions/src/scalars/decimal/src/cast.rs b/src/query/functions/src/scalars/decimal/src/cast.rs
index 910c55ac82bd..6c2154416e6b 100644
--- a/src/query/functions/src/scalars/decimal/src/cast.rs
+++ b/src/query/functions/src/scalars/decimal/src/cast.rs
@@ -18,6 +18,7 @@ use std::sync::Arc;
 use databend_common_base::base::OrderedFloat;
 use databend_common_expression::serialize::read_decimal_with_size;
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::string::StringColumnBuilder;
 use databend_common_expression::types::*;
 use databend_common_expression::vectorize_1_arg;
@@ -37,7 +38,6 @@ use databend_common_expression::FunctionRegistry;
 use databend_common_expression::FunctionSignature;
 use databend_common_expression::Scalar;
 use databend_common_expression::Value;
-use ethnum::i256;
 use num_traits::AsPrimitive;
 
 // int float to decimal
@@ -656,7 +656,7 @@ macro_rules! m_decimal_to_decimal {
             let max = T::max_for_precision($dest_size.precision);
             let min = T::min_for_precision($dest_size.precision);
 
-            let source_factor = F::e($from_size.scale as u32);
+            let source_factor = T::e($from_size.scale as u32);
 
             vectorize_with_builder_1_arg::<DecimalType<F>, DecimalType<T>>(
                 |x: F, builder: &mut Vec<T>, ctx: &mut EvalContext| {
diff --git a/src/query/functions/src/scalars/decimal/src/comparison.rs b/src/query/functions/src/scalars/decimal/src/comparison.rs
index 13f3356e29ea..511fd11db618 100644
--- a/src/query/functions/src/scalars/decimal/src/comparison.rs
+++ b/src/query/functions/src/scalars/decimal/src/comparison.rs
@@ -17,6 +17,7 @@ use std::ops::*;
 use std::sync::Arc;
 
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::*;
 use databend_common_expression::vectorize_cmp_2_arg;
 use databend_common_expression::Domain;
@@ -27,7 +28,6 @@ use databend_common_expression::FunctionRegistry;
 use databend_common_expression::FunctionSignature;
 use databend_common_expression::SimpleDomainCmp;
 use databend_common_expression::Value;
-use ethnum::i256;
 
 use super::convert_to_decimal;
 use super::convert_to_decimal_domain;
diff --git a/src/query/functions/src/scalars/decimal/src/math.rs b/src/query/functions/src/scalars/decimal/src/math.rs
index bc9fcc664d5e..7a9a77586db3 100644
--- a/src/query/functions/src/scalars/decimal/src/math.rs
+++ b/src/query/functions/src/scalars/decimal/src/math.rs
@@ -16,6 +16,7 @@ use std::ops::*;
 use std::sync::Arc;
 
 use databend_common_expression::types::decimal::*;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::*;
 use databend_common_expression::vectorize_1_arg;
 use databend_common_expression::with_decimal_mapped_type;
@@ -27,7 +28,6 @@ use databend_common_expression::FunctionRegistry;
 use databend_common_expression::FunctionSignature;
 use databend_common_expression::Scalar;
 use databend_common_expression::Value;
-use ethnum::i256;
 
 pub fn register_decimal_math(registry: &mut FunctionRegistry) {
     let factory_rounds = |params: &[Scalar], args_type: &[DataType], round_mode: RoundMode| {
diff --git a/src/query/functions/src/scalars/hash.rs b/src/query/functions/src/scalars/hash.rs
index cc008bd2647b..1dfbc0e51e9d 100644
--- a/src/query/functions/src/scalars/hash.rs
+++ b/src/query/functions/src/scalars/hash.rs
@@ -19,6 +19,7 @@ use std::hash::Hash;
 use std::hash::Hasher;
 
 use databend_common_expression::types::decimal::DecimalType;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::NumberScalar;
 use databend_common_expression::types::number::F32;
 use databend_common_expression::types::number::F64;
@@ -42,7 +43,6 @@ use databend_common_expression::with_number_mapped_type;
 use databend_common_expression::FunctionDomain;
 use databend_common_expression::FunctionRegistry;
 use databend_common_expression::Scalar;
-use ethnum::i256;
 use md5::Digest;
 use md5::Md5 as Md5Hasher;
 use naive_cityhash::cityhash64_with_seed;
@@ -311,7 +311,7 @@ for_all_integer_types! { integer_impl }
 impl DFHash for i256 {
     #[inline]
     fn hash<H: Hasher>(&self, state: &mut H) {
-        Hash::hash(self.0.as_slice(), state);
+        Hash::hash(self.0 .0.as_slice(), state);
     }
 }
 
diff --git a/src/query/functions/src/scalars/variant.rs b/src/query/functions/src/scalars/variant.rs
index 88590faad7f2..26171913472b 100644
--- a/src/query/functions/src/scalars/variant.rs
+++ b/src/query/functions/src/scalars/variant.rs
@@ -19,6 +19,7 @@ use std::iter::once;
 use std::sync::Arc;
 
 use bstr::ByteSlice;
+use databend_common_column::types::months_days_micros;
 use databend_common_expression::types::binary::BinaryColumnBuilder;
 use databend_common_expression::types::date::string_to_date;
 use databend_common_expression::types::nullable::NullableColumn;
@@ -31,11 +32,13 @@ use databend_common_expression::types::variant::cast_scalar_to_variant;
 use databend_common_expression::types::variant::cast_scalars_to_variants;
 use databend_common_expression::types::AnyType;
 use databend_common_expression::types::ArrayType;
+use databend_common_expression::types::BinaryType;
 use databend_common_expression::types::Bitmap;
 use databend_common_expression::types::BooleanType;
 use databend_common_expression::types::DataType;
 use databend_common_expression::types::DateType;
 use databend_common_expression::types::GenericType;
+use databend_common_expression::types::IntervalType;
 use databend_common_expression::types::MutableBitmap;
 use databend_common_expression::types::NullableType;
 use databend_common_expression::types::NumberDataType;
@@ -729,6 +732,148 @@ pub fn register(registry: &mut FunctionRegistry) {
         }),
     );
 
+    registry.register_passthrough_nullable_1_arg::<VariantType, BooleanType, _, _>(
+        "is_binary",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, BooleanType>(|v, output, ctx| {
+            if let Some(validity) = &ctx.validity {
+                if !validity.get_bit(output.len()) {
+                    output.push(false);
+                    return;
+                }
+            }
+            match RawJsonb::new(v).is_binary() {
+                Ok(res) => output.push(res),
+                Err(_) => output.push(false),
+            }
+        }),
+    );
+
+    registry.register_combine_nullable_1_arg::<VariantType, BinaryType, _, _>(
+        "as_binary",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, NullableType<BinaryType>>(|v, output, ctx| {
+            if let Some(validity) = &ctx.validity {
+                if !validity.get_bit(output.len()) {
+                    output.push_null();
+                    return;
+                }
+            }
+            match RawJsonb::new(v).as_binary() {
+                Ok(Some(res)) => output.push(&res),
+                _ => output.push_null(),
+            }
+        }),
+    );
+
+    registry.register_passthrough_nullable_1_arg::<VariantType, BooleanType, _, _>(
+        "is_date",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, BooleanType>(|v, output, ctx| {
+            if let Some(validity) = &ctx.validity {
+                if !validity.get_bit(output.len()) {
+                    output.push(false);
+                    return;
+                }
+            }
+            match RawJsonb::new(v).is_date() {
+                Ok(res) => output.push(res),
+                Err(_) => output.push(false),
+            }
+        }),
+    );
+
+    registry.register_combine_nullable_1_arg::<VariantType, DateType, _, _>(
+        "as_date",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, NullableType<DateType>>(|v, output, ctx| {
+            if let Some(validity) = &ctx.validity {
+                if !validity.get_bit(output.len()) {
+                    output.push_null();
+                    return;
+                }
+            }
+            match RawJsonb::new(v).as_date() {
+                Ok(Some(res)) => output.push(res.value),
+                _ => output.push_null(),
+            }
+        }),
+    );
+
+    registry.register_passthrough_nullable_1_arg::<VariantType, BooleanType, _, _>(
+        "is_timestamp",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, BooleanType>(|v, output, ctx| {
+            if let Some(validity) = &ctx.validity {
+                if !validity.get_bit(output.len()) {
+                    output.push(false);
+                    return;
+                }
+            }
+            match RawJsonb::new(v).is_timestamp() {
+                Ok(res) => output.push(res),
+                Err(_) => output.push(false),
+            }
+        }),
+    );
+
+    registry.register_combine_nullable_1_arg::<VariantType, TimestampType, _, _>(
+        "as_timestamp",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, NullableType<TimestampType>>(
+            |v, output, ctx| {
+                if let Some(validity) = &ctx.validity {
+                    if !validity.get_bit(output.len()) {
+                        output.push_null();
+                        return;
+                    }
+                }
+                match RawJsonb::new(v).as_timestamp() {
+                    Ok(Some(res)) => output.push(res.value),
+                    _ => output.push_null(),
+                }
+            },
+        ),
+    );
+
+    registry.register_passthrough_nullable_1_arg::<VariantType, BooleanType, _, _>(
+        "is_interval",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, BooleanType>(|v, output, ctx| {
+            if let Some(validity) = &ctx.validity {
+                if !validity.get_bit(output.len()) {
+                    output.push(false);
+                    return;
+                }
+            }
+            match RawJsonb::new(v).is_interval() {
+                Ok(res) => output.push(res),
+                Err(_) => output.push(false),
+            }
+        }),
+    );
+
+    registry.register_combine_nullable_1_arg::<VariantType, IntervalType, _, _>(
+        "as_interval",
+        |_, _| FunctionDomain::Full,
+        vectorize_with_builder_1_arg::<VariantType, NullableType<IntervalType>>(
+            |v, output, ctx| {
+                if let Some(validity) = &ctx.validity {
+                    if !validity.get_bit(output.len()) {
+                        output.push_null();
+                        return;
+                    }
+                }
+                match RawJsonb::new(v).as_interval() {
+                    Ok(Some(res)) => {
+                        output.push(months_days_micros::new(res.months, res.days, res.micros))
+                    }
+                    _ => output.push_null(),
+                }
+            },
+        ),
+    );
+
     registry.register_combine_nullable_1_arg::<VariantType, VariantType, _, _>(
         "as_array",
         |_, _| FunctionDomain::Full,
@@ -1122,6 +1267,10 @@ pub fn register(registry: &mut FunctionRegistry) {
                 output.push_null();
                 return;
             }
+            if let Ok(Some(date)) = raw_jsonb.as_date() {
+                output.push(date.value);
+                return;
+            }
             match raw_jsonb
                 .as_str()
                 .map_err(|e| format!("{e}"))
@@ -1156,6 +1305,10 @@ pub fn register(registry: &mut FunctionRegistry) {
                 }
             }
             let raw_jsonb = RawJsonb::new(val);
+            if let Ok(Some(date)) = raw_jsonb.as_date() {
+                output.push(date.value);
+                return;
+            }
             match raw_jsonb
                 .as_str()
                 .map_err(|e| format!("{e}"))
@@ -1191,6 +1344,10 @@ pub fn register(registry: &mut FunctionRegistry) {
                     output.push_null();
                     return;
                 }
+                if let Ok(Some(ts)) = raw_jsonb.as_timestamp() {
+                    output.push(ts.value);
+                    return;
+                }
                 match raw_jsonb
                     .as_str()
                     .map_err(|e| format!("{e}"))
@@ -1224,6 +1381,10 @@ pub fn register(registry: &mut FunctionRegistry) {
                 }
 
                 let raw_jsonb = RawJsonb::new(val);
+                if let Ok(Some(ts)) = raw_jsonb.as_timestamp() {
+                    output.push(ts.value);
+                    return;
+                }
                 match raw_jsonb
                     .as_str()
                     .map_err(|e| format!("{e}"))
diff --git a/src/query/functions/src/test_utils.rs b/src/query/functions/src/test_utils.rs
index c2b47fd701b4..70d03f9957fe 100644
--- a/src/query/functions/src/test_utils.rs
+++ b/src/query/functions/src/test_utils.rs
@@ -30,6 +30,7 @@ use databend_common_expression::type_check;
 use databend_common_expression::types::decimal::DecimalDataType;
 use databend_common_expression::types::decimal::DecimalScalar;
 use databend_common_expression::types::decimal::DecimalSize;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::DataType;
 use databend_common_expression::types::NumberDataType;
 use databend_common_expression::types::NumberScalar;
@@ -662,7 +663,7 @@ fn transform_literal(lit: ASTLiteral) -> Scalar {
             value,
             precision,
             scale,
-        } => Scalar::Decimal(DecimalScalar::Decimal256(value, DecimalSize {
+        } => Scalar::Decimal(DecimalScalar::Decimal256(i256(value), DecimalSize {
             precision,
             scale,
         })),
diff --git a/src/query/functions/tests/it/aggregates/agg_hashtable.rs b/src/query/functions/tests/it/aggregates/agg_hashtable.rs
index ec309c306f5c..368bd158237c 100644
--- a/src/query/functions/tests/it/aggregates/agg_hashtable.rs
+++ b/src/query/functions/tests/it/aggregates/agg_hashtable.rs
@@ -32,6 +32,7 @@ use std::sync::Arc;
 use bumpalo::Bump;
 use databend_common_expression::block_debug::assert_block_value_sort_eq;
 use databend_common_expression::get_states_layout;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::ArgType;
 use databend_common_expression::types::BooleanType;
 use databend_common_expression::types::DataType;
@@ -57,7 +58,6 @@ use databend_common_expression::PayloadFlushState;
 use databend_common_expression::ProbeState;
 use databend_common_functions::aggregates::AggregateFunctionFactory;
 use databend_common_functions::aggregates::DecimalSumState;
-use ethnum::I256;
 use itertools::Itertools;
 
 // cargo test --package databend-common-functions --test it -- aggregates::agg_hashtable::test_agg_hashtable --exact --nocapture
@@ -194,7 +194,7 @@ fn test_layout() {
         .get("sum", vec![], vec![decimal_type], vec![])
         .unwrap();
     type S = DecimalSumState<false, DecimalType<i128>>;
-    type M = DecimalSumState<false, DecimalType<I256>>;
+    type M = DecimalSumState<false, DecimalType<i256>>;
 
     let states_layout = get_states_layout(&[aggrs.clone()]).unwrap();
 
diff --git a/src/query/functions/tests/it/aggregates/testdata/agg.txt b/src/query/functions/tests/it/aggregates/testdata/agg.txt
index d206e21bb626..9d2c83c31c43 100644
--- a/src/query/functions/tests/it/aggregates/testdata/agg.txt
+++ b/src/query/functions/tests/it/aggregates/testdata/agg.txt
@@ -1467,12 +1467,12 @@ evaluation (internal):
 
 ast: json_array_agg(dt)
 evaluation (internal):
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
-| Column | Data                                                                                                                                                                                                                                                                  |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
-| dt     | Timestamp([1, 0, 2, 3])                                                                                                                                                                                                                                               |
-| Output | Variant([0x800000041000001a1000001a1000001a1000001a313937302d30312d30312030303a30303a30302e303030303031313937302d30312d30312030303a30303a30302e303030303030313937302d30312d30312030303a30303a30302e303030303032313937302d30312d30312030303a30303a30302e303030303033]) |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
++--------+-------------------------------------------------------------------------------------------------------------------------------+
+| Column | Data                                                                                                                          |
++--------+-------------------------------------------------------------------------------------------------------------------------------+
+| dt     | Timestamp([1, 0, 2, 3])                                                                                                       |
+| Output | Variant([0x8000000460000009600000096000000960000009200000000000000001200000000000000000200000000000000002200000000000000003]) |
++--------+-------------------------------------------------------------------------------------------------------------------------------+
 
 
 ast: json_array_agg(event1)
@@ -1487,12 +1487,12 @@ evaluation (internal):
 
 ast: json_array_agg(dec)
 evaluation (internal):
-+--------+-----------------------------------------------------------------------------------------------------+
-| Column | Data                                                                                                |
-+--------+-----------------------------------------------------------------------------------------------------+
-| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }             |
-| Output | Variant([0x80000003200000092000000920000009603ff199999999999a60400199999999999a60400a666666666666]) |
-+--------+-----------------------------------------------------------------------------------------------------+
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| Column | Data                                                                                                                                                            |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }                                                                         |
+| Output | Variant([0x80000003200000132000001320000013700000000000000000000000000000006e0f0270000000000000000000000000000000dc0f02700000000000000000000000000000014a0f02]) |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
 
 
 error: Json object have duplicate key 'k'
@@ -1523,13 +1523,13 @@ error: json_object_agg does not support key type 'Number(Int64)'
 
 ast: json_object_agg(s, dec)
 evaluation (internal):
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------+
-| Column | Data                                                                                                                                          |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------+
-| s      | StringColumn[abc, def, opq, xyz]                                                                                                              |
-| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }                                                       |
-| Output | Variant([0x4000000310000003100000031000000320000009200000092000000961626364656678797a603ff199999999999a60400199999999999a60400a666666666666]) |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------+
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| Column | Data                                                                                                                                                                                                      |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| s      | StringColumn[abc, def, opq, xyz]                                                                                                                                                                          |
+| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }                                                                                                                   |
+| Output | Variant([0x4000000310000003100000031000000320000013200000132000001361626364656678797a700000000000000000000000000000006e0f0270000000000000000000000000000000dc0f02700000000000000000000000000000014a0f02]) |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
 
 
 ast: mode(1)
diff --git a/src/query/functions/tests/it/aggregates/testdata/agg_group_by.txt b/src/query/functions/tests/it/aggregates/testdata/agg_group_by.txt
index 74d23b4e9a61..3ecbbdc08bb4 100644
--- a/src/query/functions/tests/it/aggregates/testdata/agg_group_by.txt
+++ b/src/query/functions/tests/it/aggregates/testdata/agg_group_by.txt
@@ -1405,12 +1405,12 @@ evaluation (internal):
 
 ast: json_array_agg(dt)
 evaluation (internal):
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
-| Column | Data                                                                                                                                                                                                                                                                  |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
-| dt     | Timestamp([1, 0, 2, 3])                                                                                                                                                                                                                                               |
-| Output | Variant([0x800000041000001a1000001a1000001a1000001a313937302d30312d30312030303a30303a30302e303030303031313937302d30312d30312030303a30303a30302e303030303030313937302d30312d30312030303a30303a30302e303030303032313937302d30312d30312030303a30303a30302e303030303033]) |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
++--------+-------------------------------------------------------------------------------------------------------------------------------+
+| Column | Data                                                                                                                          |
++--------+-------------------------------------------------------------------------------------------------------------------------------+
+| dt     | Timestamp([1, 0, 2, 3])                                                                                                       |
+| Output | Variant([0x8000000460000009600000096000000960000009200000000000000001200000000000000000200000000000000002200000000000000003]) |
++--------+-------------------------------------------------------------------------------------------------------------------------------+
 
 
 ast: json_array_agg(event1)
@@ -1425,12 +1425,12 @@ evaluation (internal):
 
 ast: json_array_agg(dec)
 evaluation (internal):
-+--------+-----------------------------------------------------------------------------------------------------+
-| Column | Data                                                                                                |
-+--------+-----------------------------------------------------------------------------------------------------+
-| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }             |
-| Output | Variant([0x80000003200000092000000920000009603ff199999999999a60400199999999999a60400a666666666666]) |
-+--------+-----------------------------------------------------------------------------------------------------+
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| Column | Data                                                                                                                                                            |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }                                                                         |
+| Output | Variant([0x80000003200000132000001320000013700000000000000000000000000000006e0f0270000000000000000000000000000000dc0f02700000000000000000000000000000014a0f02]) |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------+
 
 
 error: Json object have duplicate key 'k'
@@ -1461,13 +1461,13 @@ error: json_object_agg does not support key type 'Number(Int64)'
 
 ast: json_object_agg(s, dec)
 evaluation (internal):
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------+
-| Column | Data                                                                                                                                          |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------+
-| s      | StringColumn[abc, def, opq, xyz]                                                                                                              |
-| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }                                                       |
-| Output | Variant([0x4000000310000003100000031000000320000009200000092000000961626364656678797a603ff199999999999a60400199999999999a60400a666666666666]) |
-+--------+-----------------------------------------------------------------------------------------------------------------------------------------------+
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| Column | Data                                                                                                                                                                                                      |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
+| s      | StringColumn[abc, def, opq, xyz]                                                                                                                                                                          |
+| dec    | NullableColumn { column: Decimal128([1.10, 2.20, 0.00, 3.30]), validity: [0b____1011] }                                                                                                                   |
+| Output | Variant([0x4000000310000003100000031000000320000013200000132000001361626364656678797a700000000000000000000000000000006e0f0270000000000000000000000000000000dc0f02700000000000000000000000000000014a0f02]) |
++--------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
 
 
 ast: mode(1)
diff --git a/src/query/functions/tests/it/scalars/arithmetic.rs b/src/query/functions/tests/it/scalars/arithmetic.rs
index 4c36f206a160..0d31221e451f 100644
--- a/src/query/functions/tests/it/scalars/arithmetic.rs
+++ b/src/query/functions/tests/it/scalars/arithmetic.rs
@@ -16,10 +16,10 @@ use std::io::Write;
 
 use databend_common_expression::types::decimal::DecimalColumn;
 use databend_common_expression::types::decimal::DecimalSize;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::number::*;
 use databend_common_expression::Column;
 use databend_common_expression::FromData;
-use ethnum::i256;
 use goldenfile::Mint;
 
 use super::run_ast;
diff --git a/src/query/functions/tests/it/scalars/testdata/cast.txt b/src/query/functions/tests/it/scalars/testdata/cast.txt
index 6f7493425858..479d777f5d1f 100644
--- a/src/query/functions/tests/it/scalars/testdata/cast.txt
+++ b/src/query/functions/tests/it/scalars/testdata/cast.txt
@@ -231,7 +231,7 @@ output         : '-1'
 ast            : CAST(1.1 AS VARIANT)
 raw expr       : CAST(1.1 AS Variant)
 checked expr   : CAST<Decimal(2, 1)>(1.1_d128(2,1) AS Variant)
-optimized expr : 0x2000000020000009603ff199999999999a
+optimized expr : 0x2000000020000013700000000000000000000000000000000b0201
 output type    : Variant
 output domain  : Undefined
 output         : '1.1'
@@ -266,7 +266,7 @@ output         : '[0,"a"]'
 ast            : CAST(to_timestamp(1000000) AS VARIANT)
 raw expr       : CAST(to_timestamp(1000000) AS Variant)
 checked expr   : CAST<Timestamp>(CAST<Int64>(CAST<UInt32>(1000000_u32 AS Int64) AS Timestamp) AS Variant)
-optimized expr : 0x200000001000001a313937302d30312d31322031333a34363a34302e303030303030
+optimized expr : 0x200000006000000920000000e8d4a51000
 output type    : Variant
 output domain  : Undefined
 output         : '"1970-01-12 13:46:40.000000"'
@@ -2409,7 +2409,7 @@ output         : '-1'
 ast            : TRY_CAST(1.1 AS VARIANT)
 raw expr       : TRY_CAST(1.1 AS Variant)
 checked expr   : TRY_CAST<Decimal(2, 1)>(1.1_d128(2,1) AS Variant NULL)
-optimized expr : 0x2000000020000009603ff199999999999a
+optimized expr : 0x2000000020000013700000000000000000000000000000000b0201
 output type    : Variant NULL
 output domain  : Undefined
 output         : '1.1'
@@ -2445,7 +2445,7 @@ output         : '[0,"a"]'
 ast            : TRY_CAST(to_timestamp(1000000) AS VARIANT)
 raw expr       : TRY_CAST(to_timestamp(1000000) AS Variant)
 checked expr   : TRY_CAST<Timestamp>(CAST<Int64>(CAST<UInt32>(1000000_u32 AS Int64) AS Timestamp) AS Variant NULL)
-optimized expr : 0x200000001000001a313937302d30312d31322031333a34363a34302e303030303030
+optimized expr : 0x200000006000000920000000e8d4a51000
 output type    : Variant NULL
 output domain  : Undefined
 output         : '"1970-01-12 13:46:40.000000"'
diff --git a/src/query/functions/tests/it/scalars/testdata/function_list.txt b/src/query/functions/tests/it/scalars/testdata/function_list.txt
index 8d282ba9081b..fb4bb55d4216 100644
--- a/src/query/functions/tests/it/scalars/testdata/function_list.txt
+++ b/src/query/functions/tests/it/scalars/testdata/function_list.txt
@@ -201,16 +201,24 @@ Functions overloads:
 0 arrays_zip FACTORY
 0 as_array(Variant) :: Variant NULL
 1 as_array(Variant NULL) :: Variant NULL
+0 as_binary(Variant) :: Binary NULL
+1 as_binary(Variant NULL) :: Binary NULL
 0 as_boolean(Variant) :: Boolean NULL
 1 as_boolean(Variant NULL) :: Boolean NULL
+0 as_date(Variant) :: Date NULL
+1 as_date(Variant NULL) :: Date NULL
 0 as_float(Variant) :: Float64 NULL
 1 as_float(Variant NULL) :: Float64 NULL
 0 as_integer(Variant) :: Int64 NULL
 1 as_integer(Variant NULL) :: Int64 NULL
+0 as_interval(Variant) :: Interval NULL
+1 as_interval(Variant NULL) :: Interval NULL
 0 as_object(Variant) :: Variant NULL
 1 as_object(Variant NULL) :: Variant NULL
 0 as_string(Variant) :: String NULL
 1 as_string(Variant NULL) :: String NULL
+0 as_timestamp(Variant) :: Timestamp NULL
+1 as_timestamp(Variant NULL) :: Timestamp NULL
 0 ascii(String) :: UInt8
 1 ascii(String NULL) :: UInt8 NULL
 0 asin(Float64) :: Float64
@@ -2053,12 +2061,18 @@ Functions overloads:
 1 instr(String NULL, String NULL) :: UInt64 NULL
 0 is_array(Variant) :: Boolean
 1 is_array(Variant NULL) :: Boolean NULL
+0 is_binary(Variant) :: Boolean
+1 is_binary(Variant NULL) :: Boolean NULL
 0 is_boolean(Variant) :: Boolean
 1 is_boolean(Variant NULL) :: Boolean NULL
+0 is_date(Variant) :: Boolean
+1 is_date(Variant NULL) :: Boolean NULL
 0 is_float(Variant) :: Boolean
 1 is_float(Variant NULL) :: Boolean NULL
 0 is_integer(Variant) :: Boolean
 1 is_integer(Variant NULL) :: Boolean NULL
+0 is_interval(Variant) :: Boolean
+1 is_interval(Variant NULL) :: Boolean NULL
 0 is_not_error(T0) :: Boolean
 0 is_not_null(NULL) :: Boolean
 1 is_not_null(T0 NULL) :: Boolean
@@ -2068,6 +2082,8 @@ Functions overloads:
 1 is_object(Variant NULL) :: Boolean NULL
 0 is_string(Variant) :: Boolean
 1 is_string(Variant NULL) :: Boolean NULL
+0 is_timestamp(Variant) :: Boolean
+1 is_timestamp(Variant NULL) :: Boolean NULL
 0 is_true(Boolean) :: Boolean
 1 is_true(Boolean NULL) :: Boolean
 0 jaro_winkler(String, String) :: Float64
diff --git a/src/query/functions/tests/it/scalars/testdata/variant.txt b/src/query/functions/tests/it/scalars/testdata/variant.txt
index b13b2830bb6c..13cb06602235 100644
--- a/src/query/functions/tests/it/scalars/testdata/variant.txt
+++ b/src/query/functions/tests/it/scalars/testdata/variant.txt
@@ -1064,6 +1064,42 @@ output domain  : Undefined
 output         : '{"a":"b"}'
 
 
+ast            : as_binary(to_binary('abcd')::variant)
+raw expr       : as_binary(CAST(to_binary('abcd') AS Variant))
+checked expr   : as_binary<Variant>(CAST<Binary>(CAST<String>("abcd" AS Binary) AS Variant))
+optimized expr : 61626364
+output type    : Binary NULL
+output domain  : Undefined
+output         : 61626364
+
+
+ast            : as_date(to_date('2025-10-11')::variant)
+raw expr       : as_date(CAST(to_date('2025-10-11') AS Variant))
+checked expr   : as_date<Variant>(CAST<Date>(CAST<String>("2025-10-11" AS Date) AS Variant))
+optimized expr : 20372
+output type    : Date NULL
+output domain  : {20372..=20372}
+output         : '2025-10-11'
+
+
+ast            : as_timestamp(to_timestamp('2025-05-01 10:00:00')::variant)
+raw expr       : as_timestamp(CAST(to_timestamp('2025-05-01 10:00:00') AS Variant))
+checked expr   : as_timestamp<Variant>(CAST<Timestamp>(CAST<String>("2025-05-01 10:00:00" AS Timestamp) AS Variant))
+optimized expr : 1746093600000000
+output type    : Timestamp NULL
+output domain  : {1746093600000000..=1746093600000000}
+output         : '2025-05-01 10:00:00.000000'
+
+
+ast            : as_interval(to_interval('1 year 2 month')::variant)
+raw expr       : as_interval(CAST(to_interval('1 year 2 month') AS Variant))
+checked expr   : as_interval<Variant>(CAST<Interval>(CAST<String>("1 year 2 month" AS Interval) AS Variant))
+optimized expr : 1 year 2 months
+output type    : Interval NULL
+output domain  : SimpleDomain { min: months_days_micros(1109194275199700726309615304704), max: months_days_micros(1109194275199700726309615304704) }
+output         : '1 year 2 months'
+
+
 ast            : as_boolean(parse_json(s))
 raw expr       : as_boolean(parse_json(s::String))
 checked expr   : as_boolean<Variant>(CAST<String>(s AS Variant))
@@ -1346,6 +1382,42 @@ output domain  : {TRUE}
 output         : true
 
 
+ast            : is_binary(to_binary('abcd')::variant)
+raw expr       : is_binary(CAST(to_binary('abcd') AS Variant))
+checked expr   : is_binary<Variant>(CAST<Binary>(CAST<String>("abcd" AS Binary) AS Variant))
+optimized expr : true
+output type    : Boolean
+output domain  : {TRUE}
+output         : true
+
+
+ast            : is_date(to_date('2025-10-11')::variant)
+raw expr       : is_date(CAST(to_date('2025-10-11') AS Variant))
+checked expr   : is_date<Variant>(CAST<Date>(CAST<String>("2025-10-11" AS Date) AS Variant))
+optimized expr : true
+output type    : Boolean
+output domain  : {TRUE}
+output         : true
+
+
+ast            : is_timestamp(to_timestamp('2025-05-01 10:00:00')::variant)
+raw expr       : is_timestamp(CAST(to_timestamp('2025-05-01 10:00:00') AS Variant))
+checked expr   : is_timestamp<Variant>(CAST<Timestamp>(CAST<String>("2025-05-01 10:00:00" AS Timestamp) AS Variant))
+optimized expr : true
+output type    : Boolean
+output domain  : {TRUE}
+output         : true
+
+
+ast            : is_interval(to_interval('1 year 2 month')::variant)
+raw expr       : is_interval(CAST(to_interval('1 year 2 month') AS Variant))
+checked expr   : is_interval<Variant>(CAST<Interval>(CAST<String>("1 year 2 month" AS Interval) AS Variant))
+optimized expr : true
+output type    : Boolean
+output domain  : {TRUE}
+output         : true
+
+
 ast            : is_null_value(parse_json(s))
 raw expr       : is_null_value(parse_json(s::String))
 checked expr   : is_null_value<Variant>(CAST<String>(s AS Variant))
diff --git a/src/query/functions/tests/it/scalars/variant.rs b/src/query/functions/tests/it/scalars/variant.rs
index d7a708912c86..d735f11a78fa 100644
--- a/src/query/functions/tests/it/scalars/variant.rs
+++ b/src/query/functions/tests/it/scalars/variant.rs
@@ -510,6 +510,18 @@ fn test_as_type(file: &mut impl Write) {
     run_ast(file, "as_array(parse_json('{\"a\":\"b\"}'))", &[]);
     run_ast(file, "as_object(parse_json('[1,2,3]'))", &[]);
     run_ast(file, "as_object(parse_json('{\"a\":\"b\"}'))", &[]);
+    run_ast(file, "as_binary(to_binary('abcd')::variant)", &[]);
+    run_ast(file, "as_date(to_date('2025-10-11')::variant)", &[]);
+    run_ast(
+        file,
+        "as_timestamp(to_timestamp('2025-05-01 10:00:00')::variant)",
+        &[],
+    );
+    run_ast(
+        file,
+        "as_interval(to_interval('1 year 2 month')::variant)",
+        &[],
+    );
 
     let columns = &[(
         "s",
@@ -546,6 +558,18 @@ fn test_is_type(file: &mut impl Write) {
     run_ast(file, "is_array(parse_json('{\"a\":\"b\"}'))", &[]);
     run_ast(file, "is_object(parse_json('[1,2,3]'))", &[]);
     run_ast(file, "is_object(parse_json('{\"a\":\"b\"}'))", &[]);
+    run_ast(file, "is_binary(to_binary('abcd')::variant)", &[]);
+    run_ast(file, "is_date(to_date('2025-10-11')::variant)", &[]);
+    run_ast(
+        file,
+        "is_timestamp(to_timestamp('2025-05-01 10:00:00')::variant)",
+        &[],
+    );
+    run_ast(
+        file,
+        "is_interval(to_interval('1 year 2 month')::variant)",
+        &[],
+    );
 
     let columns = &[(
         "s",
diff --git a/src/query/functions/tests/it/type_check.rs b/src/query/functions/tests/it/type_check.rs
index fb6f7caf5114..6ff001278411 100644
--- a/src/query/functions/tests/it/type_check.rs
+++ b/src/query/functions/tests/it/type_check.rs
@@ -75,10 +75,10 @@ fn test_type_check() {
             "n_d128",
             Decimal128Type::from_data(vec![0_i128]).wrap_nullable(None),
         ),
-        ("d256", Decimal256Type::from_data(vec![ethnum::I256::ZERO])),
+        ("d256", Decimal256Type::from_data(vec![i256::ZERO])),
         (
             "n_d256",
-            Decimal256Type::from_data(vec![ethnum::I256::ZERO]).wrap_nullable(None),
+            Decimal256Type::from_data(vec![i256::ZERO]).wrap_nullable(None),
         ),
     ];
 
diff --git a/src/query/service/src/servers/mysql/writers/query_result_writer.rs b/src/query/service/src/servers/mysql/writers/query_result_writer.rs
index d7f2ae88d8b3..1503d8db730d 100644
--- a/src/query/service/src/servers/mysql/writers/query_result_writer.rs
+++ b/src/query/service/src/servers/mysql/writers/query_result_writer.rs
@@ -191,6 +191,7 @@ impl<'a, W: AsyncWrite + Send + Unpin> DFQueryResultWriter<'a, W> {
                 DataType::Geometry => Ok(ColumnType::MYSQL_TYPE_GEOMETRY),
                 DataType::Geography => Ok(ColumnType::MYSQL_TYPE_GEOMETRY),
                 DataType::Decimal(_) => Ok(ColumnType::MYSQL_TYPE_DECIMAL),
+                DataType::Interval => Ok(ColumnType::MYSQL_TYPE_VARCHAR),
                 _ => Err(ErrorCode::Unimplemented(format!(
                     "Unsupported column type:{:?}",
                     field.data_type()
diff --git a/src/query/sql/src/planner/semantic/type_check.rs b/src/query/sql/src/planner/semantic/type_check.rs
index 762baa4f6908..19b95109f39e 100644
--- a/src/query/sql/src/planner/semantic/type_check.rs
+++ b/src/query/sql/src/planner/semantic/type_check.rs
@@ -71,6 +71,7 @@ use databend_common_expression::types::decimal::DecimalScalar;
 use databend_common_expression::types::decimal::DecimalSize;
 use databend_common_expression::types::decimal::MAX_DECIMAL128_PRECISION;
 use databend_common_expression::types::decimal::MAX_DECIMAL256_PRECISION;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::DataType;
 use databend_common_expression::types::NumberDataType;
 use databend_common_expression::types::NumberScalar;
@@ -3961,7 +3962,7 @@ impl<'a> TypeChecker<'a> {
                 value,
                 precision,
                 scale,
-            } => Scalar::Decimal(DecimalScalar::Decimal256(*value, DecimalSize {
+            } => Scalar::Decimal(DecimalScalar::Decimal256(i256(*value), DecimalSize {
                 precision: *precision,
                 scale: *scale,
             })),
diff --git a/src/query/storages/parquet/Cargo.toml b/src/query/storages/parquet/Cargo.toml
index 5de7ef57db6f..237cf1217808 100644
--- a/src/query/storages/parquet/Cargo.toml
+++ b/src/query/storages/parquet/Cargo.toml
@@ -30,7 +30,6 @@ databend-storages-common-cache = { workspace = true }
 databend-storages-common-pruner = { workspace = true }
 databend-storages-common-stage = { workspace = true }
 databend-storages-common-table-meta = { workspace = true }
-ethnum = { workspace = true }
 futures = { workspace = true }
 log = { workspace = true }
 opendal = { workspace = true }
diff --git a/src/query/storages/parquet/src/parquet_rs/statistics/column.rs b/src/query/storages/parquet/src/parquet_rs/statistics/column.rs
index ac155c9a4b04..c410c370e61c 100644
--- a/src/query/storages/parquet/src/parquet_rs/statistics/column.rs
+++ b/src/query/storages/parquet/src/parquet_rs/statistics/column.rs
@@ -12,14 +12,13 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use databend_common_expression::types::decimal::Decimal;
 use databend_common_expression::types::decimal::DecimalScalar;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::DecimalDataType;
 use databend_common_expression::types::NumberDataType;
 use databend_common_expression::Scalar;
 use databend_common_expression::TableDataType;
 use databend_storages_common_table_meta::meta::ColumnStatistics;
-use ethnum::I256;
 use parquet::data_type::AsBytes;
 use parquet::file::statistics::Statistics;
 
@@ -58,8 +57,8 @@ pub fn convert_column_statistics(s: &Statistics, typ: &TableDataType) -> Option<
                         Scalar::Decimal(DecimalScalar::Decimal128(i128::from(min), *size)),
                     ),
                     TableDataType::Decimal(DecimalDataType::Decimal256(size)) => (
-                        Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(max), *size)),
-                        Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(min), *size)),
+                        Scalar::Decimal(DecimalScalar::Decimal256(i256::from(max), *size)),
+                        Scalar::Decimal(DecimalScalar::Decimal256(i256::from(min), *size)),
                     ),
                     _ => return None,
                 }
@@ -89,8 +88,8 @@ pub fn convert_column_statistics(s: &Statistics, typ: &TableDataType) -> Option<
                         Scalar::Decimal(DecimalScalar::Decimal128(i128::from(min), *size)),
                     ),
                     TableDataType::Decimal(DecimalDataType::Decimal256(size)) => (
-                        Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(max), *size)),
-                        Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(min), *size)),
+                        Scalar::Decimal(DecimalScalar::Decimal256(i256::from(max), *size)),
+                        Scalar::Decimal(DecimalScalar::Decimal256(i256::from(min), *size)),
                     ),
                     _ => return None,
                 }
diff --git a/src/query/storages/parquet/src/parquet_rs/statistics/page.rs b/src/query/storages/parquet/src/parquet_rs/statistics/page.rs
index 0ae34f62bab0..016d9a514716 100644
--- a/src/query/storages/parquet/src/parquet_rs/statistics/page.rs
+++ b/src/query/storages/parquet/src/parquet_rs/statistics/page.rs
@@ -12,14 +12,13 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use databend_common_expression::types::decimal::Decimal;
 use databend_common_expression::types::decimal::DecimalScalar;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::DecimalDataType;
 use databend_common_expression::types::NumberDataType;
 use databend_common_expression::Scalar;
 use databend_common_expression::TableDataType;
 use databend_storages_common_table_meta::meta::ColumnStatistics;
-use ethnum::I256;
 use parquet::data_type::AsBytes;
 use parquet::data_type::ByteArray;
 use parquet::data_type::FixedLenByteArray;
@@ -135,8 +134,8 @@ fn convert_page_index_int32(
                     Scalar::Decimal(DecimalScalar::Decimal128(i128::from(min), *size)),
                 ),
                 TableDataType::Decimal(DecimalDataType::Decimal256(size)) => (
-                    Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(max), *size)),
-                    Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(min), *size)),
+                    Scalar::Decimal(DecimalScalar::Decimal256(i256::from(max), *size)),
+                    Scalar::Decimal(DecimalScalar::Decimal256(i256::from(min), *size)),
                 ),
                 _ => unreachable!(),
             };
@@ -165,8 +164,8 @@ fn convert_page_index_int64(
                     Scalar::Decimal(DecimalScalar::Decimal128(i128::from(min), *size)),
                 ),
                 TableDataType::Decimal(DecimalDataType::Decimal256(size)) => (
-                    Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(max), *size)),
-                    Scalar::Decimal(DecimalScalar::Decimal256(I256::from_i128(min), *size)),
+                    Scalar::Decimal(DecimalScalar::Decimal256(i256::from(max), *size)),
+                    Scalar::Decimal(DecimalScalar::Decimal256(i256::from(min), *size)),
                 ),
                 _ => unreachable!(),
             };
diff --git a/src/query/storages/parquet/src/parquet_rs/statistics/utils.rs b/src/query/storages/parquet/src/parquet_rs/statistics/utils.rs
index c155ca5d8930..e1fc7efa6c1a 100644
--- a/src/query/storages/parquet/src/parquet_rs/statistics/utils.rs
+++ b/src/query/storages/parquet/src/parquet_rs/statistics/utils.rs
@@ -16,7 +16,6 @@ use arrow_buffer::i256;
 use databend_common_expression::types::decimal::DecimalScalar;
 use databend_common_expression::types::DecimalSize;
 use databend_common_expression::Scalar;
-use ethnum::I256;
 use parquet::data_type::AsBytes;
 use parquet::data_type::FixedLenByteArray;
 
@@ -28,7 +27,7 @@ pub fn decode_decimal128_from_bytes(arr: &FixedLenByteArray, size: DecimalSize)
 pub fn decode_decimal256_from_bytes(arr: &FixedLenByteArray, size: DecimalSize) -> Scalar {
     let v = i256::from_be_bytes(sign_extend_be(arr.as_bytes()));
     let (lo, hi) = v.to_parts();
-    let v = I256::from_words(hi, lo as i128);
+    let v = databend_common_expression::types::i256::from_words(hi, lo as i128);
     Scalar::Decimal(DecimalScalar::Decimal256(v, size))
 }
 
diff --git a/src/query/storages/stage/Cargo.toml b/src/query/storages/stage/Cargo.toml
index 819eb79df1fe..8aa6da5dee40 100644
--- a/src/query/storages/stage/Cargo.toml
+++ b/src/query/storages/stage/Cargo.toml
@@ -35,7 +35,6 @@ databend-common-version = { workspace = true }
 databend-storages-common-stage = { workspace = true }
 databend-storages-common-table-meta = { workspace = true }
 enum-as-inner = { workspace = true }
-ethnum = { workspace = true }
 futures = { workspace = true }
 jsonb = { workspace = true }
 lexical-core = { workspace = true }
diff --git a/src/query/storages/stage/src/read/avro/decoder.rs b/src/query/storages/stage/src/read/avro/decoder.rs
index ba2952cb8ac0..4214ef693d90 100644
--- a/src/query/storages/stage/src/read/avro/decoder.rs
+++ b/src/query/storages/stage/src/read/avro/decoder.rs
@@ -530,6 +530,7 @@ mod test {
     use apache_avro::Decimal;
     use apache_avro::Schema;
     use apache_avro::Writer;
+    use databend_common_expression::types::i256;
     use databend_common_expression::types::DecimalDataType;
     use databend_common_expression::types::DecimalScalar;
     use databend_common_expression::types::DecimalSize;
@@ -541,7 +542,6 @@ mod test {
     use databend_common_expression::TableField;
     use databend_common_expression::TableSchema;
     use databend_common_expression::TableSchemaRef;
-    use ethnum::i256;
     use num_bigint::BigInt;
     use serde_json::json;
 
diff --git a/src/query/storages/stage/src/read/avro/schema_match.rs b/src/query/storages/stage/src/read/avro/schema_match.rs
index c2971b819ffe..1cfefcb1c747 100644
--- a/src/query/storages/stage/src/read/avro/schema_match.rs
+++ b/src/query/storages/stage/src/read/avro/schema_match.rs
@@ -15,10 +15,10 @@
 use apache_avro::schema::RecordSchema;
 use apache_avro::schema::UnionSchema;
 use apache_avro::Schema;
+use databend_common_expression::types::i256;
 use databend_common_expression::types::Decimal;
 use databend_common_expression::types::NumberDataType;
 use databend_common_expression::TableDataType;
-use ethnum::i256;
 
 type MatchResult<T> = Result<T, String>;
 
diff --git a/tests/sqllogictests/suites/query/functions/02_0056_function_semi_structureds_as.test b/tests/sqllogictests/suites/query/functions/02_0056_function_semi_structureds_as.test
index 44af537ae785..bb3a5201343c 100644
--- a/tests/sqllogictests/suites/query/functions/02_0056_function_semi_structureds_as.test
+++ b/tests/sqllogictests/suites/query/functions/02_0056_function_semi_structureds_as.test
@@ -58,6 +58,25 @@ select as_object(parse_json('{"k": 123}'))
 ----
 {"k":123}
 
+query TT
+select to_binary('abc')::variant, as_binary(to_binary('abc')::variant)
+----
+"616263" 616263
+
+query TT
+select to_date('2025-01-01')::variant, as_date(to_date('2025-01-01')::variant)
+----
+"2025-01-01" 2025-01-01
+
+query TT
+select to_timestamp('2025-01-01 10:00:00')::variant, as_timestamp(to_timestamp('2025-01-01 10:00:00')::variant)
+----
+"2025-01-01 10:00:00.000000" 2025-01-01 10:00:00.000000
+
+query TT
+select to_interval('10 months 2 days')::variant, as_interval(to_interval('10 months 2 days')::variant)
+----
+"10 months 2 days" 10 months 2 days
 
 query B
 select is_null_value(parse_json('null'))
@@ -129,6 +148,27 @@ select is_object(parse_json('["a","b","c"]'))
 ----
 0
 
+query B
+select is_binary(to_binary('abc')::variant)
+----
+1
+
+query B 
+select is_date(to_date('2025-01-01')::variant)
+----
+1
+
+query B
+select is_timestamp(to_timestamp('2025-01-01 10:00:00')::variant)
+----
+1
+
+query B
+select is_interval(to_interval('10 months 2 days')::variant)
+----
+1
+
+
 statement ok
 DROP DATABASE IF EXISTS db1
 
@@ -187,3 +227,4 @@ select id, v, is_null_value(v), is_boolean(v), is_integer(v), is_float(v), is_st
 statement ok
 DROP DATABASE db1
 
+