refact: refator parse jsbon

ihippik · Oct 4, 2022 · a1c3221 · a1c3221
1 parent e381389
commit a1c3221
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/listener/wal_transaction.go b/listener/wal_transaction.go
@@ -104,15 +104,14 @@ func (c *Column) AssertValue(src []byte) {
 	case UUIDOID:
 		val, err = uuid.Parse(strSrc)
 	case JSONBOID:
+		var m any
 		if src[0] == '[' {
-			m := make([]any, 0)
-			err = json.Unmarshal(src, &m)
-			val = m
+			m = make([]any, 0)
 		} else {
-			m := make(map[string]any)
-			err = json.Unmarshal(src, &m)
-			val = m
+			m = make(map[string]any)
 		}
+		err = json.Unmarshal(src, &m)
+		val = m
 	default:
 		logrus.WithFields(logrus.Fields{"pgtype": c.valueType, "column_name": c.name}).Warnln("unknown oid type")
 		val = strSrc