From: qydysky Date: Mon, 22 Apr 2024 18:17:45 +0000 (+0000) Subject: 1 X-Git-Tag: v0.28.20240422182232 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=1aa5e013e9bafd4f1d37bce937cd2443fb5894ae;p=part%2F.git 1 --- diff --git a/log/Log.go b/log/Log.go index 3ee5437..488a3d6 100644 --- a/log/Log.go +++ b/log/Log.go @@ -1,6 +1,7 @@ package part import ( + "context" "database/sql" "fmt" "io" @@ -73,7 +74,12 @@ func New(c Config) (o *Log_interface) { } } if msg.DBConn != nil && msg.DBInsert != `` { - sqlTx := psql.BeginTx[any](msg.DBConn, pctx.GenTOCtx(o.To)) + var sqlTx *psql.SqlTx[any] + if o.To == 0 { + sqlTx = psql.BeginTx[any](msg.DBConn, context.Background()) + } else { + sqlTx = psql.BeginTx[any](msg.DBConn, pctx.GenTOCtx(o.To)) + } sqlTx.SimpleDo( msg.DBInsert, strings.TrimSpace(msg.Prefix),