Skip to content

Commit

Permalink
Fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
shnikd committed Feb 14, 2025
1 parent 1eaad6c commit 9553004
Show file tree
Hide file tree
Showing 3 changed files with 20 additions and 15 deletions.
13 changes: 10 additions & 3 deletions ydb/core/kqp/ut/query/kqp_query_ut.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -211,10 +211,13 @@ Y_UNIT_TEST_SUITE(KqpQuery) {

UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString().c_str());

UNIT_ASSERT_C(!result.GetMeta().empty(), "Query result meta is empty");
auto stats = result.GetStats();
UNIT_ASSERT(stats.has_value());

UNIT_ASSERT_C(stats->GetMeta().has_value(), "Query result meta is empty");

TStringStream in;
in << result.GetMeta();
in << stats->GetMeta().value();
NJson::TJsonValue value;
ReadJsonTree(&in, &value);

Expand All @@ -234,12 +237,16 @@ Y_UNIT_TEST_SUITE(KqpQuery) {

{
auto settings = TExecDataQuerySettings();
settings.CollectQueryStats(ECollectQueryStatsMode::Basic);

auto result = session.ExecuteDataQuery(query, TTxControl::BeginTx().CommitTx(), settings).ExtractValueSync();

UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString().c_str());

UNIT_ASSERT_C(result.GetMeta().empty(), "Query result meta should be empty, but it's not");
auto stats = result.GetStats();
UNIT_ASSERT(stats.has_value());

UNIT_ASSERT_C(!stats->GetMeta().has_value(), "Query result meta should be empty, but it's not");
}
}
}
Expand Down
14 changes: 10 additions & 4 deletions ydb/public/sdk/cpp/include/ydb-cpp-sdk/client/table/table.h
Original file line number Diff line number Diff line change
Expand Up @@ -1163,8 +1163,10 @@ struct TStreamExecScanQuerySettings : public TRequestSettings<TStreamExecScanQue

// Collect runtime statistics with a given detalization mode
FLUENT_SETTING_DEFAULT(ECollectQueryStatsMode, CollectQueryStats, ECollectQueryStatsMode::None);
// // Collect full query compilation diagnostics
// FLUENT_SETTING_DEFAULT_DEPRECATED(bool, CollectFullDiagnostics, false);

//Deprecated. Use CollectQueryStats >= ECollectQueryStatsMode::Full to get QueryMeta in QueryStats
// Collect full query compilation diagnostics
FLUENT_SETTING_DEFAULT(bool, CollectFullDiagnostics, false);
};

enum class EDataFormat {
Expand Down Expand Up @@ -2036,8 +2038,6 @@ class TDataQueryResult : public TStatus {

const std::string GetQueryPlan() const;

const std::string GetMeta() const;

private:
std::optional<TTransaction> Transaction_;
std::vector<TResultSet> ResultSets_;
Expand Down Expand Up @@ -2110,6 +2110,11 @@ class TScanQueryPart : public TStreamPartStatus {
const TQueryStats& GetQueryStats() const { return *QueryStats_; }
TQueryStats ExtractQueryStats() { return std::move(*QueryStats_); }

// Deprecated. Use GetMeta() of TQueryStats
bool HasDiagnostics() const { return FakeDiagnostics_.has_value(); }
const std::string& GetDiagnostics() const { return *FakeDiagnostics_; }
std::string&& ExtractDiagnostics() { return std::move(*FakeDiagnostics_); }

TScanQueryPart(TStatus&& status)
: TStreamPartStatus(std::move(status))
{}
Expand All @@ -2128,6 +2133,7 @@ class TScanQueryPart : public TStreamPartStatus {
private:
std::optional<TResultSet> ResultSet_;
std::optional<TQueryStats> QueryStats_;
std::optional<std::string> FakeDiagnostics_;
};

using TAsyncScanQueryPart = NThreading::TFuture<TScanQueryPart>;
Expand Down
8 changes: 0 additions & 8 deletions ydb/public/sdk/cpp/src/client/table/table.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2220,14 +2220,6 @@ const std::string TDataQueryResult::GetQueryPlan() const {
}
}

const std::string TDataQueryResult::GetMeta() const {
if (QueryStats_.has_value()) {
return NYdb::TProtoAccessor::GetProto(*QueryStats_).query_meta();
} else {
return "";
}
}

////////////////////////////////////////////////////////////////////////////////

TBeginTransactionResult::TBeginTransactionResult(TStatus&& status, TTransaction transaction)
Expand Down

0 comments on commit 9553004

Please sign in to comment.