@@ -4317,83 +4317,6 @@ Y_UNIT_TEST_SUITE(KqpQueryService) {
4317
4317
CompareYson (R"( [[1u;["test1"];10];[2u;["test2"];11];[3u;["test3"];12];[4u;#;13];[101u;["test1"];10];[102u;["test2"];11];[103u;["test3"];12];[104u;#;13]])" , FormatResultSetYson (result.GetResultSet (1 )));
4318
4318
}
4319
4319
}
4320
-
4321
- Y_UNIT_TEST (MixedReadQueryWithoutStreamLookup) {
4322
- NKikimrConfig::TAppConfig appConfig;
4323
- appConfig.MutableTableServiceConfig ()->SetEnableOlapSink (true );
4324
- appConfig.MutableTableServiceConfig ()->SetEnableOltpSink (false );
4325
- appConfig.MutableTableServiceConfig ()->SetEnableHtapTx (false );
4326
- appConfig.MutableTableServiceConfig ()->SetEnableKqpDataQueryStreamLookup (false );
4327
-
4328
- auto settings = TKikimrSettings ()
4329
- .SetAppConfig (appConfig)
4330
- .SetWithSampleTables (false );
4331
-
4332
- TKikimrRunner kikimr (settings);
4333
- Tests::NCommon::TLoggerInit (kikimr).Initialize ();
4334
-
4335
- auto client = kikimr.GetQueryClient ();
4336
-
4337
- {
4338
- auto createTable = client.ExecuteQuery (R"sql(
4339
- CREATE TABLE `/Root/DataShard` (
4340
- Col1 Uint64 NOT NULL,
4341
- Col2 Int32 NOT NULL,
4342
- Col3 String,
4343
- PRIMARY KEY (Col1, Col2)
4344
- ) WITH (STORE = ROW);
4345
- CREATE TABLE `/Root/ColumnShard` (
4346
- Col1 Uint64 NOT NULL,
4347
- Col2 Int32 NOT NULL,
4348
- Col3 String,
4349
- PRIMARY KEY (Col1, Col2)
4350
- ) WITH (STORE = COLUMN);
4351
- )sql" , NYdb::NQuery::TTxControl::NoTx ()).ExtractValueSync ();
4352
- UNIT_ASSERT_C (createTable.IsSuccess (), createTable.GetIssues ().ToString ());
4353
- }
4354
-
4355
- {
4356
- auto replaceValues = client.ExecuteQuery (R"sql(
4357
- REPLACE INTO `/Root/DataShard` (Col1, Col2, Col3) VALUES
4358
- (1u, 1, "row"), (1u, 2, "row"), (1u, 3, "row"), (2u, 3, "row");
4359
- )sql" , NYdb::NQuery::TTxControl::BeginTx ().CommitTx ()).ExtractValueSync ();
4360
- UNIT_ASSERT_C (replaceValues.IsSuccess (), replaceValues.GetIssues ().ToString ());
4361
- }
4362
- {
4363
- auto replaceValues = client.ExecuteQuery (R"sql(
4364
- REPLACE INTO `/Root/ColumnShard` (Col1, Col2, Col3) VALUES
4365
- (1u, 1, "row"), (1u, 2, "row"), (1u, 3, "row"), (2u, 3, "row");
4366
- )sql" , NYdb::NQuery::TTxControl::BeginTx ().CommitTx ()).ExtractValueSync ();
4367
- UNIT_ASSERT_C (replaceValues.IsSuccess (), replaceValues.GetIssues ().ToString ());
4368
- }
4369
-
4370
- {
4371
- auto it = client.StreamExecuteQuery (R"sql(
4372
- SELECT Col3 FROM `/Root/DataShard` WHERE Col1 = 1u
4373
- UNION ALL
4374
- SELECT Col3 FROM `/Root/ColumnShard` WHERE Col1 = 1u;
4375
- )sql" , NYdb::NQuery::TTxControl::BeginTx ().CommitTx ()).ExtractValueSync ();
4376
- UNIT_ASSERT_VALUES_EQUAL_C (it.GetStatus (), EStatus::SUCCESS, it.GetIssues ().ToString ());
4377
- TString output = StreamResultToYson (it);
4378
- CompareYson (
4379
- output,
4380
- R"( [[["row"]];[["row"]];[["row"]];[["row"]];[["row"]];[["row"]]])" );
4381
- }
4382
-
4383
- {
4384
- auto it = client.StreamExecuteQuery (R"sql(
4385
- SELECT r.Col3
4386
- FROM `/Root/DataShard` AS r
4387
- JOIN `/Root/ColumnShard` AS c
4388
- ON r.Col1 = c.Col1;
4389
- )sql" , NYdb::NQuery::TTxControl::BeginTx ().CommitTx ()).ExtractValueSync ();
4390
- UNIT_ASSERT_VALUES_EQUAL_C (it.GetStatus (), EStatus::SUCCESS, it.GetIssues ().ToString ());
4391
- TString output = StreamResultToYson (it);
4392
- CompareYson (
4393
- output,
4394
- R"( [[["row"]];[["row"]];[["row"]];[["row"]];[["row"]];[["row"]];[["row"]];[["row"]];[["row"]];[["row"]]])" );
4395
- }
4396
- }
4397
4320
}
4398
4321
4399
4322
} // namespace NKqp
0 commit comments