Function insertValue

src/Processors/Sources/MySQLSource.cpp:217–393

    using ValueType = ExternalResultDescription::ValueType;

    void insertValue(const IDataType & data_type, IColumn & column, const ValueType type, const mysqlxx::Value & value, size_t & read_bytes_size, enum enum_field_types mysql_type)
    {
        switch (type)
        {
            case ValueType::vtUInt8:
                assert_cast<ColumnUInt8 &>(column).insertValue(static_cast<UInt8>(value.getUInt()));
                read_bytes_size += 1;
                break;
            case ValueType::vtUInt16:
                assert_cast<ColumnUInt16 &>(column).insertValue(static_cast<UInt16>(value.getUInt()));
                read_bytes_size += 2;
                break;
            case ValueType::vtUInt32:
                assert_cast<ColumnUInt32 &>(column).insertValue(static_cast<UInt32>(value.getUInt()));
                read_bytes_size += 4;
                break;
            case ValueType::vtUInt64:
            {
                if (mysql_type == enum_field_types::MYSQL_TYPE_BIT)
                {
                    size_t n = value.size();
                    UInt64 val = 0UL;
                    char * to = reinterpret_cast<char *>(&val);
                    memcpy(to, const_cast<char *>(value.data()), n);

                    if constexpr (std::endian::native == std::endian::little)
                    {
                        char * start = to;
                        char * end = to + n;
                        std::reverse(start, end);
                    }
                    assert_cast<ColumnUInt64 &>(column).insertValue(val);
                    read_bytes_size += n;
                }
                else
                {
                    assert_cast<ColumnUInt64 &>(column).insertValue(value.getUInt());
                    read_bytes_size += 8;
                }
                break;
            }
            case ValueType::vtInt8:
                assert_cast<ColumnInt8 &>(column).insertValue(static_cast<Int8>(value.getInt()));
                read_bytes_size += 1;
                break;
            case ValueType::vtInt16:
                assert_cast<ColumnInt16 &>(column).insertValue(static_cast<Int16>(value.getInt()));
                read_bytes_size += 2;
                break;
            case ValueType::vtInt32:
                assert_cast<ColumnInt32 &>(column).insertValue(static_cast<Int32>(value.getInt()));
                read_bytes_size += 4;
                break;
            case ValueType::vtInt64:
            {
                if (mysql_type == enum_field_types::MYSQL_TYPE_TIME)
                {
                    String time_str(value.data(), value.size());