mirror of
https://github.com/hanzo-ds/cpp.git
synced 2026-10-30 20:31:26 +00:00
zeekay
286f257aae
Pure rename applied on top of upstream tag v2.6.2 (8d2415d6), not HEAD.
The fork was cut at 737145d = v2.6.2-57, which still declared version 2.6.2
in version.h; renaming there would have shipped 57 unreleased commits wearing
a 2.6.2 label. Reset to the tag first so this commit changes names only.
clickhouse/ -> datastore/ (public include root)
namespace clickhouse -> namespace datastore
CLICKHOUSE_CPP_VERSION -> DATASTORE_CPP_VERSION
clickhouse-cpp-lib/-ut -> datastore-cpp-lib/-ut (CMake, Bazel)
CH_MAP_BOOL_TO_UINT8 -> DS_MAP_BOOL_TO_UINT8
CLICKHOUSE_* -> DATASTORE_* (test env vars)
doc links -> docs.hanzo.ai/datastore
This client speaks the NATIVE binary protocol only - there is no HTTP path
and no X-ClickHouse-* header anywhere in it, so the header rename that the
HTTP clients required does not apply and nothing here was broken.
The one string that reaches the wire is CLIENT_NAME, sent by both SendHello
and SendQuery's ClientInfo from a single macro, and it lands in
system.query_log.client_name. Both sites still read the one macro, so they
stay consistent and the server's Hello/Query consistency check is satisfied.
Old rows keep the old name; that is a reporting discontinuity, not a
migration, since nothing keys on it.
CI is repointed at our own server: ghcr.io/hanzoai/datastore:26.2.3.2, the
image production runs. Its entrypoint honours DATASTORE_SKIP_USER_SETUP, not
the CLICKHOUSE_ spelling the compose file used, and its config lives in
/etc/hanzo-datastore-server. ci/docker-compose/config.xml is now layered in
as a config.d drop-in so the image keeps its own white-labelling. That file
and users.xml deliberately keep a <clickhouse> root: it must match the roots
of the drop-ins the image ships, and a mismatch fails silently - the server
logs "Merging bypassed" and starts with every drop-in discarded.
The remote-TLS suites used to default to the third-party host
play.clickhouse.com. They now read DATASTORE_SECURE*_HOST and skip when it is
unset rather than point at a host we do not run.
Dropped as upstream infrastructure with no meaning here: AI_POLICY.md
(upstream's policy about their codebase), .travis.yml (dead CI referencing a
third-party apt repo), cross-repo-bug-relay.yml (relays our issues into an
upstream triage repo). LICENSE keeps its copyright notice, as Apache-2.0
requires.
Verified: cmake configure + 115-target build clean; the full suite is green
against ghcr.io/hanzoai/datastore:26.2.3.2 (894 passed, 0 failed); the
pristine v2.6.2 build run against that same server passes the identical set,
and both logged the same 3914 queries under their respective client names.
110 lines
4.5 KiB
C++
110 lines
4.5 KiB
C++
#include <datastore/columns/bool.h>
|
|
#include <datastore/columns/factory.h>
|
|
#include <datastore/columns/date.h>
|
|
#include <datastore/columns/numeric.h>
|
|
#include <datastore/columns/string.h>
|
|
#include <datastore/columns/json.h>
|
|
|
|
#include <gtest/gtest.h>
|
|
|
|
namespace {
|
|
using namespace datastore;
|
|
}
|
|
|
|
TEST(CreateColumnByType, CreateSimpleAggregateFunction) {
|
|
auto col = CreateColumnByType("SimpleAggregateFunction(funt, Int32)");
|
|
|
|
ASSERT_EQ("Int32", col->Type()->GetName());
|
|
ASSERT_EQ(Type::Int32, col->Type()->GetCode());
|
|
ASSERT_NE(nullptr, col->As<ColumnInt32>());
|
|
}
|
|
|
|
TEST(CreateColumnByType, UnmatchedBrackets) {
|
|
// When type string has unmatched brackets, CreateColumnByType must return nullptr.
|
|
ASSERT_EQ(nullptr, CreateColumnByType("FixedString(10"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("Nullable(FixedString(10000"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("Nullable(FixedString(10000)"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("LowCardinality(Nullable(FixedString(10000"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("LowCardinality(Nullable(FixedString(10000)"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("LowCardinality(Nullable(FixedString(10000))"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("Array(LowCardinality(Nullable(FixedString(10000"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("Array(LowCardinality(Nullable(FixedString(10000)"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("Array(LowCardinality(Nullable(FixedString(10000))"));
|
|
ASSERT_EQ(nullptr, CreateColumnByType("Array(LowCardinality(Nullable(FixedString(10000)))"));
|
|
}
|
|
|
|
TEST(CreateColumnByType, LowCardinalityAsWrappedColumn) {
|
|
CreateColumnByTypeSettings create_column_settings;
|
|
create_column_settings.low_cardinality_as_wrapped_column = true;
|
|
|
|
ASSERT_EQ(Type::String, CreateColumnByType("LowCardinality(String)", create_column_settings)->GetType().GetCode());
|
|
ASSERT_EQ(Type::String, CreateColumnByType("LowCardinality(String)", create_column_settings)->As<ColumnString>()->GetType().GetCode());
|
|
|
|
ASSERT_EQ(Type::FixedString, CreateColumnByType("LowCardinality(FixedString(10000))", create_column_settings)->GetType().GetCode());
|
|
ASSERT_EQ(Type::FixedString, CreateColumnByType("LowCardinality(FixedString(10000))", create_column_settings)->As<ColumnFixedString>()->GetType().GetCode());
|
|
}
|
|
|
|
TEST(CreateColumnByType, DateTime) {
|
|
ASSERT_NE(nullptr, CreateColumnByType("DateTime"));
|
|
ASSERT_NE(nullptr, CreateColumnByType("DateTime('Europe/Moscow')"));
|
|
|
|
ASSERT_EQ(CreateColumnByType("DateTime('UTC')")->As<ColumnDateTime>()->Timezone(), "UTC");
|
|
ASSERT_EQ(CreateColumnByType("DateTime64(3, 'UTC')")->As<ColumnDateTime64>()->Timezone(), "UTC");
|
|
}
|
|
|
|
TEST(CreateColumnByType, AggregateFunction) {
|
|
EXPECT_EQ(nullptr, CreateColumnByType("AggregateFunction(argMax, Int32, DateTime64(3))"));
|
|
EXPECT_EQ(nullptr, CreateColumnByType("AggregateFunction(argMax, FIxedString(10), DateTime64(3, 'UTC'))"));
|
|
}
|
|
|
|
|
|
class CreateColumnByTypeWithName : public ::testing::TestWithParam<const char* /*Column Type String*/>
|
|
{};
|
|
|
|
TEST(CreateColumnByType, Bool) {
|
|
const auto col = CreateColumnByType("Bool");
|
|
ASSERT_NE(nullptr, col);
|
|
#if DS_MAP_BOOL_TO_UINT8
|
|
EXPECT_EQ(col->GetType().GetName(), "UInt8");
|
|
EXPECT_EQ(col->GetType().GetCode(), Type::UInt8);
|
|
EXPECT_NE(nullptr, col->As<ColumnUInt8>());
|
|
#else
|
|
EXPECT_EQ(col->GetType().GetName(), "Bool");
|
|
EXPECT_EQ(col->GetType().GetCode(), Type::Bool);
|
|
EXPECT_NE(nullptr, col->As<ColumnBool>());
|
|
#endif
|
|
}
|
|
|
|
TEST_P(CreateColumnByTypeWithName, CreateColumnByType)
|
|
{
|
|
const auto col = CreateColumnByType(GetParam());
|
|
ASSERT_NE(nullptr, col);
|
|
EXPECT_EQ(col->GetType().GetName(), GetParam());
|
|
}
|
|
|
|
INSTANTIATE_TEST_SUITE_P(Basic, CreateColumnByTypeWithName, ::testing::Values(
|
|
"Int8", "Int16", "Int32", "Int64",
|
|
"UInt8", "UInt16", "UInt32", "UInt64",
|
|
"String", "Date", "DateTime",
|
|
"UUID", "Int128", "UInt128"
|
|
));
|
|
#if !DS_MAP_BOOL_TO_UINT8
|
|
INSTANTIATE_TEST_SUITE_P(BasicBool, CreateColumnByTypeWithName, ::testing::Values("Bool"));
|
|
#endif
|
|
|
|
INSTANTIATE_TEST_SUITE_P(Parametrized, CreateColumnByTypeWithName, ::testing::Values(
|
|
"FixedString(0)", "FixedString(10000)",
|
|
"DateTime('UTC')", "DateTime64(3, 'UTC')",
|
|
"Decimal(9,3)", "Decimal(18,3)",
|
|
"Enum8('ONE' = 1, 'TWO' = 2)",
|
|
"Enum16('ONE' = 1, 'TWO' = 2, 'THREE' = 3, 'FOUR' = 4)"
|
|
));
|
|
|
|
|
|
INSTANTIATE_TEST_SUITE_P(Nested, CreateColumnByTypeWithName, ::testing::Values(
|
|
"Nullable(FixedString(10000))",
|
|
"Nullable(LowCardinality(FixedString(10000)))",
|
|
"Array(Nullable(LowCardinality(FixedString(10000))))",
|
|
"Array(Enum8('ONE' = 1, 'TWO' = 2))"
|
|
));
|