Merge 430eeee into 21bdc0e

Author: VPolka

ydb/core/kqp/session_actor/kqp_query_state.h

@@ -504,6 +504,10 @@ class TKqpQueryState : public TNonCopyable {
         }
     }
 
+    void PrepareCommitStatementsTransaction() {
+        TxCtx->EffectiveIsolationLevel = NKikimrKqp::ISOLATION_LEVEL_SERIALIZABLE;
+    }
+
     // validate the compiled query response and ensure that all table versions are not
     // changed since the last compilation.
      bool EnsureTableVersions(const TEvTxProxySchemeCache::TEvNavigateKeySetResult& response);

ydb/core/kqp/session_actor/kqp_session_actor.cpp

@@ -1180,6 +1180,9 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
             ProcessExecuterResult(response.get());
             return true;
         } else if (commit) {
+            if (QueryState->HasImplicitTx() && !QueryState->Commited) {
+                QueryState->PrepareCommitStatementsTransaction();
+            }
             QueryState->Commited = true;
 
             for (const auto& effect : txCtx.DeferredEffects) {

ydb/core/kqp/ut/service/kqp_qs_queries_ut.cpp

@@ -2313,6 +2313,10 @@ Y_UNIT_TEST_SUITE(KqpQueryService) {
                 ALTER TABLE TestDdlDml2 DROP COLUMN Value2;
                 UPSERT INTO TestDdlDml2 (Key, Value1) VALUES (2, "2");
                 SELECT * FROM TestDdlDml2;
+                CREATE TABLE TestDdlDml33 (
+                    Key Uint64,
+                    PRIMARY KEY (Key)
+                );
             )", TTxControl::NoTx()).ExtractValueSync();
             UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
             UNIT_ASSERT_VALUES_EQUAL(result.GetResultSets().size(), 2);