Skip to content

Commit

Permalink
another type to add
Browse files Browse the repository at this point in the history
  • Loading branch information
heavycrystal committed Dec 11, 2024
1 parent f34ce72 commit de7c766
Showing 1 changed file with 8 additions and 0 deletions.
8 changes: 8 additions & 0 deletions flow/e2e/clickhouse/clickhouse.go
Original file line number Diff line number Diff line change
Expand Up @@ -190,6 +190,14 @@ func (s ClickHouseSuite) GetRows(table string, cols string) (*model.QRecordBatch
}
case *float64:
qrow = append(qrow, qvalue.QValueFloat64{Val: *v})
case **int64:
if *v == nil {
qrow = append(qrow, qvalue.QValueNull(qvalue.QValueKindInt64))
} else {
qrow = append(qrow, qvalue.QValueInt64{Val: **v})
}
case *int64:
qrow = append(qrow, qvalue.QValueInt64{Val: *v})
default:
return nil, fmt.Errorf("cannot convert %T to qvalue", v)
}
Expand Down

0 comments on commit de7c766

Please sign in to comment.