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.
104 lines
2.9 KiB
C++
104 lines
2.9 KiB
C++
#include "../columns/itemview.h"
|
|
|
|
#include <algorithm>
|
|
#include <sstream>
|
|
|
|
namespace {
|
|
|
|
template <typename Container>
|
|
std::string ContainerToString(Container container, const char * separator = ", ") {
|
|
std::stringstream sstr;
|
|
const auto end = std::end(container);
|
|
for (auto i = std::begin(container); i != end; /*intentionally no ++i*/) {
|
|
const auto & elem = *i;
|
|
sstr << elem;
|
|
|
|
if (++i != end) {
|
|
sstr << separator;
|
|
}
|
|
}
|
|
|
|
return sstr.str();
|
|
}
|
|
|
|
}
|
|
|
|
namespace datastore {
|
|
|
|
void ItemView::ValidateData(Type::Code type, DataType data) {
|
|
|
|
auto AssertSize = [type, &data](std::initializer_list<int> allowed_sizes) -> void {
|
|
const auto end = std::end(allowed_sizes);
|
|
if (std::find(std::begin(allowed_sizes), end, static_cast<int>(data.size())) == end) {
|
|
throw AssertionError(std::string("ItemView value size mismatch for ")
|
|
+ Type::TypeName(type)
|
|
+ " expected: " + ContainerToString(allowed_sizes, " or ")
|
|
+ ", got: " + std::to_string(data.size()));
|
|
}
|
|
};
|
|
|
|
switch (type) {
|
|
case Type::Code::Void:
|
|
return AssertSize({0});
|
|
|
|
case Type::Code::Int8:
|
|
case Type::Code::UInt8:
|
|
case Type::Code::Enum8:
|
|
case Type::Code::Bool:
|
|
return AssertSize({1});
|
|
|
|
case Type::Code::Int16:
|
|
case Type::Code::UInt16:
|
|
case Type::Code::Date:
|
|
case Type::Code::Enum16:
|
|
return AssertSize({2});
|
|
|
|
case Type::Code::Int32:
|
|
case Type::Code::UInt32:
|
|
case Type::Code::Float32:
|
|
case Type::Code::DateTime:
|
|
case Type::Code::Date32:
|
|
case Type::Code::IPv4:
|
|
case Type::Code::Decimal32:
|
|
case Type::Code::Time:
|
|
return AssertSize({4});
|
|
|
|
case Type::Code::Int64:
|
|
case Type::Code::UInt64:
|
|
case Type::Code::Float64:
|
|
case Type::Code::DateTime64:
|
|
case Type::Code::Decimal64:
|
|
case Type::Code::Time64:
|
|
return AssertSize({8});
|
|
|
|
case Type::Code::String:
|
|
case Type::Code::FixedString:
|
|
case Type::Code::JSON:
|
|
// value can be of any size
|
|
return;
|
|
|
|
case Type::Code::Array:
|
|
case Type::Code::Nullable:
|
|
case Type::Code::Tuple:
|
|
case Type::Code::LowCardinality:
|
|
case Type::Code::Map:
|
|
throw AssertionError("Unsupported type in ItemView: " + std::string(Type::TypeName(type)));
|
|
|
|
case Type::Code::IPv6:
|
|
case Type::Code::UUID:
|
|
case Type::Code::UInt128:
|
|
case Type::Code::Int128:
|
|
case Type::Code::Decimal128:
|
|
return AssertSize({16});
|
|
|
|
case Type::Code::Decimal:
|
|
// Could be either Decimal32, Decimal64 or Decimal128
|
|
return AssertSize({4, 8, 16});
|
|
|
|
default:
|
|
throw UnimplementedError("Unknown type code:" + std::to_string(static_cast<int>(type)));
|
|
}
|
|
}
|
|
|
|
}
|