Method execute

src/Functions/obfuscateQuery.cpp:153–225

ColumnPtr ObfuscateQueryFunction::execute(const ColumnsWithTypeAndName & arguments, size_t input_rows_count) const
{
    const ColumnPtr col_query = arguments[0].column;

    auto col_res = ColumnString::create();
    const std::optional<UInt64> const_seed_hash = (arguments.size() >= 2) ? extractConstSeedFromArg(arguments[1].column) : std::nullopt;
    const KnownIdentifierFunc & known_identifier_func = getKnownIdentifierFunc();

    /// Two main paths: column of strings, or a const column.
    if (const ColumnString * col_query_string = checkAndGetColumn<ColumnString>(col_query.get()))
    {
        for (size_t i = 0; i < input_rows_count; ++i)
        {
            std::string_view src = col_query_string->getDataAt(i);

            UInt64 seed_value = 0;
            if (mode == Mode::WithProvidedSeed && arguments.size() >= 2)
            {
                seed_value = const_seed_hash ? *const_seed_hash : extractSeedFromArg(arguments[1].column, i);
            }
            else
            {
                seed_value = thread_local_rng();
            }

            WordMap obfuscate_map;
            WordSet used_nouns;

            SipHash hash_func;
            hash_func.update(seed_value);

            WriteBufferFromOwnString wb;
            obfuscateQueries(src, wb, obfuscate_map, used_nouns, hash_func, known_identifier_func);
            auto & out = wb.str();

            col_res->insertData(out.data(), out.size());
        }
    }
    else if (const ColumnConst * col_query_const = checkAndGetColumnConst<ColumnString>(col_query.get()))
    {
        const String & const_query = col_query_const->getValue<String>();
        for (size_t i = 0; i < input_rows_count; ++i)
        {
            UInt64 seed_value = 0;
            if (mode == Mode::WithProvidedSeed && arguments.size() >= 2)
            {
                seed_value = const_seed_hash ? *const_seed_hash : extractSeedFromArg(arguments[1].column, i);
            }
            else
            {
                seed_value = thread_local_rng();
            }

            WordMap obfuscate_map;
            WordSet used_nouns;

            SipHash hash_func;
            hash_func.update(seed_value);