You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-10-30 07:25:34 +03:00
1022 lines
30 KiB
C++
1022 lines
30 KiB
C++
/* Copyright (C) 2014 InfiniDB, Inc.
|
|
Copyright (C) 2019 MariaDB Corporation
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; version 2 of
|
|
the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
|
|
MA 02110-1301, USA. */
|
|
|
|
// $Id: functor_str.h 3923 2013-06-19 21:43:06Z bwilkinson $
|
|
|
|
/** @file */
|
|
|
|
#pragma once
|
|
|
|
#include "functor.h"
|
|
#include "sql_crypt.h"
|
|
|
|
namespace funcexp
|
|
{
|
|
/** @brief Func_Str class
|
|
* For function that returns a string result.
|
|
* Must implement getStrVal()
|
|
* Implement any other methods that behave differently from the default.
|
|
*/
|
|
class Func_Str : public Func
|
|
{
|
|
public:
|
|
Func_Str() = default;
|
|
explicit Func_Str(const std::string& funcName) : Func(funcName)
|
|
{
|
|
}
|
|
~Func_Str() override = default;
|
|
|
|
int64_t getIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
return atoll(getStrVal(row, fp, isNull, op_ct).c_str());
|
|
}
|
|
|
|
double getDoubleVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
return strtod(getStrVal(row, fp, isNull, op_ct).c_str(), nullptr);
|
|
}
|
|
|
|
long double getLongDoubleVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
return strtold(getStrVal(row, fp, isNull, op_ct).c_str(), nullptr);
|
|
}
|
|
|
|
#if 0
|
|
std::string getStrVal(rowgroup::Row& row,
|
|
FunctionParm& fp,
|
|
bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) = 0;
|
|
#endif
|
|
|
|
execplan::IDB_Decimal getDecimalVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
return execplan::IDB_Decimal(atoll(getStrVal(row, fp, isNull, op_ct).c_str()), 0, 0);
|
|
}
|
|
|
|
int32_t getDateIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
auto str = getStrVal(row, fp, isNull, op_ct);
|
|
return isNull ? 0 : stringToDate(str);
|
|
}
|
|
|
|
int64_t getDatetimeIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
auto str = getStrVal(row, fp, isNull, op_ct);
|
|
return isNull ? 0 : stringToDatetime(str);
|
|
}
|
|
|
|
int64_t getTimestampIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
auto str = getStrVal(row, fp, isNull, op_ct);
|
|
return (isNull ? 0 : stringToTimestamp(str, op_ct.getTimeZone()));
|
|
}
|
|
|
|
int64_t getTimeIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override
|
|
{
|
|
auto str = getStrVal(row, fp, isNull, op_ct);
|
|
return (isNull ? 0 : stringToTime(str));
|
|
}
|
|
|
|
protected:
|
|
void stringValue(execplan::SPTP& fp, rowgroup::Row& row, bool& isNull, std::string& fFloatStr)
|
|
{
|
|
// Bug3788, use the shorter of fixed or scientific notation for floating point values.
|
|
// [ the default format in treenode.h is fixed-point notation ]
|
|
char buf[20];
|
|
long double floatVal;
|
|
int exponent;
|
|
long double base;
|
|
|
|
switch (fp->data()->resultType().colDataType)
|
|
{
|
|
case execplan::CalpontSystemCatalog::LONGDOUBLE:
|
|
floatVal = fp->data()->getLongDoubleVal(row, isNull);
|
|
break;
|
|
|
|
case execplan::CalpontSystemCatalog::DOUBLE: floatVal = fp->data()->getDoubleVal(row, isNull); break;
|
|
|
|
case execplan::CalpontSystemCatalog::FLOAT: floatVal = fp->data()->getFloatVal(row, isNull); break;
|
|
|
|
default: fFloatStr = fp->data()->getStrVal(row, isNull).safeString(""); return;
|
|
}
|
|
|
|
if (isNull)
|
|
{
|
|
return;
|
|
}
|
|
|
|
exponent = (int)floor(log10(fabsl(floatVal)));
|
|
base = floatVal * pow(10, -1.0 * exponent);
|
|
|
|
if (std::isnan(exponent) || std::isnan(base))
|
|
{
|
|
snprintf(buf, sizeof(buf), "%Lf", floatVal);
|
|
fFloatStr = execplan::removeTrailing0(buf, sizeof(buf));
|
|
}
|
|
else
|
|
{
|
|
snprintf(buf, sizeof(buf), "%.5Lf", base);
|
|
fFloatStr = execplan::removeTrailing0(buf, sizeof(buf));
|
|
snprintf(buf, sizeof(buf), "e%02d", exponent);
|
|
fFloatStr += buf;
|
|
}
|
|
}
|
|
};
|
|
|
|
/** @brief Func_concat class
|
|
*/
|
|
class Func_concat : public Func_Str
|
|
{
|
|
public:
|
|
Func_concat() : Func_Str("concat")
|
|
{
|
|
}
|
|
~Func_concat() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_concat_oracle class
|
|
*/
|
|
class Func_concat_oracle : public Func_Str
|
|
{
|
|
public:
|
|
Func_concat_oracle() : Func_Str("concat_operator_oracle")
|
|
{
|
|
}
|
|
~Func_concat_oracle() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_substr class
|
|
*/
|
|
class Func_substr : public Func_Str
|
|
{
|
|
public:
|
|
Func_substr() : Func_Str("substr")
|
|
{
|
|
}
|
|
~Func_substr() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_date_format class
|
|
*/
|
|
class Func_date_format : public Func_Str
|
|
{
|
|
public:
|
|
Func_date_format() : Func_Str("date_format")
|
|
{
|
|
}
|
|
~Func_date_format() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int32_t getDateIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getDatetimeIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getTimestampIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_lcase class
|
|
*/
|
|
class Func_lcase : public Func_Str
|
|
{
|
|
public:
|
|
Func_lcase() : Func_Str("lcase")
|
|
{
|
|
}
|
|
~Func_lcase() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_ucase class
|
|
*/
|
|
class Func_ucase : public Func_Str
|
|
{
|
|
public:
|
|
Func_ucase() : Func_Str("ucase")
|
|
{
|
|
}
|
|
~Func_ucase() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_left class
|
|
*/
|
|
class Func_left : public Func_Str
|
|
{
|
|
public:
|
|
Func_left() : Func_Str("left")
|
|
{
|
|
}
|
|
~Func_left() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_ltrim class
|
|
*/
|
|
class Func_ltrim : public Func_Str
|
|
{
|
|
public:
|
|
Func_ltrim() : Func_Str("ltrim")
|
|
{
|
|
}
|
|
~Func_ltrim() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_rtrim class
|
|
*/
|
|
class Func_rtrim : public Func_Str
|
|
{
|
|
public:
|
|
Func_rtrim() : Func_Str("rtrim")
|
|
{
|
|
}
|
|
~Func_rtrim() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_trim class
|
|
*/
|
|
class Func_trim : public Func_Str
|
|
{
|
|
public:
|
|
Func_trim() : Func_Str("trim")
|
|
{
|
|
}
|
|
~Func_trim() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_ltrim class
|
|
*/
|
|
class Func_ltrim_oracle : public Func_Str
|
|
{
|
|
public:
|
|
Func_ltrim_oracle() : Func_Str("ltrim_oracle")
|
|
{
|
|
}
|
|
~Func_ltrim_oracle() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_rtrim class
|
|
*/
|
|
class Func_rtrim_oracle : public Func_Str
|
|
{
|
|
public:
|
|
Func_rtrim_oracle() : Func_Str("rtrim_oracle")
|
|
{
|
|
}
|
|
~Func_rtrim_oracle() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_trim class
|
|
*/
|
|
class Func_trim_oracle : public Func_Str
|
|
{
|
|
public:
|
|
Func_trim_oracle() : Func_Str("trim_oracle")
|
|
{
|
|
}
|
|
~Func_trim_oracle() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_lpad class
|
|
*/
|
|
class Func_lpad : public Func_Str
|
|
{
|
|
static const std::string fPad;
|
|
|
|
public:
|
|
Func_lpad() : Func_Str("lpad")
|
|
{
|
|
}
|
|
~Func_lpad() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_rpad class
|
|
*/
|
|
class Func_rpad : public Func_Str
|
|
{
|
|
static const std::string fPad;
|
|
|
|
public:
|
|
Func_rpad() : Func_Str("rpad")
|
|
{
|
|
}
|
|
~Func_rpad() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_replace class
|
|
*/
|
|
class Func_replace : public Func_Str
|
|
{
|
|
public:
|
|
Func_replace() : Func_Str("replace")
|
|
{
|
|
}
|
|
~Func_replace() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
class Func_regexp_replace : public Func_Str
|
|
{
|
|
public:
|
|
Func_regexp_replace() : Func_Str("regexp_replace")
|
|
{
|
|
}
|
|
~Func_regexp_replace() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
class Func_regexp_instr : public Func_Str
|
|
{
|
|
public:
|
|
Func_regexp_instr() : Func_Str("regexp_instr")
|
|
{
|
|
}
|
|
~Func_regexp_instr() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
class Func_regexp_substr : public Func_Str
|
|
{
|
|
public:
|
|
Func_regexp_substr() : Func_Str("regexp_substr")
|
|
{
|
|
}
|
|
~Func_regexp_substr() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
class Func_replace_oracle : public Func_Str
|
|
{
|
|
public:
|
|
Func_replace_oracle() : Func_Str("replace_oracle")
|
|
{
|
|
}
|
|
~Func_replace_oracle() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_right class
|
|
*/
|
|
class Func_right : public Func_Str
|
|
{
|
|
public:
|
|
Func_right() : Func_Str("right")
|
|
{
|
|
}
|
|
~Func_right() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_char class
|
|
*/
|
|
class Func_char : public Func_Str
|
|
{
|
|
public:
|
|
Func_char() : Func_Str("char")
|
|
{
|
|
}
|
|
~Func_char() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_cast_char class
|
|
*/
|
|
class Func_cast_char : public Func_Str
|
|
{
|
|
public:
|
|
Func_cast_char() : Func_Str("char")
|
|
{
|
|
}
|
|
~Func_cast_char() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_format class
|
|
*/
|
|
class Func_format : public Func_Str
|
|
{
|
|
public:
|
|
Func_format() : Func_Str("format")
|
|
{
|
|
}
|
|
~Func_format() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_conv class
|
|
*/
|
|
class Func_conv : public Func_Str
|
|
{
|
|
public:
|
|
Func_conv() : Func_Str("conv")
|
|
{
|
|
}
|
|
~Func_conv() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_md5 class
|
|
*/
|
|
class Func_md5 : public Func_Str
|
|
{
|
|
public:
|
|
Func_md5() : Func_Str("md5")
|
|
{
|
|
}
|
|
~Func_md5() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_unhex class
|
|
*/
|
|
class Func_unhex : public Func_Str
|
|
{
|
|
public:
|
|
Func_unhex() : Func_Str("unhex")
|
|
{
|
|
}
|
|
~Func_unhex() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_concat_ws class
|
|
*/
|
|
class Func_concat_ws : public Func_Str
|
|
{
|
|
public:
|
|
Func_concat_ws() : Func_Str("concat_ws")
|
|
{
|
|
}
|
|
~Func_concat_ws() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_monthname class
|
|
*/
|
|
class Func_monthname : public Func_Str
|
|
{
|
|
public:
|
|
Func_monthname() : Func_Str("monthname")
|
|
{
|
|
}
|
|
~Func_monthname() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
int64_t getIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
int64_t getIntValInternal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct);
|
|
|
|
double getDoubleVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
execplan::IDB_Decimal getDecimalVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int32_t getDateIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getDatetimeIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getTimestampIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_time_format class
|
|
*/
|
|
class Func_time_format : public Func_Str
|
|
{
|
|
public:
|
|
Func_time_format() : Func_Str("time_format")
|
|
{
|
|
}
|
|
~Func_time_format() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_sec_to_time class
|
|
*/
|
|
class Func_sec_to_time : public Func_Str
|
|
{
|
|
public:
|
|
Func_sec_to_time() : Func_Str("sec_to_time")
|
|
{
|
|
}
|
|
~Func_sec_to_time() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
int64_t getIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
double getDoubleVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
execplan::IDB_Decimal getDecimalVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_substring_index class
|
|
*/
|
|
class Func_substring_index : public Func_Str
|
|
{
|
|
public:
|
|
Func_substring_index() : Func_Str("substring_index")
|
|
{
|
|
}
|
|
~Func_substring_index() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_hex class
|
|
*/
|
|
class Func_hex : public Func_Str
|
|
{
|
|
public:
|
|
Func_hex() : Func_Str("hex")
|
|
{
|
|
}
|
|
~Func_hex() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_repeat class
|
|
*/
|
|
class Func_repeat : public Func_Str
|
|
{
|
|
public:
|
|
Func_repeat() : Func_Str("repeat")
|
|
{
|
|
}
|
|
~Func_repeat() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_inet_ntoa class to convert big-indian (network ordered) int to
|
|
* an ascii IP address
|
|
*/
|
|
class Func_inet_ntoa : public Func_Str
|
|
{
|
|
public:
|
|
Func_inet_ntoa() : Func_Str("inet_ntoa")
|
|
{
|
|
}
|
|
~Func_inet_ntoa() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
int64_t getIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
double getDoubleVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
bool getBoolVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
execplan::IDB_Decimal getDecimalVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int32_t getDateIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getDatetimeIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getTimestampIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
int64_t getTimeIntVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
private:
|
|
void convertNtoa(int64_t ipNum, std::string& ipString);
|
|
};
|
|
|
|
/** @brief Func_reverse class
|
|
*/
|
|
class Func_reverse : public Func_Str
|
|
{
|
|
public:
|
|
Func_reverse() : Func_Str("reverse")
|
|
{
|
|
}
|
|
~Func_reverse() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_insert class
|
|
*/
|
|
class Func_insert : public Func_Str
|
|
{
|
|
public:
|
|
Func_insert() : Func_Str("insert")
|
|
{
|
|
}
|
|
~Func_insert() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_maketime class
|
|
*/
|
|
class Func_maketime : public Func_Str
|
|
{
|
|
public:
|
|
Func_maketime() : Func_Str("maketime")
|
|
{
|
|
}
|
|
~Func_maketime() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_get_format class
|
|
*/
|
|
class Func_get_format : public Func_Str
|
|
{
|
|
public:
|
|
Func_get_format() : Func_Str("get_format")
|
|
{
|
|
}
|
|
~Func_get_format() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_elt class
|
|
*/
|
|
class Func_elt : public Func_Str
|
|
{
|
|
public:
|
|
Func_elt() : Func_Str("elt")
|
|
{
|
|
}
|
|
~Func_elt() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_sha class
|
|
*/
|
|
class Func_sha : public Func_Str
|
|
{
|
|
public:
|
|
Func_sha() : Func_Str("sha")
|
|
{
|
|
}
|
|
~Func_sha() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_idbpartition class
|
|
*/
|
|
class Func_idbpartition : public Func_Str
|
|
{
|
|
public:
|
|
Func_idbpartition() : Func_Str("idbpartition")
|
|
{
|
|
}
|
|
~Func_idbpartition() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_space class
|
|
*/
|
|
class Func_space : public Func_Str
|
|
{
|
|
public:
|
|
Func_space() : Func_Str("space")
|
|
{
|
|
}
|
|
~Func_space() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_quote class
|
|
*/
|
|
class Func_quote : public Func_Str
|
|
{
|
|
public:
|
|
Func_quote() : Func_Str("quote")
|
|
{
|
|
}
|
|
~Func_quote() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
};
|
|
|
|
/** @brief Func_encode class
|
|
*/
|
|
|
|
class Func_encode : public Func_Str
|
|
{
|
|
public:
|
|
Func_encode() : Func_Str("encode"), fSeeded(false), fSeeds{0, 0}
|
|
{
|
|
}
|
|
~Func_encode() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
void resetSeed()
|
|
{
|
|
fSeeded = false;
|
|
fSeeds[0] = 0;
|
|
fSeeds[1] = 0;
|
|
}
|
|
|
|
private:
|
|
void hash_password(ulong* result, const char* password, uint password_len);
|
|
bool fSeeded;
|
|
SQL_CRYPT sql_crypt;
|
|
ulong fSeeds[2];
|
|
};
|
|
|
|
/** @brief Func_encode class
|
|
*/
|
|
|
|
class Func_decode : public Func_Str
|
|
{
|
|
public:
|
|
Func_decode() : Func_Str("decode"), fSeeded(false), fSeeds{0, 0}
|
|
{
|
|
}
|
|
~Func_decode() override = default;
|
|
|
|
execplan::CalpontSystemCatalog::ColType operationType(
|
|
FunctionParm& fp, execplan::CalpontSystemCatalog::ColType& resultType) override;
|
|
|
|
std::string getStrVal(rowgroup::Row& row, FunctionParm& fp, bool& isNull,
|
|
execplan::CalpontSystemCatalog::ColType& op_ct) override;
|
|
|
|
void resetSeed()
|
|
{
|
|
fSeeded = false;
|
|
fSeeds[0] = 0;
|
|
fSeeds[1] = 0;
|
|
}
|
|
|
|
private:
|
|
void hash_password(ulong* result, const char* password, uint password_len);
|
|
bool fSeeded;
|
|
SQL_CRYPT sql_crypt;
|
|
ulong fSeeds[2];
|
|
};
|
|
|
|
} // namespace funcexp
|