Function interactive

cmd/sqlread/main.go:80–149

(tree sqlread.SummaryTree, buff io.ReaderAt)

}

func interactive(tree sqlread.SummaryTree, buff io.ReaderAt) {
	w := csv.NewWriter(os.Stdout)
	sw := NewReadlineWrap()

	intp := sqlread.Intp{}
	for {
		stdinlex, stdli := sqlread.Lex(sw)
		go func() {
			stdinlex.Run(intp.StartIntpState)
		}()

		qp := sqlread.NewQueryParser()

		p := sqlread.Parse(stdli)
		err := p.Run(qp.ParseStart)
		if err != nil {
			log.Println("query error: ", err)
			sw.Flush()
			continue
		}

		for _, qry := range qp.Tree.Queries {
			w2 := w
			path := ""

			if qry.Outfile != nil && *qry.Outfile != "" {
				path = filepath.Clean(*qry.Outfile)
				outfile, err := os.OpenFile(path, os.O_CREATE|os.O_WRONLY, 0644)
				if err != nil {
					log.Println(err)
					continue
				}

				w2 = csv.NewWriter(outfile)
			}
			if err := execQuery(tree, qry, buff, w2); err != nil {
				log.Println(err)
			} else if path != "" {
				log.Printf("written to `%s`", path)
			}
		}

		for i := uint(0); i < qp.Tree.ShowTables; i++ {
			showTables(tree, w)
		}

		for _, sctbl := range qp.Tree.ShowColumns {
			if err := showColumns(tree, sctbl, w); err != nil {
				log.Println(err)
			}
		}

		for _, sctbl := range qp.Tree.ShowCreateTables {
			if err := showCreateTable(tree, sctbl, buff, w); err != nil {
				log.Println(err)
			}
		}