Method NewDeleteQuery

compiler/compiler.go:45–68

(rctx *runtime.Context, ast *parser.AST, head *dbid.Commitish)

}

func (l *compiler) NewDeleteQuery(rctx *runtime.Context, ast *parser.AST, head *dbid.Commitish) (runtime.DeleteQuery, error) {
	if err := ast.ConvertToDeleteWhere(head.Pool, head.Branch); err != nil {
		return nil, err
	}
	seq := ast.Parsed()
	if len(seq) != 2 {
		return nil, &InvalidDeleteWhereQuery{}
	}
	main, err := Analyze(rctx, ast, l.env, false)
	if err != nil {
		return nil, err
	}
	if _, ok := main.Body[1].(*dag.FilterOp); !ok {
		return nil, &InvalidDeleteWhereQuery{}
	}
	if err = optimizer.New(rctx, l.env).OptimizeDeleter(main, Parallelism); err != nil {
		return nil, err
	}
	outputs, debugs, b, err := BuildWithBuilder(rctx, main, l.env, nil)
	if err != nil {
		return nil, err
	}
	return exec.NewDeleteQuery(rctx, bundleOutputs(rctx, outputs, debugs), b.Deletes()), nil
}

type InvalidDeleteWhereQuery struct{}