refactor: enhance copy from avro. (#17709)

* refactor: enhance copy from avro.

1. support more types.
2. support default expr.
3. add unit test.

* fix flaky test

Author: youngsofun

Cargo.lock

@@ -399,6 +399,7 @@ pub trait Decimal:
 
     fn from_float(value: f64) -> Self;
     fn from_i128<U: Into<i128>>(value: U) -> Self;
+    fn from_i256(value: i256) -> Self;
     fn from_bigint(value: BigInt) -> Option<Self>;
 
     fn de_binary(bytes: &mut &[u8]) -> Self;
@@ -578,6 +579,10 @@ impl Decimal for i128 {
         value.into()
     }
 
+    fn from_i256(value: i256) -> Self {
+        value.as_i128()
+    }
+
     fn from_bigint(value: BigInt) -> Option<Self> {
         value.to_i128()
     }
@@ -811,6 +816,10 @@ impl Decimal for i256 {
         i256::from(value.into())
     }
 
+    fn from_i256(value: i256) -> Self {
+        value
+    }
+
     fn from_bigint(value: BigInt) -> Option<Self> {
         let mut ret: u256 = u256::ZERO;
         let mut bits = 0;

src/query/expression/src/types/decimal.rs

@@ -35,11 +35,13 @@ databend-common-storages-parquet = { 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 }
 log = { workspace = true }
 match-template = { workspace = true }
+num-bigint = { workspace = true }
 num-traits = { workspace = true }
 opendal = { workspace = true }
 parquet = { workspace = true }

src/query/storages/stage/Cargo.toml

@@ -26,6 +26,7 @@ pub(super) fn to_jsonb(value: &Value) -> Result<jsonb::Value, String> {
         Value::Double(v) => jsonb::Value::from(*v),
         Value::String(v) => jsonb::Value::from(v.as_str()),
         Value::Enum(_, v) => jsonb::Value::from(v.as_str()),
+        Value::Uuid(v) => jsonb::Value::from(v.to_string()),
         Value::Union(_, v) => to_jsonb(v)?,
         Value::Array(v) => {
             let mut array = Vec::with_capacity(v.len());
@@ -62,7 +63,6 @@ pub(super) fn to_jsonb(value: &Value) -> Result<jsonb::Value, String> {
         // Value::LocalTimestampMicros(_) => {}
         // Value::LocalTimestampNanos(_) => {}
         // Value::Duration(_) => {}
-        // Value::Uuid(_) => {}
     };
     Ok(jvalue)
 }