Skip to content

Commit 5f8846d

Browse files
authored
Merge to 24-1 (#2367)
1 parent d2983fe commit 5f8846d

File tree

2 files changed

+17
-1
lines changed

2 files changed

+17
-1
lines changed

ydb/core/kqp/opt/logical/kqp_opt_log_ranges_predext.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ TExprBase KqpPushExtractedPredicateToReadTable(TExprBase node, TExprContext& ctx
366366
if (buildResult.ExpectedMaxRanges.Defined()) {
367367
prompt.SetExpectedMaxRanges(buildResult.ExpectedMaxRanges.GetRef());
368368
}
369-
prompt.SetPointPrefixLen(buildResult.UsedPrefixLen);
369+
prompt.SetPointPrefixLen(buildResult.PointPrefixLen);
370370

371371
YQL_CLOG(DEBUG, ProviderKqp) << "Ranges extracted: " << KqpExprToPrettyString(*ranges, ctx);
372372
YQL_CLOG(DEBUG, ProviderKqp) << "Residual lambda: " << KqpExprToPrettyString(*residualLambda, ctx);

ydb/core/kqp/ut/opt/kqp_ne_ut.cpp

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2639,6 +2639,22 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
26392639
])", FormatResultSetYson(result.GetResultSet(0)));
26402640
}
26412641

2642+
Y_UNIT_TEST(DeleteON) {
2643+
auto kikimr = DefaultKikimrRunner();
2644+
auto db = kikimr.GetTableClient();
2645+
auto session = db.CreateSession().GetValueSync().GetSession();
2646+
2647+
NYdb::NTable::TExecDataQuerySettings execSettings;
2648+
execSettings.CollectQueryStats(ECollectQueryStatsMode::Basic);
2649+
2650+
auto result = session.ExecuteDataQuery(R"(
2651+
--!syntax_v1
2652+
2653+
DELETE FROM `/Root/Join2` where (Key1 = 1 and Key2 = "") OR Key1 = 3;
2654+
)", TTxControl::BeginTx().CommitTx(), execSettings).ExtractValueSync();
2655+
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
2656+
}
2657+
26422658
Y_UNIT_TEST(JoinWithPrecompute) {
26432659
auto kikimr = DefaultKikimrRunner();
26442660
auto db = kikimr.GetTableClient();

0 commit comments

Comments
 (0)