()
| 230 | } |
| 231 | |
| 232 | func (m *DeletionTask) Run() error { |
| 233 | defer m.Ctx.Recover() |
| 234 | defer close(m.msgOutCh) |
| 235 | |
| 236 | vals := make([]driver.Value, 2) |
| 237 | deletedCt, err := m.db.DeleteExpression(m.p, m.sql.Where.Expr) |
| 238 | if err != nil { |
| 239 | u.Errorf("Could not delete values: %v", err) |
| 240 | vals[0] = err.Error() |
| 241 | vals[1] = int64(0) |
| 242 | m.msgOutCh <- &datasource.SqlDriverMessage{Vals: vals, IdVal: 1} |
| 243 | return err |
| 244 | } |
| 245 | m.deleted = deletedCt |
| 246 | |
| 247 | vals[0] = int64(0) |
| 248 | vals[1] = int64(deletedCt) |
| 249 | m.msgOutCh <- &datasource.SqlDriverMessage{Vals: vals, IdVal: 1} |
| 250 | |
| 251 | return nil |
| 252 | } |
| 253 | |
| 254 | func (m *DeletionScanner) Run() error { |
| 255 | defer m.Ctx.Recover() |
nothing calls this directly
no test coverage detected