Skip to content

Commit e777a3b

Browse files
committed
Merge branch 'rd_decimal' of github.com:questdb/go-questdb-client into rd_decimal
2 parents 4746449 + 8e4947f commit e777a3b

File tree

1 file changed

+31
-0
lines changed

1 file changed

+31
-0
lines changed

http_sender_test.go

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ import (
2828
"context"
2929
"errors"
3030
"fmt"
31+
"math/big"
3132
"net/http"
3233
"os"
3334
"testing"
@@ -1016,3 +1017,33 @@ func BenchmarkHttpLineSenderNoFlush(b *testing.B) {
10161017
sender.Flush(ctx)
10171018
sender.Close(ctx)
10181019
}
1020+
1021+
func BenchmarkHttpLineSenderDecimal(b *testing.B) {
1022+
const decimalStr = "123456.789"
1023+
1024+
ctx := context.Background()
1025+
1026+
srv, err := newTestHttpServer(readAndDiscard)
1027+
assert.NoError(b, err)
1028+
defer srv.Close()
1029+
1030+
sender, err := qdb.NewLineSender(ctx, qdb.WithHttp(), qdb.WithAddress(srv.Addr()))
1031+
assert.NoError(b, err)
1032+
1033+
b.ResetTimer()
1034+
for i := 0; i < b.N; i++ {
1035+
bi := big.NewInt(int64(i))
1036+
for j := 0; j < 1000; j++ {
1037+
d1 := qdb.NewDecimalFromInt64(int64(j), 3)
1038+
d2, _ := qdb.NewDecimal(bi, 3)
1039+
sender.
1040+
Table(testTable).
1041+
DecimalColumnScaled("dec_col", d1).
1042+
DecimalColumnScaled("dec_col2", d2).
1043+
DecimalColumnString("dec_col3", decimalStr).
1044+
At(ctx, time.UnixMicro(int64(1000*i)))
1045+
}
1046+
sender.Flush(ctx)
1047+
sender.Close(ctx)
1048+
}
1049+
}

0 commit comments

Comments
 (0)