diff --git a/db/executor.go b/db/executor.go index 4ba10f26..69759e24 100644 --- a/db/executor.go +++ b/db/executor.go @@ -125,6 +125,16 @@ func (e *executor) conduct(ctx context.Context, stm sql.Statement) { var rsp *Response var res []interface{} + if log.IsDebug() { + log.WithPrefix(logKeySql).WithFields(map[string]interface{}{ + logKeyId: e.id, + logKeyNS: e.ns, + logKeyDB: e.db, + logKeyKind: ctx.Value(ctxKeyKind), + logKeyVars: ctx.Value(ctxKeyVars), + }).Debugln("Running", stm) + } + // If we are not inside a global transaction // then reset the error to nil so that the // next statement is not ignored.