Method ParseJSONArray

src/storage/json_reader.cpp:387–441

}

void JSONReader::ParseJSONArray() {
    std::ifstream file(path_);
    if (!file.is_open()) throw IOException(ErrorCode::FILE_NOT_FOUND, "Cannot open: " + path_);

    std::string content((std::istreambuf_iterator<char>(file)),
                         std::istreambuf_iterator<char>());

    size_t pos = 0;
    JSONParser::SkipWhitespace(content, pos);

    if (pos >= content.size() || content[pos] != '[') {
        // Try as NDJSON.
        options_.array_format = false;
        file.close();
        ParseNDJSON();
        return;
    }

    pos++; // skip [
    JSONParser::SkipWhitespace(content, pos);

    while (pos < content.size() && content[pos] != ']') {
        if (content[pos] != '{') break;

        // Parse object.
        std::unordered_map<std::string, Value> record;
        pos++; // skip {
        JSONParser::SkipWhitespace(content, pos);

        while (pos < content.size() && content[pos] != '}') {
            if (content[pos] != '"') break;
            auto key_val = JSONParser::ParseString(content, pos);
            auto key = key_val.GetValue<std::string>();

            JSONParser::SkipWhitespace(content, pos);
            if (pos < content.size() && content[pos] == ':') pos++;
            JSONParser::SkipWhitespace(content, pos);

            auto val = JSONParser::Parse(content, pos);
            record[key] = val;

            JSONParser::SkipWhitespace(content, pos);
            if (pos < content.size() && content[pos] == ',') pos++;
            JSONParser::SkipWhitespace(content, pos);
        }

        if (pos < content.size() && content[pos] == '}') pos++;
        records_.push_back(std::move(record));

        JSONParser::SkipWhitespace(content, pos);
        if (pos < content.size() && content[pos] == ',') pos++;
        JSONParser::SkipWhitespace(content, pos);
    }
    parsed_ = true;
}

void JSONReader::DetectSchema() {
    if (!parsed_) {