summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoruzhas <[email protected]>2023-09-17 12:41:52 +0300
committeruzhas <[email protected]>2023-09-17 12:55:50 +0300
commitea822ade3aadc548db1bdbfd44b3aca12b4cf370 (patch)
tree8b948eacff6ca4f4373e029d304c74a161cb66a1
parent05f35667cc0531fdeeadb4925bb101f6b25c9dfa (diff)
fix empty results for scan queries and via query service
-rw-r--r--ydb/core/viewer/json_query.h7
1 files changed, 6 insertions, 1 deletions
diff --git a/ydb/core/viewer/json_query.h b/ydb/core/viewer/json_query.h
index 21a8907386e..422e5a7916b 100644
--- a/ydb/core/viewer/json_query.h
+++ b/ydb/core/viewer/json_query.h
@@ -392,6 +392,7 @@ private:
} else {
TEvViewer::TEvViewerResponse* response = new TEvViewer::TEvViewerResponse();
response->Record.MutableQueryResponse()->CopyFrom(record);
+ response->Record.MutableQueryResponse()->MutableResponse()->MutableYdbResults()->Add(ResultSets.begin(), ResultSets.end());
ReplyAndPassAway(response);
}
}
@@ -473,13 +474,17 @@ private:
void MakeOkReply(TStringBuilder& out, NJson::TJsonValue& jsonResponse, NKikimrKqp::TEvQueryResponse& record) {
const auto& response = record.GetResponse();
- if (response.ResultsSize() > 0) {
+ if (response.ResultsSize() > 0 || response.YdbResultsSize() > 0) {
try {
for (const auto& result : response.GetResults()) {
Ydb::ResultSet resultSet;
NKqp::ConvertKqpQueryResultToDbResult(result, &resultSet);
ResultSets.emplace_back(std::move(resultSet));
}
+
+ for (const auto& result : response.GetYdbResults()) {
+ ResultSets.emplace_back(result);
+ }
}
catch (const std::exception& ex) {
Ydb::Issue::IssueMessage* issue = record.MutableResponse()->AddQueryIssues();