diff options
author | xenoxeno <[email protected]> | 2023-08-15 12:04:58 +0300 |
---|---|---|
committer | xenoxeno <[email protected]> | 2023-08-15 13:27:17 +0300 |
commit | d90f268c68af2702de77fc5bf8a81923ca0ad8e2 (patch) | |
tree | 6e12d76c9e239c94003da4540b1be3f54b5bda58 | |
parent | 445c5470a2dc5586d6837112a9a31d0160b182ce (diff) |
fixing extra empty statement KIKIMR-19007
-rw-r--r-- | ydb/core/local_pgwire/local_pgwire_connection.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/core/local_pgwire/local_pgwire_connection.cpp b/ydb/core/local_pgwire/local_pgwire_connection.cpp index 3221d2de8fc..6a8c98f764c 100644 --- a/ydb/core/local_pgwire/local_pgwire_connection.cpp +++ b/ydb/core/local_pgwire/local_pgwire_connection.cpp @@ -67,6 +67,9 @@ public: std::vector<TString> statements; for (auto pStmt = stmtIter.Next(); pStmt != nullptr; pStmt = stmtIter.Next()) { + if (!statements.empty() && IsQueryEmpty(*pStmt)) { + continue; + } statements.push_back(*pStmt); } |