#pragma once #include "FunctionsStringSearch.h" #include #include #include #include #include namespace DB { namespace ErrorCodes { extern const int ILLEGAL_COLUMN; } /** Implementation details for functions of 'position' family depending on ASCII/UTF8 and case sensitiveness. */ struct PositionCaseSensitiveASCII { /// For searching single substring inside big-enough contiguous chunk of data. Coluld have slightly expensive initialization. using SearcherInBigHaystack = Volnitsky; /// For search many substrings in one string using MultiSearcherInBigHaystack = MultiVolnitsky; /// For searching single substring, that is different each time. This object is created for each row of data. It must have cheap initialization. using SearcherInSmallHaystack = LibCASCIICaseSensitiveStringSearcher; static SearcherInBigHaystack createSearcherInBigHaystack(const char * needle_data, size_t needle_size, size_t haystack_size_hint) { return SearcherInBigHaystack(needle_data, needle_size, haystack_size_hint); } static SearcherInSmallHaystack createSearcherInSmallHaystack(const char * needle_data, size_t needle_size) { return SearcherInSmallHaystack(needle_data, needle_size); } static MultiSearcherInBigHaystack createMultiSearcherInBigHaystack(const std::vector & needles) { return MultiSearcherInBigHaystack(needles); } static const char * advancePos(const char * pos, const char * end, size_t n) { return std::min(pos + n, end); } /// Number of code points between 'begin' and 'end' (this has different behaviour for ASCII and UTF-8). static size_t countChars(const char * begin, const char * end) { return end - begin; } /// Convert string to lowercase. Only for case-insensitive search. /// Implementation is permitted to be inefficient because it is called for single string. static void toLowerIfNeed(std::string &) { } }; struct PositionCaseInsensitiveASCII { /// `Volnitsky` is not used here, because one person has measured that this is better. It will be good if you question it. using SearcherInBigHaystack = ASCIICaseInsensitiveStringSearcher; using MultiSearcherInBigHaystack = MultiVolnitskyCaseInsensitive; using SearcherInSmallHaystack = LibCASCIICaseInsensitiveStringSearcher; static SearcherInBigHaystack createSearcherInBigHaystack(const char * needle_data, size_t needle_size, size_t /*haystack_size_hint*/) { return SearcherInBigHaystack(needle_data, needle_size); } static SearcherInSmallHaystack createSearcherInSmallHaystack(const char * needle_data, size_t needle_size) { return SearcherInSmallHaystack(needle_data, needle_size); } static MultiSearcherInBigHaystack createMultiSearcherInBigHaystack(const std::vector & needles) { return MultiSearcherInBigHaystack(needles); } static const char * advancePos(const char * pos, const char * end, size_t n) { return std::min(pos + n, end); } static size_t countChars(const char * begin, const char * end) { return end - begin; } static void toLowerIfNeed(std::string & s) { std::transform(std::begin(s), std::end(s), std::begin(s), tolower); } }; struct PositionCaseSensitiveUTF8 { using SearcherInBigHaystack = VolnitskyUTF8; using MultiSearcherInBigHaystack = MultiVolnitskyUTF8; using SearcherInSmallHaystack = LibCASCIICaseSensitiveStringSearcher; static SearcherInBigHaystack createSearcherInBigHaystack(const char * needle_data, size_t needle_size, size_t haystack_size_hint) { return SearcherInBigHaystack(needle_data, needle_size, haystack_size_hint); } static SearcherInSmallHaystack createSearcherInSmallHaystack(const char * needle_data, size_t needle_size) { return SearcherInSmallHaystack(needle_data, needle_size); } static MultiSearcherInBigHaystack createMultiSearcherInBigHaystack(const std::vector & needles) { return MultiSearcherInBigHaystack(needles); } static const char * advancePos(const char * pos, const char * end, size_t n) { for (auto it = pos; it != end; ++it) { if (!UTF8::isContinuationOctet(static_cast(*it))) { if (n == 0) return it; n--; } } return end; } static size_t countChars(const char * begin, const char * end) { size_t res = 0; for (auto it = begin; it != end; ++it) if (!UTF8::isContinuationOctet(static_cast(*it))) ++res; return res; } static void toLowerIfNeed(std::string &) { } }; struct PositionCaseInsensitiveUTF8 { using SearcherInBigHaystack = VolnitskyCaseInsensitiveUTF8; using MultiSearcherInBigHaystack = MultiVolnitskyCaseInsensitiveUTF8; using SearcherInSmallHaystack = UTF8CaseInsensitiveStringSearcher; /// TODO Very suboptimal. static SearcherInBigHaystack createSearcherInBigHaystack(const char * needle_data, size_t needle_size, size_t haystack_size_hint) { return SearcherInBigHaystack(needle_data, needle_size, haystack_size_hint); } static SearcherInSmallHaystack createSearcherInSmallHaystack(const char * needle_data, size_t needle_size) { return SearcherInSmallHaystack(needle_data, needle_size); } static MultiSearcherInBigHaystack createMultiSearcherInBigHaystack(const std::vector & needles) { return MultiSearcherInBigHaystack(needles); } static const char * advancePos(const char * pos, const char * end, size_t n) { // reuse implementation that doesn't depend on case return PositionCaseSensitiveUTF8::advancePos(pos, end, n); } static size_t countChars(const char * begin, const char * end) { // reuse implementation that doesn't depend on case return PositionCaseSensitiveUTF8::countChars(begin, end); } static void toLowerIfNeed(std::string & s) { Poco::UTF8::toLowerInPlace(s); } }; template struct PositionImpl { static constexpr bool use_default_implementation_for_constants = false; static constexpr bool supports_start_pos = true; static constexpr auto name = Name::name; using ResultType = UInt64; /// Find one substring in many strings. static void vectorConstant( const ColumnString::Chars & data, const ColumnString::Offsets & offsets, const std::string & needle, const ColumnPtr & start_pos, PaddedPODArray & res) { const UInt8 * begin = data.data(); const UInt8 * pos = begin; const UInt8 * end = pos + data.size(); /// Current index in the array of strings. size_t i = 0; typename Impl::SearcherInBigHaystack searcher = Impl::createSearcherInBigHaystack(needle.data(), needle.size(), end - pos); /// We will search for the next occurrence in all strings at once. while (pos < end && end != (pos = searcher.search(pos, end - pos))) { /// Determine which index it refers to. while (begin + offsets[i] <= pos) { res[i] = 0; ++i; } auto start = start_pos != nullptr ? start_pos->getUInt(i) : 0; /// We check that the entry does not pass through the boundaries of strings. if (pos + needle.size() < begin + offsets[i]) { auto res_pos = 1 + Impl::countChars(reinterpret_cast(begin + offsets[i - 1]), reinterpret_cast(pos)); if (res_pos < start) { pos = reinterpret_cast(Impl::advancePos( reinterpret_cast(pos), reinterpret_cast(begin + offsets[i]), start - res_pos)); continue; } res[i] = res_pos; } else { res[i] = 0; } pos = begin + offsets[i]; ++i; } if (i < res.size()) memset(&res[i], 0, (res.size() - i) * sizeof(res[0])); } /// Search for substring in string. static void constantConstantScalar( std::string data, std::string needle, UInt64 start_pos, UInt64 & res) { auto start = std::max(start_pos, UInt64(1)); if (needle.size() == 0) { size_t haystack_size = Impl::countChars(data.data(), data.data() + data.size()); res = start <= haystack_size + 1 ? start : 0; return; } size_t start_byte = Impl::advancePos(data.data(), data.data() + data.size(), start - 1) - data.data(); res = data.find(needle, start_byte); if (res == std::string::npos) res = 0; else res = 1 + Impl::countChars(data.data(), data.data() + res); } /// Search for substring in string starting from different positions. static void constantConstant( std::string data, std::string needle, const ColumnPtr & start_pos, PaddedPODArray & res) { Impl::toLowerIfNeed(data); Impl::toLowerIfNeed(needle); if (start_pos == nullptr) { constantConstantScalar(data, needle, 0, res[0]); return; } size_t haystack_size = Impl::countChars(data.data(), data.data() + data.size()); size_t size = start_pos != nullptr ? start_pos->size() : 0; for (size_t i = 0; i < size; ++i) { auto start = start_pos->getUInt(i); if (start > haystack_size + 1) { res[i] = 0; continue; } constantConstantScalar(data, needle, start, res[i]); } } /// Search each time for a different single substring inside each time different string. static void vectorVector( const ColumnString::Chars & haystack_data, const ColumnString::Offsets & haystack_offsets, const ColumnString::Chars & needle_data, const ColumnString::Offsets & needle_offsets, const ColumnPtr & start_pos, PaddedPODArray & res) { ColumnString::Offset prev_haystack_offset = 0; ColumnString::Offset prev_needle_offset = 0; size_t size = haystack_offsets.size(); for (size_t i = 0; i < size; ++i) { size_t needle_size = needle_offsets[i] - prev_needle_offset - 1; size_t haystack_size = haystack_offsets[i] - prev_haystack_offset - 1; auto start = start_pos != nullptr ? std::max(start_pos->getUInt(i), UInt64(1)) : UInt64(1); if (start > haystack_size + 1) { res[i] = 0; } else if (0 == needle_size) { /// An empty string is always at any position in `haystack`. res[i] = start; } else { /// It is assumed that the StringSearcher is not very difficult to initialize. typename Impl::SearcherInSmallHaystack searcher = Impl::createSearcherInSmallHaystack( reinterpret_cast(&needle_data[prev_needle_offset]), needle_offsets[i] - prev_needle_offset - 1); /// zero byte at the end const char * beg = Impl::advancePos( reinterpret_cast(&haystack_data[prev_haystack_offset]), reinterpret_cast(&haystack_data[haystack_offsets[i] - 1]), start - 1); /// searcher returns a pointer to the found substring or to the end of `haystack`. size_t pos = searcher.search(reinterpret_cast(beg), &haystack_data[haystack_offsets[i] - 1]) - &haystack_data[prev_haystack_offset]; if (pos != haystack_size) { res[i] = 1 + Impl::countChars( reinterpret_cast(&haystack_data[prev_haystack_offset]), reinterpret_cast(&haystack_data[prev_haystack_offset + pos])); } else res[i] = 0; } prev_haystack_offset = haystack_offsets[i]; prev_needle_offset = needle_offsets[i]; } } /// Find many substrings in single string. static void constantVector( const String & haystack, const ColumnString::Chars & needle_data, const ColumnString::Offsets & needle_offsets, const ColumnPtr & start_pos, PaddedPODArray & res) { /// NOTE You could use haystack indexing. But this is a rare case. ColumnString::Offset prev_needle_offset = 0; size_t size = needle_offsets.size(); for (size_t i = 0; i < size; ++i) { size_t needle_size = needle_offsets[i] - prev_needle_offset - 1; auto start = start_pos != nullptr ? std::max(start_pos->getUInt(i), UInt64(1)) : UInt64(1); if (start > haystack.size() + 1) { res[i] = 0; } else if (0 == needle_size) { res[i] = start; } else { typename Impl::SearcherInSmallHaystack searcher = Impl::createSearcherInSmallHaystack( reinterpret_cast(&needle_data[prev_needle_offset]), needle_offsets[i] - prev_needle_offset - 1); const char * beg = Impl::advancePos(haystack.data(), haystack.data() + haystack.size(), start - 1); size_t pos = searcher.search( reinterpret_cast(beg), reinterpret_cast(haystack.data()) + haystack.size()) - reinterpret_cast(haystack.data()); if (pos != haystack.size()) { res[i] = 1 + Impl::countChars(haystack.data(), haystack.data() + pos); } else res[i] = 0; } prev_needle_offset = needle_offsets[i]; } } template static void vectorFixedConstant(Args &&...) { throw Exception(ErrorCodes::ILLEGAL_COLUMN, "Function '{}' doesn't support FixedString haystack argument", name); } }; }