fix varbinary type error

common_types/src/datum.rs

@@ -213,6 +213,7 @@ impl TryFrom<&SqlDataType> for DatumKind {
             SqlDataType::Int(_) => Ok(Self::Int32),
             SqlDataType::SmallInt(_) => Ok(Self::Int16),
             SqlDataType::String => Ok(Self::String),
+            SqlDataType::Varbinary(_) => Ok(Self::Varbinary),
             SqlDataType::Custom(objects, _) if objects.0.len() == 1 => {
                 match objects.0[0].value.as_str() {
                     "UINT64" | "uint64" => Ok(Self::UInt64),
@@ -223,7 +224,6 @@ impl TryFrom<&SqlDataType> for DatumKind {
                     "INT32" | "int32" => Ok(Self::Int32),
                     "INT16" | "int16" => Ok(Self::Int16),
                     "TINYINT" | "INT8" | "tinyint" | "int8" => Ok(Self::Int8),
-                    "VARBINARY" | "varbinary" => Ok(Self::Varbinary),
                     _ => UnsupportedDataType {
                         sql_type: sql_type.clone(),
                     }

integration_tests/cases/local/03_dml/issue-637.result

@@ -0,0 +1,31 @@
+DROP TABLE IF EXISTS `issue637`;
+
+affected_rows: 0
+
+CREATE TABLE IF NOT EXISTS `issue637`
+(
+    str_tag string TAG,
+    int_tag int32 TAG,
+    var_tag VARBINARY TAG,
+    str_field string,
+    int_field int32,
+    bin_field string,
+    t timestamp NOT NULL,
+     TIMESTAMP KEY (t)
+) ENGINE=Analytic with(enable_ttl = 'false');
+
+affected_rows: 0
+
+INSERT INTO issue637
+    (`str_tag`,`int_tag`,`var_tag`,`str_field`,`int_field`,`bin_field`,`t`)
+VALUES
+    ("t1",1,"v1","s1",1,"b1",1651737067000);
+
+affected_rows: 1
+
+select * from `issue637`;
+
+tsid,t,str_tag,int_tag,var_tag,str_field,int_field,bin_field,
+UInt64(15527369105987057363),Timestamp(1651737067000),String("t1"),Int32(1),Varbinary([118, 49]),String("s1"),Int32(1),String("b1"),
+
+

integration_tests/cases/local/03_dml/issue-637.sql

@@ -0,0 +1,22 @@
+DROP TABLE IF EXISTS `issue637`;
+
+CREATE TABLE IF NOT EXISTS `issue637`
+(
+    str_tag string TAG,
+    int_tag int32 TAG,
+    var_tag VARBINARY TAG,
+    str_field string,
+    int_field int32,
+    bin_field string,
+    t timestamp NOT NULL,
+     TIMESTAMP KEY (t)
+) ENGINE=Analytic with(enable_ttl = 'false');
+
+
+INSERT INTO issue637
+    (`str_tag`,`int_tag`,`var_tag`,`str_field`,`int_field`,`bin_field`,`t`)
+VALUES
+    ("t1",1,"v1","s1",1,"b1",1651737067000);
+
+select * from `issue637`;
+