Method Run

exec/mutations.go:254–281

()

}

func (m *DeletionScanner) Run() error {
	defer m.Ctx.Recover()
	defer close(m.msgOutCh)

	select {
	case <-m.SigChan():
		return nil
	default:
		if m.sql.Where != nil {

			vals := make([]driver.Value, 2)
			deletedCt, err := m.db.DeleteExpression(m.p, m.sql.Where.Expr)
			if err != nil {
				u.Errorf("Could not delete values: %v", err)

				vals[0] = err.Error()
				vals[1] = int64(0)
				m.msgOutCh <- &datasource.SqlDriverMessage{Vals: vals, IdVal: 1}
				return err
			}
			m.deleted = deletedCt
			vals[0] = int64(0)
			vals[1] = int64(deletedCt)
			m.msgOutCh <- &datasource.SqlDriverMessage{Vals: vals, IdVal: 1}
		}
	}
	return nil
}