mirror of https://github.com/VinGarcia/ksql.git
Minor change on where we are calling ctxLog on some funcs
parent
e6b5eced70
commit
c37835ef44
6
ksql.go
6
ksql.go
|
@ -451,11 +451,12 @@ func (c DB) Insert(
|
|||
}
|
||||
|
||||
query, params, scanValues, err := buildInsertQuery(ctx, c.dialect, table, t, v, info, record)
|
||||
defer ctxLog(ctx, query, params, &err)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
defer ctxLog(ctx, query, params, &err)
|
||||
|
||||
switch table.insertMethodFor(c.dialect) {
|
||||
case sqldialect.InsertWithReturning, sqldialect.InsertWithOutput:
|
||||
err = c.insertReturningIDs(ctx, query, params, scanValues, table.idColumns)
|
||||
|
@ -683,11 +684,12 @@ func (c DB) Patch(
|
|||
}
|
||||
|
||||
query, params, err := buildUpdateQuery(ctx, c.dialect, table.name, info, recordMap, table.idColumns...)
|
||||
defer ctxLog(ctx, query, params, &err)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
defer ctxLog(ctx, query, params, &err)
|
||||
|
||||
result, err := c.db.ExecContext(ctx, query, params...)
|
||||
if err != nil {
|
||||
return err
|
||||
|
|
Loading…
Reference in New Issue