From b651b0c44739411acfe1a9739e9a917dc69a2ea6 Mon Sep 17 00:00:00 2001 From: Grigoriy Pisarenko Date: Tue, 2 Jul 2024 09:23:15 +0000 Subject: [PATCH] Fixed unit tests --- .../s3/kqp_federated_query_ut.cpp | 20 +++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/ydb/core/kqp/ut/federated_query/s3/kqp_federated_query_ut.cpp b/ydb/core/kqp/ut/federated_query/s3/kqp_federated_query_ut.cpp index 41c7395d1ca7..6c1e9ffa9763 100644 --- a/ydb/core/kqp/ut/federated_query/s3/kqp_federated_query_ut.cpp +++ b/ydb/core/kqp/ut/federated_query/s3/kqp_federated_query_ut.cpp @@ -1861,15 +1861,16 @@ Y_UNIT_TEST_SUITE(KqpFederatedQuery) { } Y_UNIT_TEST(CreateTableAsSelectFromExternalDataSource) { - const TString externalDataSourceName = "/Root/external_data_source"; - const TString externalTableName = "/Root/test_binding_resolve"; + const TString externalDataSourceName = "external_data_source"; + const TString externalTableName = "test_binding_resolve"; auto kikimr = CreateSampleDataSource(externalDataSourceName, externalTableName); auto client = kikimr->GetQueryClient(); - const TString oltpTable = "/Root/DestinationOltp"; + const TString oltpTable = "DestinationOltp"; { const TString query = fmt::format(R"( + PRAGMA TablePathPrefix = "Root"; CREATE TABLE `{destination}` ( PRIMARY KEY (key, value) ) @@ -1888,9 +1889,10 @@ Y_UNIT_TEST_SUITE(KqpFederatedQuery) { UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString()); } - const TString olapTable = "/Root/DestinationOlap"; + const TString olapTable = "DestinationOlap"; { const TString query = fmt::format(R"( + PRAGMA TablePathPrefix = "Root"; CREATE TABLE `{destination}` ( PRIMARY KEY (key, value) ) @@ -1914,15 +1916,16 @@ Y_UNIT_TEST_SUITE(KqpFederatedQuery) { } Y_UNIT_TEST(CreateTableAsSelectFromExternalTable) { - const TString externalDataSourceName = "/Root/external_data_source"; - const TString externalTableName = "/Root/test_binding_resolve"; + const TString externalDataSourceName = "external_data_source"; + const TString externalTableName = "test_binding_resolve"; auto kikimr = CreateSampleDataSource(externalDataSourceName, externalTableName); auto client = kikimr->GetQueryClient(); - const TString oltpTable = "/Root/DestinationOltp"; + const TString oltpTable = "DestinationOltp"; { const TString query = fmt::format(R"( + PRAGMA TablePathPrefix = "Root"; CREATE TABLE `{destination}` ( PRIMARY KEY (key, value) ) @@ -1935,9 +1938,10 @@ Y_UNIT_TEST_SUITE(KqpFederatedQuery) { UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString()); } - const TString olapTable = "/Root/DestinationOlap"; + const TString olapTable = "DestinationOlap"; { const TString query = fmt::format(R"( + PRAGMA TablePathPrefix = "Root"; CREATE TABLE `{destination}` ( PRIMARY KEY (key, value) )