#pragma once #include #include #include class SipHash; namespace DB { namespace ErrorCodes { extern const int CANNOT_CONVERT_TYPE; extern const int BAD_TYPE_OF_FIELD; extern const int LOGICAL_ERROR; } UInt128 stringToUUID(const String &); /** StaticVisitor (and its descendants) - class with overloaded operator() for all types of fields. * You could call visitor for field using function 'applyVisitor'. * Also "binary visitor" is supported - its operator() takes two arguments. */ template struct StaticVisitor { using ResultType = R; }; /// F is template parameter, to allow universal reference for field, that is useful for const and non-const values. template typename std::decay_t::ResultType applyVisitor(Visitor && visitor, F && field) { switch (field.getType()) { case Field::Types::Null: return visitor(field.template get()); case Field::Types::UInt64: return visitor(field.template get()); case Field::Types::UInt128: return visitor(field.template get()); case Field::Types::Int64: return visitor(field.template get()); case Field::Types::Float64: return visitor(field.template get()); case Field::Types::String: return visitor(field.template get()); case Field::Types::Array: return visitor(field.template get()); case Field::Types::Tuple: return visitor(field.template get()); case Field::Types::Decimal32: return visitor(field.template get>()); case Field::Types::Decimal64: return visitor(field.template get>()); case Field::Types::Decimal128: return visitor(field.template get>()); case Field::Types::AggregateFunctionState: return visitor(field.template get()); default: throw Exception("Bad type of Field", ErrorCodes::BAD_TYPE_OF_FIELD); } } template static typename std::decay_t::ResultType applyBinaryVisitorImpl(Visitor && visitor, F1 && field1, F2 && field2) { switch (field2.getType()) { case Field::Types::Null: return visitor(field1, field2.template get()); case Field::Types::UInt64: return visitor(field1, field2.template get()); case Field::Types::UInt128: return visitor(field1, field2.template get()); case Field::Types::Int64: return visitor(field1, field2.template get()); case Field::Types::Float64: return visitor(field1, field2.template get()); case Field::Types::String: return visitor(field1, field2.template get()); case Field::Types::Array: return visitor(field1, field2.template get()); case Field::Types::Tuple: return visitor(field1, field2.template get()); case Field::Types::Decimal32: return visitor(field1, field2.template get>()); case Field::Types::Decimal64: return visitor(field1, field2.template get>()); case Field::Types::Decimal128: return visitor(field1, field2.template get>()); case Field::Types::AggregateFunctionState: return visitor(field1, field2.template get()); default: throw Exception("Bad type of Field", ErrorCodes::BAD_TYPE_OF_FIELD); } } template typename std::decay_t::ResultType applyVisitor(Visitor && visitor, F1 && field1, F2 && field2) { switch (field1.getType()) { case Field::Types::Null: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::UInt64: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::UInt128: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::Int64: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::Float64: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::String: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::Array: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::Tuple: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); case Field::Types::Decimal32: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get>(), std::forward(field2)); case Field::Types::Decimal64: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get>(), std::forward(field2)); case Field::Types::Decimal128: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get>(), std::forward(field2)); case Field::Types::AggregateFunctionState: return applyBinaryVisitorImpl( std::forward(visitor), field1.template get(), std::forward(field2)); default: throw Exception("Bad type of Field", ErrorCodes::BAD_TYPE_OF_FIELD); } } /** Prints Field as literal in SQL query */ class FieldVisitorToString : public StaticVisitor { public: String operator() (const Null & x) const; String operator() (const UInt64 & x) const; String operator() (const UInt128 & x) const; String operator() (const Int64 & x) const; String operator() (const Float64 & x) const; String operator() (const String & x) const; String operator() (const Array & x) const; String operator() (const Tuple & x) const; String operator() (const DecimalField & x) const; String operator() (const DecimalField & x) const; String operator() (const DecimalField & x) const; String operator() (const AggregateFunctionStateData & x) const; }; /** Print readable and unique text dump of field type and value. */ class FieldVisitorDump : public StaticVisitor { public: String operator() (const Null & x) const; String operator() (const UInt64 & x) const; String operator() (const UInt128 & x) const; String operator() (const Int64 & x) const; String operator() (const Float64 & x) const; String operator() (const String & x) const; String operator() (const Array & x) const; String operator() (const Tuple & x) const; String operator() (const DecimalField & x) const; String operator() (const DecimalField & x) const; String operator() (const DecimalField & x) const; String operator() (const AggregateFunctionStateData & x) const; }; /** Converts numberic value of any type to specified type. */ template class FieldVisitorConvertToNumber : public StaticVisitor { public: T operator() (const Null &) const { throw Exception("Cannot convert NULL to " + demangle(typeid(T).name()), ErrorCodes::CANNOT_CONVERT_TYPE); } T operator() (const String &) const { throw Exception("Cannot convert String to " + demangle(typeid(T).name()), ErrorCodes::CANNOT_CONVERT_TYPE); } T operator() (const Array &) const { throw Exception("Cannot convert Array to " + demangle(typeid(T).name()), ErrorCodes::CANNOT_CONVERT_TYPE); } T operator() (const Tuple &) const { throw Exception("Cannot convert Tuple to " + demangle(typeid(T).name()), ErrorCodes::CANNOT_CONVERT_TYPE); } T operator() (const UInt64 & x) const { return x; } T operator() (const Int64 & x) const { return x; } T operator() (const Float64 & x) const { return x; } T operator() (const UInt128 &) const { throw Exception("Cannot convert UInt128 to " + demangle(typeid(T).name()), ErrorCodes::CANNOT_CONVERT_TYPE); } template T operator() (const DecimalField & x) const { if constexpr (std::is_floating_point_v) return static_cast(x.getValue()) / x.getScaleMultiplier(); else return x.getValue() / x.getScaleMultiplier(); } T operator() (const AggregateFunctionStateData &) const { throw Exception("Cannot convert AggregateFunctionStateData to " + demangle(typeid(T).name()), ErrorCodes::CANNOT_CONVERT_TYPE); } }; /** Updates SipHash by type and value of Field */ class FieldVisitorHash : public StaticVisitor<> { private: SipHash & hash; public: FieldVisitorHash(SipHash & hash); void operator() (const Null & x) const; void operator() (const UInt64 & x) const; void operator() (const UInt128 & x) const; void operator() (const Int64 & x) const; void operator() (const Float64 & x) const; void operator() (const String & x) const; void operator() (const Array & x) const; void operator() (const DecimalField & x) const; void operator() (const DecimalField & x) const; void operator() (const DecimalField & x) const; void operator() (const AggregateFunctionStateData & x) const; }; template constexpr bool isDecimalField() { return false; } template <> constexpr bool isDecimalField>() { return true; } template <> constexpr bool isDecimalField>() { return true; } template <> constexpr bool isDecimalField>() { return true; } /** More precise comparison, used for index. * Differs from Field::operator< and Field::operator== in that it also compares values of different types. * Comparison rules are same as in FunctionsComparison (to be consistent with expression evaluation in query). */ class FieldVisitorAccurateEquals : public StaticVisitor { public: bool operator() (const UInt64 & l, const Null & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const UInt64 & r) const { return l == r; } bool operator() (const UInt64 & l, const UInt128 & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const Int64 & r) const { return accurate::equalsOp(l, r); } bool operator() (const UInt64 & l, const Float64 & r) const { return accurate::equalsOp(l, r); } bool operator() (const UInt64 & l, const String & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const Array & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const Tuple & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const AggregateFunctionStateData & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Null & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const UInt64 & r) const { return accurate::equalsOp(l, r); } bool operator() (const Int64 & l, const UInt128 & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Int64 & r) const { return l == r; } bool operator() (const Int64 & l, const Float64 & r) const { return accurate::equalsOp(l, r); } bool operator() (const Int64 & l, const String & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Array & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Tuple & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const AggregateFunctionStateData & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Null & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const UInt64 & r) const { return accurate::equalsOp(l, r); } bool operator() (const Float64 & l, const UInt128 & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Int64 & r) const { return accurate::equalsOp(l, r); } bool operator() (const Float64 & l, const Float64 & r) const { return l == r; } bool operator() (const Float64 & l, const String & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Array & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Tuple & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const AggregateFunctionStateData & r) const { return cantCompare(l, r); } template bool operator() (const Null &, const T &) const { return std::is_same_v; } template bool operator() (const String & l, const T & r) const { if constexpr (std::is_same_v) return l == r; if constexpr (std::is_same_v) return stringToUUID(l) == r; return cantCompare(l, r); } template bool operator() (const UInt128 & l, const T & r) const { if constexpr (std::is_same_v) return l == r; if constexpr (std::is_same_v) return l == stringToUUID(r); return cantCompare(l, r); } template bool operator() (const Array & l, const T & r) const { if constexpr (std::is_same_v) return l == r; return cantCompare(l, r); } template bool operator() (const Tuple & l, const T & r) const { if constexpr (std::is_same_v) return l == r; return cantCompare(l, r); } template bool operator() (const DecimalField & l, const U & r) const { if constexpr (isDecimalField()) return l == r; if constexpr (std::is_same_v || std::is_same_v) return l == DecimalField(r, 0); return cantCompare(l, r); } template bool operator() (const UInt64 & l, const DecimalField & r) const { return DecimalField(l, 0) == r; } template bool operator() (const Int64 & l, const DecimalField & r) const { return DecimalField(l, 0) == r; } template bool operator() (const Float64 & l, const DecimalField & r) const { return cantCompare(l, r); } template bool operator() (const AggregateFunctionStateData & l, const T & r) const { if constexpr (std::is_same_v) return l == r; return cantCompare(l, r); } private: template bool cantCompare(const T &, const U &) const { if constexpr (std::is_same_v) return false; throw Exception("Cannot compare " + demangle(typeid(T).name()) + " with " + demangle(typeid(U).name()), ErrorCodes::BAD_TYPE_OF_FIELD); } }; class FieldVisitorAccurateLess : public StaticVisitor { public: bool operator() (const UInt64 & l, const Null & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const UInt64 & r) const { return l < r; } bool operator() (const UInt64 & l, const UInt128 & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const Int64 & r) const { return accurate::lessOp(l, r); } bool operator() (const UInt64 & l, const Float64 & r) const { return accurate::lessOp(l, r); } bool operator() (const UInt64 & l, const String & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const Array & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const Tuple & r) const { return cantCompare(l, r); } bool operator() (const UInt64 & l, const AggregateFunctionStateData & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Null & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const UInt64 & r) const { return accurate::lessOp(l, r); } bool operator() (const Int64 & l, const UInt128 & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Int64 & r) const { return l < r; } bool operator() (const Int64 & l, const Float64 & r) const { return accurate::lessOp(l, r); } bool operator() (const Int64 & l, const String & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Array & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const Tuple & r) const { return cantCompare(l, r); } bool operator() (const Int64 & l, const AggregateFunctionStateData & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Null & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const UInt64 & r) const { return accurate::lessOp(l, r); } bool operator() (const Float64 & l, const UInt128 & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Int64 & r) const { return accurate::lessOp(l, r); } bool operator() (const Float64 & l, const Float64 & r) const { return l < r; } bool operator() (const Float64 & l, const String & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Array & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const Tuple & r) const { return cantCompare(l, r); } bool operator() (const Float64 & l, const AggregateFunctionStateData & r) const { return cantCompare(l, r); } template bool operator() (const Null &, const T &) const { return !std::is_same_v; } template bool operator() (const String & l, const T & r) const { if constexpr (std::is_same_v) return l < r; if constexpr (std::is_same_v) return stringToUUID(l) < r; return cantCompare(l, r); } template bool operator() (const UInt128 & l, const T & r) const { if constexpr (std::is_same_v) return l < r; if constexpr (std::is_same_v) return l < stringToUUID(r); return cantCompare(l, r); } template bool operator() (const Array & l, const T & r) const { if constexpr (std::is_same_v) return l < r; return cantCompare(l, r); } template bool operator() (const Tuple & l, const T & r) const { if constexpr (std::is_same_v) return l < r; return cantCompare(l, r); } template bool operator() (const DecimalField & l, const U & r) const { if constexpr (isDecimalField()) return l < r; else if constexpr (std::is_same_v || std::is_same_v) return l < DecimalField(r, 0); return cantCompare(l, r); } template bool operator() (const UInt64 & l, const DecimalField & r) const { return DecimalField(l, 0) < r; } template bool operator() (const Int64 & l, const DecimalField & r) const { return DecimalField(l, 0) < r; } template bool operator() (const Float64 &, const DecimalField &) const { return false; } template bool operator() (const AggregateFunctionStateData & l, const T & r) const { return cantCompare(l, r); } private: template bool cantCompare(const T &, const U &) const { throw Exception("Cannot compare " + demangle(typeid(T).name()) + " with " + demangle(typeid(U).name()), ErrorCodes::BAD_TYPE_OF_FIELD); } }; /** Implements `+=` operation. * Returns false if the result is zero. */ class FieldVisitorSum : public StaticVisitor { private: const Field & rhs; public: explicit FieldVisitorSum(const Field & rhs_) : rhs(rhs_) {} bool operator() (UInt64 & x) const { x += get(rhs); return x != 0; } bool operator() (Int64 & x) const { x += get(rhs); return x != 0; } bool operator() (Float64 & x) const { x += get(rhs); return x != 0; } bool operator() (Null &) const { throw Exception("Cannot sum Nulls", ErrorCodes::LOGICAL_ERROR); } bool operator() (String &) const { throw Exception("Cannot sum Strings", ErrorCodes::LOGICAL_ERROR); } bool operator() (Array &) const { throw Exception("Cannot sum Arrays", ErrorCodes::LOGICAL_ERROR); } bool operator() (UInt128 &) const { throw Exception("Cannot sum UUIDs", ErrorCodes::LOGICAL_ERROR); } bool operator() (AggregateFunctionStateData &) const { throw Exception("Cannot sum AggregateFunctionStates", ErrorCodes::LOGICAL_ERROR); } template bool operator() (DecimalField & x) const { x += get>(rhs); return x.getValue() != 0; } }; }