Method update

src/Functions/generateSerialID.cpp:97–143

Increments the counter and returns the old counter.

    /// Increments the counter and returns the old counter.
    [[nodiscard]] UInt64 update(String series_name, UInt64 start_value, size_t & current_series, UInt64 increment, zkutil::ZooKeeperPtr & keeper) const
    {
        if (series_name.empty())
            throw Exception(ErrorCodes::BAD_ARGUMENTS, "The first argument of function {} (the series name) cannot be empty", name);
        series_name = escapeForFileName(series_name);
        if (series_name.size() > 100) /// Arbitrary safety threshold
            throw Exception(ErrorCodes::BAD_ARGUMENTS, "Series name '{}' is too long", series_name);

        String serial_path = std::filesystem::path(keeper_path) / series_name;

        if (current_series < max_series)
        {
            const auto initial_value = toString(start_value);
            auto code = keeper->tryCreate(serial_path, initial_value, zkutil::CreateMode::Persistent);
            if (code == Coordination::Error::ZOK)
                ++current_series;
            else if (code != Coordination::Error::ZNODEEXISTS)
                throw zkutil::KeeperException::fromPath(code, serial_path);
        }
        else
        {
            if (!keeper->exists(serial_path))
                throw Exception(ErrorCodes::LIMIT_EXCEEDED,
                    "Too many series created by {} function, maximum: {}. This is controlled by the `max_autoincrement_series` setting.",
                    name, max_series);
        }

        UInt64 counter = 0;
        Coordination::Stat stat;
        while (true)
        {
            String old_value = keeper->get(serial_path, &stat);
            counter = parse<UInt64>(old_value);
            String new_value = toString(counter + increment);
            auto code = keeper->trySet(serial_path, new_value, stat.version);

            if (code == Coordination::Error::ZOK)
                break;

            if (code == Coordination::Error::ZBADVERSION)
                continue;

            throw zkutil::KeeperException::fromPath(code, serial_path);
        }

        return counter;
    }

    ColumnPtr executeImpl(const ColumnsWithTypeAndName & arguments, const DataTypePtr &, size_t input_rows_count) const override
    {