diff options
| author | xenoxeno <xeno@ydb.tech> | 2023-08-25 15:48:08 +0300 |
|---|---|---|
| committer | xenoxeno <xeno@ydb.tech> | 2023-08-25 16:08:54 +0300 |
| commit | db95400451e17b63d29a9f128f7a0f68718283e1 (patch) | |
| tree | a3410e70b490bb95550254569897251e418160f1 | |
| parent | efe6854ee705493580e853fa841afacc98a6a3c3 (diff) | |
| download | ydb-db95400451e17b63d29a9f128f7a0f68718283e1.tar.gz | |
fix commit for PG KIKIMR-19107
| -rw-r--r-- | ydb/core/local_pgwire/pgwire_kqp_proxy.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp b/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp index 6272fb73ea..d1bdc9cbcc 100644 --- a/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp +++ b/ydb/core/local_pgwire/pgwire_kqp_proxy.cpp @@ -79,10 +79,11 @@ protected: Tag_ = "BEGIN"; request.SetAction(NKikimrKqp::QUERY_ACTION_BEGIN_TX); request.MutableTxControl()->mutable_begin_tx()->mutable_serializable_read_write(); - } else if (q.StartsWith("COMMIT")) { + } else if (q.StartsWith("COMMIT") || q.StartsWith("END")) { Tag_ = "COMMIT"; request.SetAction(NKikimrKqp::QUERY_ACTION_COMMIT_TX); request.MutableTxControl()->set_tx_id(Connection_.Transaction.Id); + request.MutableTxControl()->set_commit_tx(true); } else if (q.StartsWith("ROLLBACK")) { Tag_ = "ROLLBACK"; if (Connection_.Transaction.Status == 'T') { |