|
|
@ -554,7 +554,7 @@ func (h DefaultCURDHandler) delete(ctx RequestContext, urlParams Parameters, que |
|
|
|
for _, k := range h.pks { |
|
|
|
pks = append(pks, k) |
|
|
|
} |
|
|
|
qs := session.Table(h.table, pks...).Filter(queryControl.Filters...) |
|
|
|
qs := session.Table(h.table).Filter(queryControl.Filters...) |
|
|
|
if rows, err := qs.All(); nil != err { |
|
|
|
log.Errorln("DefaultCURDHandler.read:> failure:", err) |
|
|
|
return FailureResult(FatalDbReadFailed, fmt.Sprintf("%s", err)) |
|
|
@ -570,7 +570,8 @@ func (h DefaultCURDHandler) delete(ctx RequestContext, urlParams Parameters, que |
|
|
|
objects = reflect.Append(objects, obj) |
|
|
|
} |
|
|
|
} |
|
|
|
n, err := session.Table(h.table).Filter(queryControl.Filters...).Delete() |
|
|
|
//session.Table(h.table).Filter(queryControl.Filters...)
|
|
|
|
n, err := qs.Delete() |
|
|
|
if nil != err { |
|
|
|
return FailureResult(FatalDbWriteFailed, fmt.Sprint(err)) |
|
|
|
} |
|
|
@ -580,7 +581,7 @@ func (h DefaultCURDHandler) delete(ctx RequestContext, urlParams Parameters, que |
|
|
|
} |
|
|
|
} |
|
|
|
if e := session.Commit(); nil != e { |
|
|
|
session.Rollback() |
|
|
|
_ = session.Rollback() |
|
|
|
log.Errorln("DefaultCURDHandler.delete:> session commit failed:", e) |
|
|
|
return FailureResult(FatalDbWriteFailed, e.Error()) |
|
|
|
} |
|
|
|