#include #include #include #include namespace { template struct CRCBase { T tab[256]; explicit CRCBase(T polynomial) { for (size_t i = 0; i < 256; ++i) { T c = i; for (size_t j = 0; j < 8; ++j) { c = c & 1 ? polynomial ^ (c >> 1) : c >> 1; } tab[i] = c; } } }; template struct CRCImpl { using ReturnType = T; static T make_crc(const unsigned char *buf, size_t size) { static CRCBase base(polynomial); T i, crc; crc = 0; for (i = 0; i < size; i++) { crc = base.tab[(crc ^ buf[i]) & 0xff] ^ (crc >> 8); } return crc; } }; constexpr UInt64 CRC64_ECMA = 0xc96c5795d7870f42ULL; struct CRC64ECMAImpl : public CRCImpl { static constexpr auto name = "CRC64"; }; constexpr UInt32 CRC32_IEEE = 0xedb88320; struct CRC32IEEEImpl : public CRCImpl { static constexpr auto name = "CRC32IEEE"; }; struct CRC32ZLIBImpl { using ReturnType = UInt32; static constexpr auto name = "CRC32"; static UInt32 make_crc(const unsigned char *buf, size_t size) { return crc32_z(0L, buf, size); } }; } // \anonymous namespace DB { namespace ErrorCodes { extern const int ILLEGAL_TYPE_OF_ARGUMENT; } template struct CRCFunctionWrapper { static constexpr auto is_fixed_to_constant = true; using ReturnType = typename Impl::ReturnType; static void vector(const ColumnString::Chars & data, const ColumnString::Offsets & offsets, PaddedPODArray & res) { size_t size = offsets.size(); ColumnString::Offset prev_offset = 0; for (size_t i = 0; i < size; ++i) { res[i] = do_crc(data, prev_offset, offsets[i] - prev_offset - 1); prev_offset = offsets[i]; } } static void vector_fixed_to_constant(const ColumnString::Chars & data, size_t n, ReturnType & res) { res = do_crc(data, 0, n); } static void vector_fixed_to_vector(const ColumnString::Chars & data, size_t n, PaddedPODArray & res) { size_t size = data.size() / n; for (size_t i = 0; i < size; ++i) { res[i] = do_crc(data, i * n, n); } } [[noreturn]] static void array(const ColumnString::Offsets & /*offsets*/, PaddedPODArray & /*res*/) { throw Exception("Cannot apply function " + std::string(Impl::name) + " to Array argument", ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT); } private: static ReturnType do_crc(const ColumnString::Chars & buf, size_t offset, size_t size) { const unsigned char * p = reinterpret_cast(&buf[0]) + offset; return Impl::make_crc(p, size); } }; template using FunctionCRC = FunctionStringOrArrayToT, T, typename T::ReturnType>; // The same as IEEE variant, but uses 0xffffffff as initial value // This is the default // // (And zlib is used here, since it has optimized version) using FunctionCRC32ZLIB = FunctionCRC; // Uses CRC-32-IEEE 802.3 polynomial using FunctionCRC32IEEE = FunctionCRC; // Uses CRC-64-ECMA polynomial using FunctionCRC64ECMA = FunctionCRC; template void registerFunctionCRCImpl(FunctionFactory & factory) { factory.registerFunction(T::name, FunctionFactory::CaseInsensitive); } void registerFunctionCRC(FunctionFactory & factory) { registerFunctionCRCImpl(factory); registerFunctionCRCImpl(factory); registerFunctionCRCImpl(factory); } }