Method Run

cmd/super/root/command.go:66–115

(args []string)

}

func (c *Command) Run(args []string) error {
	if c.canon && len(c.queryFlags.Query) == 0 {
		return errors.New("query text must be specified (-c or -I) when using -C")
	}
	ctx, cleanup, err := c.Init(&c.inputFlags, &c.outputFlags, &c.runtimeFlags)
	if err != nil {
		return err
	}
	defer cleanup()
	if len(args) == 0 && len(c.queryFlags.Query) == 0 {
		return charm.NeedHelp
	}
	ast, err := parser.ParseFiles(c.queryFlags.Query)
	if err != nil {
		return err
	}
	if c.canon {
		fmt.Println(sfmt.AST(ast.Parsed()))
		return nil
	}
	if len(args) > 0 {
		ast.PrependFileScan(args)
	}
	env := exec.NewEnvironment(storage.NewLocalEngine(), nil)
	env.Dynamic = c.inputFlags.Dynamic
	env.IgnoreOpenErrors = !c.stopErr
	env.ReaderOpts = c.inputFlags.ReaderOpts
	env.Runtime = c.runtimeFlags.Runtime
	env.SampleSize = c.inputFlags.SampleSize
	comp := compiler.NewCompilerWithEnv(env)
	query, err := runtime.CompileQuery(ctx, super.NewContext(), comp, ast, nil)
	if err != nil {
		return err
	}
	defer query.Pull(true)
	writer, err := c.outputFlags.Open(ctx, env.Engine())
	if err != nil {
		return err
	}
	out := map[string]vio.Pusher{
		"main":  writer,
		"debug": supio.NewWriter(sio.NopCloser(os.Stderr), supio.WriterOpts{}),
	}
	err = vio.CopyMux(out, query)
	if closeErr := writer.Close(); err == nil {
		err = closeErr
	}
	c.queryFlags.PrintStats(query.Progress())
	return err
}