Function NewInsert

exec/mutations.go:51–58

An insert to write to data source

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

// An insert to write to data source
func NewInsert(ctx *plan.Context, p *plan.Insert) *Upsert {
	m := &Upsert{
		TaskBase: NewTaskBase(ctx),
		db:       p.Source,
		insert:   p.Stmt,
	}
	return m
}
func NewUpdate(ctx *plan.Context, p *plan.Update) *Upsert {
	m := &Upsert{
		TaskBase: NewTaskBase(ctx),