go/go-clickhouse
1
0
Fork 0
mirror of https://github.com/uptrace/go-clickhouse.git synced 2025-06-14 23:44:59 +02:00
Code Issues Releases Activity

chore: enable test

Browse Source
This commit is contained in:
Vladimir Mihailenco
2022-04-30 15:02:07 +03:00
parent aca5cfeb91
commit 94da9c644c
2 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ch/db_test.go
View File

@ -48,8 +48,6 @@ func TestCHError(t *testing.T) {
} }
func TestCHTimeout(t *testing.T) { func TestCHTimeout(t *testing.T) {
t.Skip()
ctx := context.Background() ctx := context.Background()
db := chDB(ch.WithTimeout(time.Second), ch.WithMaxRetries(0)) db := chDB(ch.WithTimeout(time.Second), ch.WithMaxRetries(0))

17
ch/query_insert.go
View File

@ -191,13 +191,20 @@ func (q *InsertQuery) Exec(ctx context.Context) (sql.Result, error) {
} }
query := internal.String(queryBytes) query := internal.String(queryBytes)
fields, err := q.getFields() ctx, evt := q.db.beforeQuery(ctx, q, query, nil, q.tableModel)
if err != nil { var res *result
return nil, err
if q.tableModel != nil {
fields, err := q.getFields()
if err != nil {
return nil, err
}
res, err = q.db.insert(ctx, q.tableModel, query, fields)
} else {
res, err = q.db.exec(ctx, query)
} }
ctx, evt := q.db.beforeQuery(ctx, q, query, nil, q.tableModel)
res, err := q.db.insert(ctx, q.tableModel, query, fields)
q.db.afterQuery(ctx, evt, res, err) q.db.afterQuery(ctx, evt, res, err)
return res, err return res, err
} }