Method executeImpl

src/Functions/FunctionSQLJSON.h:1669–1830

    }

    ColumnPtr executeImpl(const ColumnsWithTypeAndName & arguments, const DataTypePtr & result_type, size_t input_rows_count) const override
    {
        //Only support Object JSON
        bool has_nothing_argument = false;
        for (const auto & arg : arguments)
            has_nothing_argument |= isNothing(arg.type);

        if (arguments.empty())
            throw Exception(ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH, "Function {} requires at least one argument", Name::name);

        // TODO: add logic to handle single argument
        if (arguments.size() < 3)
        {
            throw Exception{"Function JSON_CONTAINS_PATH require at least 3 arguments", ErrorCodes::TOO_FEW_ARGUMENTS_FOR_FUNCTION};
        }

        const auto & json_column = arguments[0];
        auto first_type_base = removeNullable(removeLowCardinality(json_column.type));

        bool is_string = isString(first_type_base);
        bool is_object = isObject(first_type_base);
        bool is_tuple = isTuple(first_type_base);

        if (!is_string && !is_object && !is_tuple)
            throw Exception(
                ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT,
                "The first argument of function {} should be a string containing Object or Tuple or JSON, illegal type: {}",
                Name::name,
                json_column.type->getName());

        const auto & any_or_all_column = arguments[1];
        if (!isString(any_or_all_column.type) || !isColumnConst(*any_or_all_column.column))
            throw Exception("Second argument (any or all) must be constant string", ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT);

        const ColumnPtr & arg_any_or_all = any_or_all_column.column;
        const auto * arg_any_or_all_const = typeid_cast<const ColumnConst *>(arg_any_or_all.get());
        const auto * arg_any_or_all_string = typeid_cast<const ColumnString *>(arg_any_or_all_const->getDataColumnPtr().get());
        
        bool contains_all = false;
        if (Poco::toLower(arg_any_or_all_string->getDataAt(0).toString()) == "all")
            contains_all = true;
        else if (Poco::toLower(arg_any_or_all_string->getDataAt(0).toString()) == "one")
            contains_all = false;
        else
            throw Exception("Second argument (any or all) only can be any or all", ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT);
        
        ASTs json_path_ast_ptrs;
        for (size_t i = 2; i < arguments.size(); i++)
        {
            const auto & json_path_column = arguments[i];

            if (!isString(json_path_column.type))
            {
                throw Exception(
                    "JSONPath functions require third argument to be JSONPath of type string, illegal type: "
                        + json_path_column.type->getName(),
                    ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT);
            }