Msgs string
}
- var replaceF []func(index int, holder string) (replaceTo string)
- if c.DBDriverName == "postgres" {
- replaceF = append(replaceF, func(index int, holder string) (replaceTo string) {
- return fmt.Sprintf("$%d", index+1)
- })
- }
-
o.MQ.Pull_tag_only(`L`, func(msg Msg_item) bool {
var showObj = []io.Writer{}
if msg.Stdout {
sqlTx = psql.BeginTx[any](msg.DBConn, pctx.GenTOCtx(o.DBConnTo))
}
+ var replaceF []func(index int, holder string) (replaceTo string)
+ if c.DBDriverName == "postgres" {
+ replaceF = append(replaceF, func(index int, holder string) (replaceTo string) {
+ return fmt.Sprintf("$%d", index+1)
+ })
+ }
+
sqlTx.DoPlaceHolder(psql.SqlFunc[any]{Sql: msg.DBInsert}, &LogI{
Date: time.Now().Format(time.DateTime),
Unix: time.Now().Unix(),