Skip to content

Commit 7db85af

Browse files
committed
fix: batch update categories list
1 parent cc54b64 commit 7db85af

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

service/impl/category.go

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -427,10 +427,16 @@ func (c *categoryUpdateExecutor) UpdateBatch(ctx context.Context, categoryParams
427427

428428
err := dal.Transaction(ctx, func(txCtx context.Context) error {
429429
categoryDAL := dal.GetQueryByCtx(txCtx).Category
430-
err := categoryDAL.WithContext(txCtx).Omit(categoryDAL.CreateTime).Save(categories...)
431-
if err != nil {
432-
return WrapDBErr(err)
430+
for _, category := range categories {
431+
resultInfo, err := categoryDAL.WithContext(txCtx).Where(categoryDAL.ID.Eq(category.ID)).Select(field.Star).Omit(categoryDAL.CreateTime).Updates(category)
432+
if err != nil {
433+
return WrapDBErr(err)
434+
}
435+
if resultInfo.RowsAffected != 1 {
436+
return xerr.DB.New("").WithMsg("update failed")
437+
}
433438
}
439+
434440
if err := c.prepare(txCtx, categoryParams); err != nil {
435441
return err
436442
}

0 commit comments

Comments
 (0)