mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 00:30:49 +00:00
FunctionsConversion: Remove some templates
This commit is contained in:
Raúl Marín
parent
e4209218d4
commit
54c5ea8d6d
@ -1127,23 +1127,24 @@ struct AccurateOrNullConvertStrategyAdditions
|
||||
UInt32 scale { 0 };
|
||||
};
|
||||
|
||||
|
||||
struct ConvertDefaultBehaviorTag {};
|
||||
struct ConvertReturnNullOnErrorTag {};
|
||||
struct ConvertReturnZeroOnErrorTag {};
|
||||
enum class BehaviourOnErrorFromString
|
||||
{
|
||||
ConvertDefaultBehaviorTag,
|
||||
ConvertReturnNullOnErrorTag,
|
||||
ConvertReturnZeroOnErrorTag
|
||||
};
|
||||
|
||||
/** Conversion of number types to each other, enums to numbers, dates and datetimes to numbers and back: done by straight assignment.
|
||||
* (Date is represented internally as number of days from some day; DateTime - as unix timestamp)
|
||||
*/
|
||||
template <typename FromDataType, typename ToDataType, typename Name,
|
||||
typename SpecialTag = ConvertDefaultBehaviorTag,
|
||||
FormatSettings::DateTimeOverflowBehavior date_time_overflow_behavior = default_date_time_overflow_behavior>
|
||||
struct ConvertImpl
|
||||
{
|
||||
template <typename Additions = void *>
|
||||
static ColumnPtr NO_SANITIZE_UNDEFINED execute(
|
||||
const ColumnsWithTypeAndName & arguments, const DataTypePtr & result_type [[maybe_unused]], size_t input_rows_count,
|
||||
Additions additions = Additions())
|
||||
BehaviourOnErrorFromString from_string_tag [[maybe_unused]], Additions additions = Additions())
|
||||
{
|
||||
const ColumnWithTypeAndName & named_from = arguments[0];
|
||||
|
||||
@ -1176,8 +1177,7 @@ struct ConvertImpl
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTimeImpl<date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
}
|
||||
else if constexpr (std::is_same_v<FromDataType, DataTypeDateTime64> && std::is_same_v<ToDataType, DataTypeDate32>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
else if constexpr (std::is_same_v<FromDataType, DataTypeDateTime64> && std::is_same_v<ToDataType, DataTypeDate32>)
|
||||
{
|
||||
return DateTimeTransformImpl<DataTypeDateTime64, DataTypeDate32, TransformDateTime64<ToDate32Impl>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
@ -1194,8 +1194,7 @@ struct ConvertImpl
|
||||
else if constexpr ((
|
||||
std::is_same_v<FromDataType, DataTypeUInt32>
|
||||
|| std::is_same_v<FromDataType, DataTypeUInt64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTransform32Or64<typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1203,8 +1202,7 @@ struct ConvertImpl
|
||||
else if constexpr ((
|
||||
std::is_same_v<FromDataType, DataTypeInt8>
|
||||
|| std::is_same_v<FromDataType, DataTypeInt16>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTransform8Or16Signed<typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1214,8 +1212,7 @@ struct ConvertImpl
|
||||
|| std::is_same_v<FromDataType, DataTypeInt64>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat32>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTransform32Or64Signed<typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1223,8 +1220,7 @@ struct ConvertImpl
|
||||
else if constexpr ((
|
||||
std::is_same_v<FromDataType, DataTypeUInt32>
|
||||
|| std::is_same_v<FromDataType, DataTypeUInt64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate32>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate32>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDate32Transform32Or64<typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1232,8 +1228,7 @@ struct ConvertImpl
|
||||
else if constexpr ((
|
||||
std::is_same_v<FromDataType, DataTypeInt8>
|
||||
|| std::is_same_v<FromDataType, DataTypeInt16>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate32>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate32>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDate32Transform8Or16Signed<typename FromDataType::FieldType>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1243,8 +1238,7 @@ struct ConvertImpl
|
||||
|| std::is_same_v<FromDataType, DataTypeInt64>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat32>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate32>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate32>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDate32Transform32Or64Signed<typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1254,15 +1248,13 @@ struct ConvertImpl
|
||||
std::is_same_v<FromDataType, DataTypeInt8>
|
||||
|| std::is_same_v<FromDataType, DataTypeInt16>
|
||||
|| std::is_same_v<FromDataType, DataTypeInt32>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTimeTransformSigned<typename FromDataType::FieldType, UInt32, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
}
|
||||
else if constexpr (std::is_same_v<FromDataType, DataTypeUInt64>
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTimeTransform64<typename FromDataType::FieldType, UInt32, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1271,8 +1263,7 @@ struct ConvertImpl
|
||||
std::is_same_v<FromDataType, DataTypeInt64>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat32>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTimeTransform64Signed<typename FromDataType::FieldType, UInt32, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
@ -1282,15 +1273,13 @@ struct ConvertImpl
|
||||
|| std::is_same_v<FromDataType, DataTypeInt16>
|
||||
|| std::is_same_v<FromDataType, DataTypeInt32>
|
||||
|| std::is_same_v<FromDataType, DataTypeInt64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTime64TransformSigned<typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
}
|
||||
else if constexpr (std::is_same_v<FromDataType, DataTypeUInt64>
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTime64TransformUnsigned<UInt64, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
@ -1298,23 +1287,20 @@ struct ConvertImpl
|
||||
else if constexpr ((
|
||||
std::is_same_v<FromDataType, DataTypeFloat32>
|
||||
|| std::is_same_v<FromDataType, DataTypeFloat64>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTime64TransformFloat<FromDataType, typename FromDataType::FieldType, default_date_time_overflow_behavior>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
}
|
||||
/// Conversion of DateTime64 to Date or DateTime: discards fractional part.
|
||||
else if constexpr (std::is_same_v<FromDataType, DataTypeDateTime64>
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDate>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, TransformDateTime64<ToDateImpl<date_time_overflow_behavior>>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
}
|
||||
else if constexpr (std::is_same_v<FromDataType, DataTypeDateTime64>
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, TransformDateTime64<ToDateTimeImpl<date_time_overflow_behavior>>, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
@ -1324,8 +1310,7 @@ struct ConvertImpl
|
||||
std::is_same_v<FromDataType, DataTypeDate>
|
||||
|| std::is_same_v<FromDataType, DataTypeDate32>
|
||||
|| std::is_same_v<FromDataType, DataTypeDateTime>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<ToDataType, DataTypeDateTime64>)
|
||||
{
|
||||
return DateTimeTransformImpl<FromDataType, ToDataType, ToDateTime64Transform, false>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
@ -1443,8 +1428,7 @@ struct ConvertImpl
|
||||
/// Conversion from FixedString to String.
|
||||
/// Cutting sequences of zero bytes from end of strings.
|
||||
else if constexpr (std::is_same_v<ToDataType, DataTypeString>
|
||||
&& std::is_same_v<FromDataType, DataTypeFixedString>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
&& std::is_same_v<FromDataType, DataTypeFixedString>)
|
||||
{
|
||||
ColumnUInt8::MutablePtr null_map = copyNullMap(arguments[0].column);
|
||||
const auto & nested = columnGetNested(arguments[0]);
|
||||
@ -1488,8 +1472,7 @@ struct ConvertImpl
|
||||
throw Exception(ErrorCodes::ILLEGAL_COLUMN, "Illegal column {} of first argument of function {}",
|
||||
arguments[0].column->getName(), Name::name);
|
||||
}
|
||||
else if constexpr (std::is_same_v<ToDataType, DataTypeString>
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
else if constexpr (std::is_same_v<ToDataType, DataTypeString>)
|
||||
{
|
||||
/// Anything else to String.
|
||||
|
||||
@ -1550,27 +1533,35 @@ struct ConvertImpl
|
||||
&& std::is_same_v<FromDataType, DataTypeString>
|
||||
&& std::is_same_v<ToDataType, DataTypeUInt32>)
|
||||
{
|
||||
return ConvertImpl<FromDataType, DataTypeDateTime, Name, SpecialTag, date_time_overflow_behavior>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count);
|
||||
return ConvertImpl<FromDataType, DataTypeDateTime, Name, date_time_overflow_behavior>::template execute<Additions>(
|
||||
arguments, result_type, input_rows_count, from_string_tag);
|
||||
}
|
||||
else if constexpr ((std::is_same_v<FromDataType, DataTypeString> || std::is_same_v<FromDataType, DataTypeFixedString>)
|
||||
&& std::is_same_v<SpecialTag, ConvertDefaultBehaviorTag>)
|
||||
else if constexpr ((std::is_same_v<FromDataType, DataTypeString> || std::is_same_v<FromDataType, DataTypeFixedString>))
|
||||
{
|
||||
return ConvertThroughParsing<FromDataType, ToDataType, Name, ConvertFromStringExceptionMode::Throw, ConvertFromStringParsingMode::Normal>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
}
|
||||
else if constexpr ((std::is_same_v<FromDataType, DataTypeString> || std::is_same_v<FromDataType, DataTypeFixedString>)
|
||||
&& std::is_same_v<SpecialTag, ConvertReturnNullOnErrorTag>)
|
||||
{
|
||||
return ConvertThroughParsing<FromDataType, ToDataType, Name, ConvertFromStringExceptionMode::Null, ConvertFromStringParsingMode::Normal>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
}
|
||||
else if constexpr ((std::is_same_v<FromDataType, DataTypeString> || std::is_same_v<FromDataType, DataTypeFixedString>)
|
||||
&& is_any_of<ToDataType, DataTypeIPv4, DataTypeIPv6>
|
||||
&& std::is_same_v<SpecialTag, ConvertReturnZeroOnErrorTag>)
|
||||
{
|
||||
return ConvertThroughParsing<FromDataType, ToDataType, Name, ConvertFromStringExceptionMode::Zero, ConvertFromStringParsingMode::Normal>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
switch (from_string_tag)
|
||||
{
|
||||
case BehaviourOnErrorFromString::ConvertDefaultBehaviorTag:
|
||||
return ConvertThroughParsing<FromDataType,
|
||||
ToDataType,
|
||||
Name,
|
||||
ConvertFromStringExceptionMode::Throw,
|
||||
ConvertFromStringParsingMode::Normal>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
case BehaviourOnErrorFromString::ConvertReturnNullOnErrorTag:
|
||||
return ConvertThroughParsing<FromDataType,
|
||||
ToDataType,
|
||||
Name,
|
||||
ConvertFromStringExceptionMode::Null,
|
||||
ConvertFromStringParsingMode::Normal>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
case BehaviourOnErrorFromString::ConvertReturnZeroOnErrorTag:
|
||||
return ConvertThroughParsing<FromDataType,
|
||||
ToDataType,
|
||||
Name,
|
||||
ConvertFromStringExceptionMode::Zero,
|
||||
ConvertFromStringParsingMode::Normal>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
@ -2165,12 +2156,11 @@ private:
|
||||
if (context)
|
||||
date_time_overflow_behavior = context->getSettingsRef().date_time_overflow_behavior.value;
|
||||
|
||||
auto call = [&](const auto & types, const auto & tag) -> bool
|
||||
auto call = [&](const auto & types, BehaviourOnErrorFromString from_string_tag) -> bool
|
||||
{
|
||||
using Types = std::decay_t<decltype(types)>;
|
||||
using LeftDataType = typename Types::LeftType;
|
||||
using RightDataType = typename Types::RightType;
|
||||
using SpecialTag = std::decay_t<decltype(tag)>;
|
||||
|
||||
if constexpr (IsDataTypeDecimal<RightDataType>)
|
||||
{
|
||||
@ -2191,13 +2181,13 @@ private:
|
||||
switch (date_time_overflow_behavior)
|
||||
{
|
||||
case FormatSettings::DateTimeOverflowBehavior::Throw:
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::Throw>::execute(arguments, result_type, input_rows_count, scale);
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::Throw>::execute(arguments, result_type, input_rows_count, from_string_tag, scale);
|
||||
break;
|
||||
case FormatSettings::DateTimeOverflowBehavior::Ignore:
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::Ignore>::execute(arguments, result_type, input_rows_count, scale);
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::Ignore>::execute(arguments, result_type, input_rows_count, from_string_tag, scale);
|
||||
break;
|
||||
case FormatSettings::DateTimeOverflowBehavior::Saturate:
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::Saturate>::execute(arguments, result_type, input_rows_count, scale);
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::Saturate>::execute(arguments, result_type, input_rows_count, from_string_tag, scale);
|
||||
break;
|
||||
}
|
||||
|
||||
@ -2208,20 +2198,20 @@ private:
|
||||
switch (date_time_overflow_behavior)
|
||||
{
|
||||
case FormatSettings::DateTimeOverflowBehavior::Throw:
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::Throw>::execute(arguments, result_type, input_rows_count, dt64->getScale());
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::Throw>::execute(arguments, result_type, input_rows_count, from_string_tag, dt64->getScale());
|
||||
break;
|
||||
case FormatSettings::DateTimeOverflowBehavior::Ignore:
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::Ignore>::execute(arguments, result_type, input_rows_count, dt64->getScale());
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::Ignore>::execute(arguments, result_type, input_rows_count, from_string_tag, dt64->getScale());
|
||||
break;
|
||||
case FormatSettings::DateTimeOverflowBehavior::Saturate:
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::Saturate>::execute(arguments, result_type, input_rows_count, dt64->getScale());
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::Saturate>::execute(arguments, result_type, input_rows_count, from_string_tag, dt64->getScale());
|
||||
break;
|
||||
}
|
||||
}
|
||||
#define GENERATE_OVERFLOW_MODE_CASE(OVERFLOW_MODE) \
|
||||
case FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE: \
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag, FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE>::execute( \
|
||||
arguments, result_type, input_rows_count); \
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE>::execute( \
|
||||
arguments, result_type, input_rows_count, from_string_tag); \
|
||||
break;
|
||||
|
||||
else if constexpr (IsDataTypeDecimalOrNumber<LeftDataType> && IsDataTypeDecimalOrNumber<RightDataType>)
|
||||
@ -2262,7 +2252,7 @@ private:
|
||||
}
|
||||
#undef GENERATE_OVERFLOW_MODE_CASE
|
||||
else
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name, SpecialTag>::execute(arguments, result_type, input_rows_count);
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, Name>::execute(arguments, result_type, input_rows_count, from_string_tag);
|
||||
|
||||
return true;
|
||||
};
|
||||
@ -2275,7 +2265,7 @@ private:
|
||||
|
||||
if (to_datetime64 || scale != 0) /// When scale = 0, the data type is DateTime otherwise the data type is DateTime64
|
||||
{
|
||||
if (!callOnIndexAndDataType<DataTypeDateTime64>(from_type->getTypeId(), call, ConvertDefaultBehaviorTag{}))
|
||||
if (!callOnIndexAndDataType<DataTypeDateTime64>(from_type->getTypeId(), call, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag))
|
||||
throw Exception(ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT, "Illegal type {} of argument of function {}",
|
||||
arguments[0].type->getName(), getName());
|
||||
|
||||
@ -2292,23 +2282,25 @@ private:
|
||||
bool done = false;
|
||||
if constexpr (is_any_of<ToDataType, DataTypeString, DataTypeFixedString>)
|
||||
{
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, ConvertDefaultBehaviorTag{});
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag);
|
||||
}
|
||||
else
|
||||
{
|
||||
bool cast_ipv4_ipv6_default_on_conversion_error = false;
|
||||
if constexpr (is_any_of<ToDataType, DataTypeIPv4, DataTypeIPv6>)
|
||||
{
|
||||
if (context && (cast_ipv4_ipv6_default_on_conversion_error = context->getSettingsRef().cast_ipv4_ipv6_default_on_conversion_error))
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, ConvertReturnZeroOnErrorTag{});
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, BehaviourOnErrorFromString::ConvertReturnZeroOnErrorTag);
|
||||
}
|
||||
|
||||
if (!cast_ipv4_ipv6_default_on_conversion_error)
|
||||
{
|
||||
/// We should use ConvertFromStringExceptionMode::Null mode when converting from String (or FixedString)
|
||||
/// to Nullable type, to avoid 'value is too short' error on attempt to parse empty string from NULL values.
|
||||
if (to_nullable && WhichDataType(from_type).isStringOrFixedString())
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, ConvertReturnNullOnErrorTag{});
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, BehaviourOnErrorFromString::ConvertReturnNullOnErrorTag);
|
||||
else
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, ConvertDefaultBehaviorTag{});
|
||||
done = callOnIndexAndDataType<ToDataType>(from_type->getTypeId(), call, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag);
|
||||
}
|
||||
}
|
||||
|
||||
@ -3185,8 +3177,8 @@ private:
|
||||
{
|
||||
#define GENERATE_OVERFLOW_MODE_CASE(OVERFLOW_MODE, ADDITIONS) \
|
||||
case FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE: \
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName, ConvertDefaultBehaviorTag, FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE>::execute( \
|
||||
arguments, result_type, input_rows_count, ADDITIONS()); \
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName, FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE>::execute( \
|
||||
arguments, result_type, input_rows_count, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag, ADDITIONS()); \
|
||||
break;
|
||||
if (wrapper_cast_type == CastType::accurate)
|
||||
{
|
||||
@ -3215,8 +3207,8 @@ private:
|
||||
{
|
||||
#define GENERATE_OVERFLOW_MODE_CASE(OVERFLOW_MODE, ADDITIONS) \
|
||||
case FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE: \
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName, ConvertDefaultBehaviorTag, FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE>::template execute<ADDITIONS>( \
|
||||
arguments, result_type, input_rows_count); \
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName, FormatSettings::DateTimeOverflowBehavior::OVERFLOW_MODE>::template execute<ADDITIONS>( \
|
||||
arguments, result_type, input_rows_count, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag); \
|
||||
break;
|
||||
if (wrapper_cast_type == CastType::accurate)
|
||||
{
|
||||
@ -3376,7 +3368,7 @@ arguments, result_type, input_rows_count); \
|
||||
AccurateConvertStrategyAdditions additions;
|
||||
additions.scale = scale;
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
arguments, result_type, input_rows_count, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag, additions);
|
||||
|
||||
return true;
|
||||
}
|
||||
@ -3385,7 +3377,7 @@ arguments, result_type, input_rows_count); \
|
||||
AccurateOrNullConvertStrategyAdditions additions;
|
||||
additions.scale = scale;
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName>::execute(
|
||||
arguments, result_type, input_rows_count, additions);
|
||||
arguments, result_type, input_rows_count, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag, additions);
|
||||
|
||||
return true;
|
||||
}
|
||||
@ -3397,14 +3389,14 @@ arguments, result_type, input_rows_count); \
|
||||
/// Consistent with CAST(Nullable(String) AS Nullable(Numbers))
|
||||
/// In case when converting to Nullable type, we apply different parsing rule,
|
||||
/// that will not throw an exception but return NULL in case of malformed input.
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName, ConvertReturnNullOnErrorTag>::execute(
|
||||
arguments, result_type, input_rows_count, scale);
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName>::execute(
|
||||
arguments, result_type, input_rows_count, BehaviourOnErrorFromString::ConvertReturnNullOnErrorTag, scale);
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName>::execute(arguments, result_type, input_rows_count, scale);
|
||||
result_column = ConvertImpl<LeftDataType, RightDataType, FunctionCastName>::execute(arguments, result_type, input_rows_count, BehaviourOnErrorFromString::ConvertDefaultBehaviorTag, scale);
|
||||
|
||||
return true;
|
||||
});
|
||||
|
||||
Loading…
Reference in New Issue
Block a user