mirror of
https://github.com/hanzo-ds/go.git
synced 2026-10-30 19:45:01 +00:00
zeekay
22b3f5ce2b
Feature-complete v2.44.0 (lib/churl, lib/col, BFloat16, QBit, scanTypeDuration, Options.Logger *slog.Logger) — fixes the [email protected].0 downgrade RED caught. Package datastore, module github.com/hanzo-ds/go, depends only on hanzo-ds/native. Wire strings preserved VERBATIM (X-ClickHouse-* headers, sql.Register("clickhouse"), clickhouse:// DSN, ClientName="clickhouse-go") — consistent with native.
31 lines
627 B
Go
31 lines
627 B
Go
package datastore
|
|
|
|
import (
|
|
"context"
|
|
)
|
|
|
|
func (h *httpConnect) asyncInsert(ctx context.Context, query string, wait bool, args ...any) error {
|
|
|
|
options := queryOptions(ctx)
|
|
options.settings["async_insert"] = 1
|
|
options.settings["wait_for_async_insert"] = 0
|
|
if wait {
|
|
options.settings["wait_for_async_insert"] = 1
|
|
}
|
|
if len(args) > 0 {
|
|
var err error
|
|
query, err = bindQueryOrAppendParameters(true, &options, query, h.handshake.Timezone, args...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
res, err := h.sendQuery(ctx, query, &options, nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer discardAndClose(res.Body)
|
|
|
|
return nil
|
|
}
|