Method processInput

tools/shell/embedded_shell.cpp:542–603

}

std::vector<std::unique_ptr<QueryResult>> EmbeddedShell::processInput(std::string input) {
    std::stringstream ss;
    std::vector<std::unique_ptr<QueryResult>> queryResults;
    historyLine = "";
    // Append rest of multiline query to current input line
    if (continueLine) {
        input = std::move(currLine) + std::move(input);
        currLine = "";
        continueLine = false;
    }
    input = input.erase(input.find_last_not_of(" \t\n\r\f\v") + 1);
    // Decode escape sequences
    std::string unicodeInput;
    try {
        unicodeInput = decodeEscapeSequences(input);
    } catch (std::exception& e) {
        printf("Error: %s\n", e.what());
        historyLine = input;
        return queryResults;
    }
    // Normalize trailing semicolons
    if (!unicodeInput.empty() && unicodeInput.back() == ';') {
        // trim trailing ;
        while (!unicodeInput.empty() && unicodeInput.back() == ';') {
            unicodeInput.pop_back();
        }
        if (unicodeInput.empty()) {
            return queryResults;
        }
        unicodeInput += ';';
    }
    // process shell commands
    if (!continueLine && unicodeInput[0] == ':') {
        processShellCommands(unicodeInput);
        // process queries
    } else if (!unicodeInput.empty() && cypherComplete((char*)unicodeInput.c_str())) {
        ss.clear();
        ss.str(unicodeInput);
        auto result = conn->query(unicodeInput);
        auto curr = result.get();
        checkConfidentialStatement(unicodeInput, curr, input);
        while (true) {
            queryResults.push_back(std::move(result));
            if (!curr->hasNextQueryResult()) {
                break;
            }
            result = curr->moveNextResult();
            curr = result.get();
            checkConfidentialStatement(unicodeInput, curr, input);
        }
        // set up multiline query if current query doesn't end with a semicolon
    } else if (!input.empty() && input[0] != ':') {
        continueLine = true;
        currLine += input + "\n";
    }
    if (catalogVersion != database->catalog->getVersion()) {
        updateTableNames();
        catalogVersion = database->catalog->getVersion();