-
Notifications
You must be signed in to change notification settings - Fork 66
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Rudimentary REPL implementation to allow you to run BQL statements.
- Loading branch information
Showing
6 changed files
with
174 additions
and
16 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,161 @@ | ||
| // Copyright 2016 Google Inc. All rights reserved. | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| // Package repl contains the implementation of the command that prints the | ||
| // BQL version. | ||
| package repl | ||
|
|
||
| import ( | ||
| "bufio" | ||
| "fmt" | ||
| "os" | ||
| "strings" | ||
| "time" | ||
|
|
||
| "golang.org/x/net/context" | ||
|
|
||
| "github.com/google/badwolf/bql/grammar" | ||
| "github.com/google/badwolf/bql/planner" | ||
| "github.com/google/badwolf/bql/semantic" | ||
| "github.com/google/badwolf/bql/table" | ||
| "github.com/google/badwolf/bql/version" | ||
| "github.com/google/badwolf/storage" | ||
| "github.com/google/badwolf/tools/vcli/bw/command" | ||
| "github.com/google/badwolf/tools/vcli/bw/io" | ||
| ) | ||
|
|
||
| const prompt = "bql> " | ||
|
|
||
| // New create the version command. | ||
| func New(driver storage.Store, chanSize int) *command.Command { | ||
| return &command.Command{ | ||
| Run: func(ctx context.Context, args []string) int { | ||
| REPL(driver, os.Stdin, simpleReadLine, chanSize) | ||
| return 0 | ||
| }, | ||
| UsageLine: "bql", | ||
| Short: "starts a REPL to run BQL statements.", | ||
| Long: "Starts a REPL from the command line to accept BQL statements. Type quit; to leave the REPL.", | ||
| } | ||
| } | ||
|
|
||
| type readLiner func(*os.File) <-chan string | ||
|
|
||
| // simpleReadline reads a line from the provided file. This does not support | ||
| // any advanced terminal functionalities. | ||
| // | ||
| // TODO(xllora): Replace simple reader for function that supports advanced | ||
| // teminal input. | ||
| func simpleReadLine(f *os.File) <-chan string { | ||
| c := make(chan string) | ||
| go func() { | ||
| defer close(c) | ||
| scanner := bufio.NewScanner(os.Stdin) | ||
| for scanner.Scan() { | ||
| c <- strings.TrimSpace(scanner.Text()) | ||
| } | ||
| }() | ||
| return c | ||
| } | ||
|
|
||
| // REPL starts a read-evaluation-print-loop to run BQL commands. | ||
| func REPL(driver storage.Store, input *os.File, rl readLiner, chanSize int) int { | ||
| ctx := context.Background() | ||
| fmt.Printf("Welcome to BadWolf vCli (%d.%d.%d-%s)\n", version.Major, version.Minor, version.Patch, version.Release) | ||
| fmt.Printf("Using driver %q. Type quit; to exit\n", driver.Name(ctx)) | ||
| fmt.Printf("Session started at %v\n\n", time.Now()) | ||
| defer func() { | ||
| fmt.Printf("\nThanks for all those BQL queries!\n\n") | ||
| }() | ||
| fmt.Print(prompt) | ||
| for l := range rl(input) { | ||
| if strings.HasPrefix(l, "quit") { | ||
| break | ||
| } | ||
| if strings.HasPrefix(l, "help") { | ||
| printHelp() | ||
| fmt.Print(prompt) | ||
| continue | ||
| } | ||
| if strings.HasPrefix(l, "run") { | ||
| path, cmds, err := loadData(ctx, driver, chanSize, l) | ||
| if err != nil { | ||
| fmt.Printf("[ERROR] %s\n\n", err) | ||
| } else { | ||
| fmt.Printf("Loaded %q and run %d BQL commands successfully\n\n", path, cmds) | ||
| } | ||
| fmt.Print(prompt) | ||
| continue | ||
| } | ||
| table, err := runBQL(ctx, l, driver, chanSize) | ||
| if err != nil { | ||
| fmt.Printf("[ERROR] %s\n\n", err) | ||
| } else { | ||
| fmt.Println(table.String()) | ||
| } | ||
| fmt.Print(prompt) | ||
| } | ||
| return 0 | ||
| } | ||
|
|
||
| // printHelp prints help for the console commands. | ||
| func printHelp() { | ||
| fmt.Println("help - prints help for the bw console.") | ||
| fmt.Println("run <file_with_bql_statements> - quits the console.") | ||
| fmt.Println("quit - quits the console.") | ||
| fmt.Println() | ||
| } | ||
|
|
||
| // loadData loads all the triples in the file into the current driver. | ||
| func loadData(ctx context.Context, driver storage.Store, chanSize int, line string) (string, int, error) { | ||
| ss := strings.Split(strings.TrimSpace(line), " ") | ||
| if len(ss) != 2 { | ||
| return "", 0, fmt.Errorf("wrong syntax: run <file_with_bql_statements>") | ||
| } | ||
| path := ss[1] | ||
| lines, err := io.GetStatementsFromFile(path) | ||
| if err != nil { | ||
| return "", 0, fmt.Errorf("failed to read file %q with error %v on\n", path, err) | ||
| } | ||
| for idx, stm := range lines { | ||
| fmt.Printf("Processing statement (%d/%d)\n", idx+1, len(lines)) | ||
| _, err := runBQL(ctx, stm, driver, chanSize) | ||
| if err != nil { | ||
| return "", 0, fmt.Errorf("%v on\n%s\n", err, stm) | ||
| } | ||
| } | ||
| fmt.Println() | ||
| return path, len(lines), nil | ||
| } | ||
|
|
||
| // runBQL attemps to excecute the provided query against the given store. | ||
| func runBQL(ctx context.Context, bql string, s storage.Store, chanSize int) (*table.Table, error) { | ||
| p, err := grammar.NewParser(grammar.SemanticBQL()) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to initilize a valid BQL parser") | ||
| } | ||
| stm := &semantic.Statement{} | ||
| if err := p.Parse(grammar.NewLLk(bql, 1), stm); err != nil { | ||
| return nil, fmt.Errorf("failed to parse BQL statement with error %v", err) | ||
| } | ||
| pln, err := planner.New(ctx, s, stm, chanSize) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("should have not failed to create a plan using memory.DefaultStorage for statement %v with error %v", stm, err) | ||
| } | ||
| res, err := pln.Excecute(ctx) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("planner.Execute: failed to execute insert plan with error %v", err) | ||
| } | ||
| return res, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters