package part
import (
+ "context"
"database/sql"
"fmt"
"io"
}
}
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),