diff --git a/pkg/clickhouse/clickhouse.go b/pkg/clickhouse/clickhouse.go index bcce072d..9809e1b6 100644 --- a/pkg/clickhouse/clickhouse.go +++ b/pkg/clickhouse/clickhouse.go @@ -909,10 +909,12 @@ func (ch *ClickHouse) SelectSingleRowNoCtx(dest interface{}, query string, args func (ch *ClickHouse) LogQuery(query string, args ...interface{}) string { var logF *zerolog.Event + // zerolog is not thread-safe https://github.com/rs/zerolog/issues/242 ;( + logger := ch.Logger.With().Logger() if !ch.Config.LogSQLQueries { - logF = ch.Logger.Debug() + logF = logger.Debug() } else { - logF = ch.Logger.Info() + logF = logger.Info() } if len(args) > 0 { logF.Msg(strings.NewReplacer("\n", " ", "\r", " ", "\t", " ").Replace(fmt.Sprintf("%s with args %v", query, args)))