Skip to content

Commit 8abcdd8

Browse files
author
Pavel Velikhov
committed
Working commit, waiting for YQL changes
1 parent 28db4cd commit 8abcdd8

File tree

3 files changed

+1114
-53
lines changed

3 files changed

+1114
-53
lines changed

ydb/core/kqp/ut/rbo/kqp_rbo_ut.cpp renamed to ydb/core/kqp/ut/rbo/kqp_rbo_pg_ut.cpp

Lines changed: 1 addition & 52 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ double TimeQuery(TString schema, TString query, int nIterations) {
7979
return elapsed_time / nIterations;
8080
}
8181

82-
Y_UNIT_TEST_SUITE(KqpRbo) {
82+
Y_UNIT_TEST_SUITE(KqpRboPg) {
8383

8484
Y_UNIT_TEST(Select) {
8585
NKikimrConfig::TAppConfig appConfig;
@@ -154,57 +154,6 @@ Y_UNIT_TEST_SUITE(KqpRbo) {
154154
}
155155
}
156156

157-
Y_UNIT_TEST(FilterYql) {
158-
NKikimrConfig::TAppConfig appConfig;
159-
appConfig.MutableTableServiceConfig()->SetEnableNewRBO(true);
160-
TKikimrRunner kikimr(NKqp::TKikimrSettings(appConfig).SetWithSampleTables(false));
161-
auto db = kikimr.GetTableClient();
162-
auto session = db.CreateSession().GetValueSync().GetSession();
163-
164-
session.ExecuteSchemeQuery(R"(
165-
CREATE TABLE `/Root/foo` (
166-
id Int64 NOT NULL,
167-
name String,
168-
primary key(id)
169-
);
170-
)").GetValueSync();
171-
172-
NYdb::TValueBuilder rows;
173-
rows.BeginList();
174-
for (size_t i = 0; i < 10; ++i) {
175-
rows.AddListItem()
176-
.BeginStruct()
177-
.AddMember("id").Int64(i)
178-
.AddMember("name").String(std::to_string(i) + "_name")
179-
.EndStruct();
180-
}
181-
rows.EndList();
182-
183-
auto resultUpsert = db.BulkUpsert("/Root/foo", rows.Build()).GetValueSync();
184-
UNIT_ASSERT_C(resultUpsert.IsSuccess(), resultUpsert.GetIssues().ToString());
185-
186-
db = kikimr.GetTableClient();
187-
auto session2 = db.CreateSession().GetValueSync().GetSession();
188-
189-
std::vector<std::string> queries = {
190-
R"(
191-
PRAGMA YqlSelect = 'force';
192-
SELECT id as id2 FROM `/Root/foo` WHERE name != '3_name';
193-
)"
194-
};
195-
196-
std::vector<std::string> results = {
197-
R"([[0];[1];[2];[4];[5];[6];[7];[8];[9]])",
198-
};
199-
200-
for (ui32 i = 0; i < queries.size(); ++i) {
201-
const auto &query = queries[i];
202-
auto result = session2.ExecuteDataQuery(query, TTxControl::BeginTx().CommitTx()).GetValueSync();
203-
UNIT_ASSERT_C(result.IsSuccess(), result.GetIssues().ToString());
204-
UNIT_ASSERT_VALUES_EQUAL(FormatResultSetYson(result.GetResultSet(0)), results[i]);
205-
}
206-
}
207-
208157
Y_UNIT_TEST(ConstantFolding) {
209158
NKikimrConfig::TAppConfig appConfig;
210159
appConfig.MutableTableServiceConfig()->SetEnableNewRBO(true);

0 commit comments

Comments
 (0)