diff options
| author | makostrov <makostrov@yandex-team.com> | 2023-08-15 15:19:56 +0300 |
|---|---|---|
| committer | makostrov <makostrov@yandex-team.com> | 2023-08-15 16:37:53 +0300 |
| commit | bd4e4740d96a4d79f791576a730e251eb36db67c (patch) | |
| tree | 8f864daba5d94c3c7f476a076997a5932e0ab23d | |
| parent | 80fd37f8194119c843bb6dceb987700322740234 (diff) | |
| download | ydb-bd4e4740d96a4d79f791576a730e251eb36db67c.tar.gz | |
PR from branch users/makostrov/remove_mkql_from_pgwire
| -rw-r--r-- | ydb/core/local_pgwire/pgwire_kqp_proxy.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp b/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp index c4b65cf170..5ab2fd4bf1 100644 --- a/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp +++ b/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp @@ -178,6 +178,7 @@ public: // HACK ConvertQueryToRequest(query, request); + request.SetUsePublicResponseDataFormat(true); if (request.HasAction()) { ActorIdToProto(SelfId(), event->Record.MutableRequestActorId()); BLOG_D("Sent event to kqpProxy " << request.ShortDebugString()); @@ -245,7 +246,7 @@ public: try { if (record.HasYdbStatus()) { if (record.GetYdbStatus() == Ydb::StatusIds::SUCCESS) { - BLOG_ENSURE(record.GetResponse().GetResults().empty()); + BLOG_ENSURE(record.GetResponse().GetYdbResults().empty()); // HACK if (response->Tag == "SELECT") { @@ -389,6 +390,7 @@ public: // HACK ConvertQueryToRequest(Statement_.QueryData.Query, request); + request.SetUsePublicResponseDataFormat(true); if (request.HasAction()) { for (unsigned int paramNum = 0; paramNum < Statement_.BindData.ParametersValue.size(); ++paramNum) { if (paramNum >= Statement_.ParameterTypes.size()) { @@ -447,7 +449,7 @@ public: try { if (record.HasYdbStatus()) { if (record.GetYdbStatus() == Ydb::StatusIds::SUCCESS) { - BLOG_ENSURE(record.GetResponse().GetResults().empty()); + BLOG_ENSURE(record.GetResponse().GetYdbResults().empty()); // HACK if (response->Tag == "SELECT") { |