diff --git a/ksql.go b/ksql.go index 74494ce..45b6a10 100644 --- a/ksql.go +++ b/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