Function addUpdateValue

cpp_src/core/query/sql/sqlparser.cc:482–541

}

static void addUpdateValue(const Token& tok, Tokenizer& parser, UpdateEntry& updateField) {
	if (tok.Type() == TokenString) {
		updateField.Values().push_back(Token2kv(tok, parser, CompositeAllowed_False, FieldAllowed_False, NullAllowed_True));
	} else {
		if (tok.Text() == "null"sv) {
			updateField.Values().push_back(Variant());
		} else if (tok.Text() == "{"sv) {
			try {
				const size_t jsonPos = parser.GetPrevPos();
				std::string json(parser.Begin() + jsonPos, parser.Length() - jsonPos);
				size_t jsonLength = 0;
				gason::JsonParser jsonParser;
				jsonParser.Parse(giftStr(json), &jsonLength);
				updateField.Values().emplace_back(Variant(std::string(parser.Begin() + jsonPos, jsonLength)));
				updateField.SetMode(FieldModeSetJson);
				parser.SetPos(jsonPos + jsonLength);
			} catch (const gason::Exception& e) {
				const auto range = parser.Where(tok);
				throw SqlParserError(range, "{}, in query {}", e.what(), range);
			}
		} else {
			auto eof = [](Tokenizer& parser, bool& inArray) -> bool {
				if (parser.End()) {
					return true;
				}
				auto nextTok = parser.PeekToken();
				bool result = (nextTok.Text() == "where"sv) || (nextTok.Text() == "order"sv) || (nextTok.Text() == "limit"sv) ||
							  (nextTok.Text() == "offset"sv) || (!inArray && nextTok.Text() == "]"sv) ||
							  (!inArray && nextTok.Text() == ","sv);
				if (nextTok.Text() == "["sv && !inArray) {
					inArray = true;
				}
				if (nextTok.Text() == "]"sv && inArray) {
					inArray = false;
				}
				return result;
			};
			int count = 0;
			std::string expression(tok.Text());
			bool inArray = false;
			while (!eof(parser, inArray)) {
				auto nextTok = parser.NextToken(Tokenizer::Flags::TreatSignAsToken);
				expression += (nextTok.Type() == TokenString) ? ('\'' + std::string{nextTok.Text()} + '\'') : std::string{nextTok.Text()};
				++count;
			}
			if (count > 0) {
				updateField.Values().emplace_back(std::move(expression));
				updateField.SetIsExpression(true);
			} else {
				try {
					Variant val = Token2kv(tok, parser, CompositeAllowed_False, FieldAllowed_False, NullAllowed_True);
					updateField.Values().emplace_back(std::move(val));
				} catch (const Error&) {
					updateField.Values().emplace_back(std::move(expression));
					updateField.SetIsExpression(true);
				}
			}
		}