根据文档id删除
(docId, limit int)
| 191 | |
| 192 | // 根据文档id删除 |
| 193 | func (history *DocumentHistory) DeleteByLimit(docId, limit int) (err error) { |
| 194 | if limit <= 0 { |
| 195 | return |
| 196 | } |
| 197 | |
| 198 | filter := orm.NewOrm().QueryTable(history.TableNameWithPrefix()).Filter("document_id", docId) |
| 199 | |
| 200 | var cnt int64 |
| 201 | cnt, err = filter.Count() |
| 202 | if err != nil { |
| 203 | return |
| 204 | } |
| 205 | |
| 206 | l := int64(limit) |
| 207 | |
| 208 | if cnt > l { |
| 209 | |
| 210 | var histories []DocumentHistory |
| 211 | var historyIds []interface{} |
| 212 | |
| 213 | filter2 := filter.OrderBy("history_id").Limit(cnt - l) |
| 214 | filter2.All(&histories, "document_id", "version", "history_id") |
| 215 | |
| 216 | for _, item := range histories { |
| 217 | ver := NewVersionControl(item.DocumentId, item.Version) |
| 218 | ver.DeleteVersion() |
| 219 | historyIds = append(historyIds, item.HistoryId) |
| 220 | } |
| 221 | filter.Filter("history_id__in", historyIds).Delete() |
| 222 | } |
| 223 | return |
| 224 | } |
no test coverage detected