another another type to add

PeerDB-io · Dec 11, 2024 · dff1b04 · dff1b04
1 parent de7c766
commit dff1b04
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/flow/e2e/clickhouse/clickhouse.go b/flow/e2e/clickhouse/clickhouse.go
@@ -198,6 +198,14 @@ func (s ClickHouseSuite) GetRows(table string, cols string) (*model.QRecordBatch
 				}
 			case *int64:
 				qrow = append(qrow, qvalue.QValueInt64{Val: *v})
+			case **int16:
+				if *v == nil {
+					qrow = append(qrow, qvalue.QValueNull(qvalue.QValueKindInt16))
+				} else {
+					qrow = append(qrow, qvalue.QValueInt16{Val: **v})
+				}
+			case *int16:
+				qrow = append(qrow, qvalue.QValueInt16{Val: *v})
 			default:
 				return nil, fmt.Errorf("cannot convert %T to qvalue", v)
 			}