Support UNSIGNED TINYINT SMALLINT INT BIGINT

Author: wyhaya

crossdb

@@ -45,6 +45,8 @@ pub enum DataType {
     Inet = xdb_type_t_XDB_TYPE_INET,
     #[strum(serialize = "MAC")]
     Mac = xdb_type_t_XDB_TYPE_MAC,
+    #[strum(serialize = "JSON")]
+    Json = xdb_type_t_XDB_TYPE_JSON,
     #[strum(serialize = "ARRAY")]
     Array = xdb_type_t_XDB_TYPE_ARRAY,
     #[strum(serialize = "MAX")]

src/column.rs

@@ -85,6 +85,8 @@ impl<'de> Deserializer<'de> for ValueDeserializer<'de> {
             Value::Null => visitor.visit_none(),
             Value::I32(v) => visitor.visit_i32(v),
             Value::I64(v) => visitor.visit_i64(v),
+            Value::U32(v) => visitor.visit_u32(v),
+            Value::U64(v) => visitor.visit_u64(v),
             Value::F32(v) => visitor.visit_f32(v),
             Value::F64(v) => visitor.visit_f64(v),
             // TODO

src/de.rs

@@ -8,6 +8,8 @@ pub enum Value<'a> {
     Null,
     I32(i32),
     I64(i64),
+    U32(u32),
+    U64(u64),
     F32(f32),
     F64(f64),
     Timestamp(i64),
@@ -25,6 +27,8 @@ impl Display for Value<'_> {
             Value::Null => write!(f, "NULL"),
             Value::I32(v) => write!(f, "{}", v),
             Value::I64(v) => write!(f, "{}", v),
+            Value::U32(v) => write!(f, "{}", v),
+            Value::U64(v) => write!(f, "{}", v),
             Value::F32(v) => write!(f, "{}", v),
             Value::F64(v) => write!(f, "{}", v),
             Value::Timestamp(v) => write!(f, "{}", v),
@@ -49,14 +53,14 @@ impl Value<'_> {
         }
         match t {
             DataType::Null => Self::Null,
-            DataType::TinyInt => Self::I32(xdb_column_int(res, row, i)),
-            DataType::SmallInt => Self::I32(xdb_column_int(res, row, i)),
-            DataType::Int => Self::I32(xdb_column_int(res, row, i)),
+            DataType::TinyInt | DataType::SmallInt | DataType::Int => {
+                Self::I32(xdb_column_int(res, row, i))
+            }
             DataType::BigInt => Self::I64(xdb_column_int64(res, row, i)),
-            DataType::UTinyInt => todo!(),
-            DataType::USmallInt => todo!(),
-            DataType::UInt => todo!(),
-            DataType::UBigInt => todo!(),
+            DataType::UTinyInt | DataType::USmallInt | DataType::UInt => {
+                Self::U32(xdb_column_uint(res, row, i))
+            }
+            DataType::UBigInt => Self::U64(xdb_column_uint64(res, row, i)),
             DataType::Float => Self::F32(xdb_column_float(res, row, i)),
             DataType::Double => Self::F64(xdb_column_double(res, row, i)),
             DataType::Timestamp => Self::Timestamp(xdb_column_int64(res, row, i)),
@@ -96,6 +100,7 @@ impl Value<'_> {
                 let address = MacAddress::new(mac.addr);
                 Self::Mac(address)
             }
+            DataType::Json => todo!(),
             DataType::Array => todo!(),
             DataType::Max => todo!(),
         }