diff options
| author | uzhas <[email protected]> | 2023-09-17 12:41:52 +0300 |
|---|---|---|
| committer | uzhas <[email protected]> | 2023-09-17 12:55:50 +0300 |
| commit | ea822ade3aadc548db1bdbfd44b3aca12b4cf370 (patch) | |
| tree | 8b948eacff6ca4f4373e029d304c74a161cb66a1 | |
| parent | 05f35667cc0531fdeeadb4925bb101f6b25c9dfa (diff) | |
fix empty results for scan queries and via query service
| -rw-r--r-- | ydb/core/viewer/json_query.h | 7 |
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(); |
