From 1aa5e013e9bafd4f1d37bce937cd2443fb5894ae Mon Sep 17 00:00:00 2001 From: qydysky Date: Mon, 22 Apr 2024 18:17:45 +0000 Subject: [PATCH] 1 --- log/Log.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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), -- 2.39.2