support parsing field type(char,time)

caicancai · caicancai · commit 45813db7bce4 · 2023-04-19T22:29:34.000+08:00
diff --git a/binlog-stream/app/io/laserdisc/mysql/binlog/stream/TransactionState.scala b/binlog-stream/app/io/laserdisc/mysql/binlog/stream/TransactionState.scala
@@ -353,10 +353,10 @@ object TransactionState {
       val jsonValue = metadata.dataType match {
         case "bigint"            => Json.fromLong(value.asInstanceOf[Long])
         case "int" | "tinyint"   => Json.fromInt(value.asInstanceOf[Int])
-        case "date" | "datetime" => Json.fromLong(value.asInstanceOf[Long])
+        case "date" | "datetime" | "time" => Json.fromLong(value.asInstanceOf[Long])
         case "decimal"           => Json.fromBigDecimal(value.asInstanceOf[BigDecimal])
         case "float"             => Json.fromFloat(value.asInstanceOf[Float]).get
-        case "text" | "mediumtext" | "longtext" | "tinytext" | "varchar" =>
+        case "text" | "mediumtext" | "longtext" | "tinytext" | "varchar | "char" =>
           Json.fromString(new String(value.asInstanceOf[Array[Byte]]))
         case "json" =>
           Json.fromString(JsonBinary.parseAsString(value.asInstanceOf[Array[Byte]]))
