diff options
Diffstat (limited to 'vendor/github.com/uptrace/bun/query_delete.go')
| -rw-r--r-- | vendor/github.com/uptrace/bun/query_delete.go | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/vendor/github.com/uptrace/bun/query_delete.go b/vendor/github.com/uptrace/bun/query_delete.go index 99ec37bb7..bbeb2b4b4 100644 --- a/vendor/github.com/uptrace/bun/query_delete.go +++ b/vendor/github.com/uptrace/bun/query_delete.go @@ -127,7 +127,7 @@ func (q *DeleteQuery) WhereAllWithDeleted() *DeleteQuery { func (q *DeleteQuery) Order(orders ...string) *DeleteQuery { if !q.hasFeature(feature.DeleteOrderLimit) { - q.err = feature.NewNotSupportError(feature.DeleteOrderLimit) + q.setErr(feature.NewNotSupportError(feature.DeleteOrderLimit)) return q } q.addOrder(orders...) @@ -136,7 +136,7 @@ func (q *DeleteQuery) Order(orders ...string) *DeleteQuery { func (q *DeleteQuery) OrderExpr(query string, args ...interface{}) *DeleteQuery { if !q.hasFeature(feature.DeleteOrderLimit) { - q.err = feature.NewNotSupportError(feature.DeleteOrderLimit) + q.setErr(feature.NewNotSupportError(feature.DeleteOrderLimit)) return q } q.addOrderExpr(query, args...) @@ -151,7 +151,7 @@ func (q *DeleteQuery) ForceDelete() *DeleteQuery { // ------------------------------------------------------------------------------ func (q *DeleteQuery) Limit(n int) *DeleteQuery { if !q.hasFeature(feature.DeleteOrderLimit) { - q.err = feature.NewNotSupportError(feature.DeleteOrderLimit) + q.setErr(feature.NewNotSupportError(feature.DeleteOrderLimit)) return q } q.setLimit(n) @@ -165,7 +165,7 @@ func (q *DeleteQuery) Limit(n int) *DeleteQuery { // To suppress the auto-generated RETURNING clause, use `Returning("NULL")`. func (q *DeleteQuery) Returning(query string, args ...interface{}) *DeleteQuery { if !q.hasFeature(feature.DeleteReturning) { - q.err = feature.NewNotSupportError(feature.DeleteOrderLimit) + q.setErr(feature.NewNotSupportError(feature.DeleteOrderLimit)) return q } @@ -321,6 +321,9 @@ func (q *DeleteQuery) scanOrExec( return nil, err } + // if a comment is propagated via the context, use it + setCommentFromContext(ctx, q) + // Generate the query before checking hasReturning. queryBytes, err := q.AppendQuery(q.db.fmter, q.db.makeQueryBytes()) if err != nil { |