@@ -50,38 +50,6 @@ Y_UNIT_TEST_SUITE(KqpDataIntegrityTrails) {
5050 UNIT_ASSERT_VALUES_EQUAL (CountSubstr (ss.Str (), " DATA_INTEGRITY INFO: Component: DataShard" ), LogEnabled ? 2 : 0 );
5151 }
5252
53- Y_UNIT_TEST (UpsertEvWrite) {
54- NKikimrConfig::TAppConfig AppConfig;
55- AppConfig.MutableTableServiceConfig ()->SetEnableOltpSink (true );
56- TKikimrSettings serverSettings = TKikimrSettings ().SetAppConfig (AppConfig);
57- TStringStream ss;
58- serverSettings.LogStream = &ss;
59- TKikimrRunner kikimr (serverSettings);
60- kikimr.GetTestServer ().GetRuntime ()->SetLogPriority (NKikimrServices::DATA_INTEGRITY, NLog::PRI_TRACE);
61-
62- auto db = kikimr.GetTableClient ();
63- auto session = db.CreateSession ().GetValueSync ().GetSession ();
64-
65- auto result = session.ExecuteDataQuery (R"(
66- --!syntax_v1
67-
68- UPSERT INTO `/Root/KeyValue` (Key, Value) VALUES
69- (3u, "Value3"),
70- (101u, "Value101"),
71- (201u, "Value201");
72- )" , TTxControl::BeginTx ().CommitTx ()).ExtractValueSync ();
73- UNIT_ASSERT_VALUES_EQUAL_C (result.GetStatus (), EStatus::SUCCESS, result.GetIssues ().ToString ());
74-
75- // check executer logs
76- UNIT_ASSERT_VALUES_EQUAL (CountSubstr (ss.Str (), " DATA_INTEGRITY INFO: Component: Executer" ), 2 );
77- // check session actor logs
78- UNIT_ASSERT_VALUES_EQUAL (CountSubstr (ss.Str (), " DATA_INTEGRITY DEBUG: Component: SessionActor" ), 2 );
79- // check grpc logs
80- UNIT_ASSERT_VALUES_EQUAL (CountSubstr (ss.Str (), " DATA_INTEGRITY TRACE: Component: Grpc" ), 2 );
81- // check datashard logs
82- UNIT_ASSERT_VALUES_EQUAL (CountSubstr (ss.Str (), " DATA_INTEGRITY INFO: Component: DataShard" ), 4 );
83- }
84-
8553 Y_UNIT_TEST (Ddl) {
8654 TKikimrSettings serverSettings;
8755 TStringStream ss;
0 commit comments