Function runConsole

cmd/cql/internal/console.go:320–441

runConsole runs a console for sql operation in command line.

(cmd *Command, args []string)

// runConsole runs a console for sql operation in command line.
func runConsole(cmd *Command, args []string) {
	configFile = utils.HomeDirExpand(configFile)

	commonFlagsInit(cmd)

	var err error
	// load config
	if conf.GConf, err = conf.LoadConfig(configFile); err != nil {
		ConsoleLog.WithError(err).Error("load config file failed")
		SetExitStatus(1)
		ExitIfErrors()
	}

	if len(args) == 1 {
		dsn = args[0]
	}

	if dsn == "" {
		dsnArray := loadDSN()
		if len(dsnArray) > 0 {
			//Print dsn list
			fmt.Printf("Found local stored dsn list: \n")
			for i := 0; i < len(dsnArray); i++ {
				fmt.Printf("%v: %v\n", i, dsnArray[i])
			}
			fmt.Println("Which would you like to connect? (press Enter for default 0):")

			//Read from terminal
			reader := bufio.NewReader(os.Stdin)
			t, err := reader.ReadString('\n')
			t = strings.Trim(t, "\n")
			if err != nil {
				ConsoleLog.WithError(err).Error("unexpected error")
				SetExitStatus(1)
				Exit()
			}

			var choice int
			if t == "" {
				choice = 0
			} else {
				choice, err = strconv.Atoi(t)
				if err != nil || choice >= len(dsnArray) || choice < 0 {
					ConsoleLog.Error("invalid choice number")
					SetExitStatus(1)
					Exit()
				}
			}

			//Set dsn
			dsn = dsnArray[choice]
		} else {
			ConsoleLog.Error("neither local dsn storage exists nor a dsn string present")
			SetExitStatus(1)
			printCommandHelp(cmd)
			Exit()
		}
	}