Function NewDelete

exec/mutations.go:77–85

An inserter to write to data source

(ctx *plan.Context, p *plan.Delete)

// An inserter to write to data source
func NewDelete(ctx *plan.Context, p *plan.Delete) *DeletionTask {
	m := &DeletionTask{
		TaskBase: NewTaskBase(ctx),
		db:       p.Source,
		sql:      p.Stmt,
		p:        p,
	}
	return m
}

func (m *Upsert) Close() error {
	if m.closed {