Method executeImpl

src/Functions/fuzzQuery.cpp:69–110

    }

    ColumnPtr executeImpl(const ColumnsWithTypeAndName & arguments, const DataTypePtr &, size_t input_rows_count) const override
    {
        const ColumnPtr col_query = arguments[0].column;

        if (const ColumnString * col_query_string = checkAndGetColumn<ColumnString>(col_query.get()))
        {
            auto col_res = ColumnString::create();
            fuzzVector(
                col_query_string->getChars(), col_query_string->getOffsets(),
                *col_res,
                input_rows_count);
            return col_res;
        }

        if (const ColumnConst * col_query_const = checkAndGetColumnConstStringOrFixedString(col_query.get()))
        {
            auto col_res = ColumnString::create();

            const ColumnString::Chars & data = assert_cast<const ColumnString &>(col_query_const->getDataColumn()).getChars();
            const char * begin = reinterpret_cast<const char *>(data.data());
            const char * end = begin + data.size();
            ParserQuery parser(end, false, implicit_select);
            ASTPtr ast = parseQuery(parser, begin, end, "fuzzQuery", max_query_size, max_parser_depth, max_parser_backtracks);

            for (size_t i = 0; i < input_rows_count; ++i)
            {
                ASTPtr fuzzed_ast = ast->clone();
                {
                    auto [fuzzer, lock] = getGlobalASTFuzzer();
                    fuzzer->fuzzMain(fuzzed_ast);
                }

                WriteBufferFromOwnString buf;
                fuzzed_ast->format(buf, IAST::FormatSettings(/*one_line=*/true));
                col_res->insertData(buf.str().data(), buf.str().size());
            }

            return col_res;
        }

        throw Exception(ErrorCodes::ILLEGAL_COLUMN, "Illegal column {} of argument of function {}", col_query->getName(), getName());
    }

private:
    void fuzzVector(