Skip to content

Commit

Permalink
Fixed unit tests
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed Jul 2, 2024
1 parent 57ffc7b commit b651b0c
Showing 1 changed file with 12 additions and 8 deletions.
20 changes: 12 additions & 8 deletions ydb/core/kqp/ut/federated_query/s3/kqp_federated_query_ut.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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)
)
Expand All @@ -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)
)
Expand All @@ -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)
)
Expand All @@ -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)
)
Expand Down

0 comments on commit b651b0c

Please sign in to comment.