java-project/baiyue-firstleg
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(selfop): stabilize profile candidate join order

Browse Source
This commit is contained in:
ouyangxq
2026-10-13 02:00:14 +08:00
parent bf693fab6b
commit 2c8c26490a
2 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lastleg-service/src/main/java/com/baiyue/lastleg/selfoperated/analytics/outbound/OutboundAggregateMapper.java
+2 -1
View File
@@ -56,7 +56,8 @@ public interface OutboundAggregateMapper {
MAX(CASE WHEN outbound_rank=1 THEN observation_run_id END) evidence_run_id,
MAX(CASE WHEN seen_rank=1 THEN observation_run_id END) last_seen_run_id
FROM (
SELECT o.customer_code,i.sku_code,i.product_name,i.quantity_unit,o.outbound_at_utc,
SELECT /*+ JOIN_ORDER(o,i,s,r,t) INDEX(s idx_selfop_stage_fact_observation) */
o.customer_code,i.sku_code,i.product_name,i.quantity_unit,o.outbound_at_utc,
s.observed_at_utc,s.run_id observation_run_id,
ROW_NUMBER() OVER (PARTITION BY o.customer_code,i.sku_code ORDER BY o.outbound_at_utc,o.id) outbound_rank,
ROW_NUMBER() OVER (PARTITION BY o.customer_code,i.sku_code ORDER BY s.observed_at_utc DESC,s.id DESC) seen_rank
lastleg-service/src/test/java/com/baiyue/lastleg/selfoperated/analytics/outbound/OutboundAggregateMapperTest.java
+24
View File
@@ -79,6 +79,30 @@ public class OutboundAggregateMapperTest {
assertEquals(1L,profiles.get(0).getEvidenceRunId());assertEquals(1L,profiles.get(0).getLastSeenRunId());
assertEquals(LocalDateTime.of(2026,10,12,2,0),profiles.get(0).getFirstSeenAtUtc());
}
@Test void orderDrivenProfileBatchPreservesCursorAndIndependentEvidenceRanks() throws Exception {
order(1,"demo","C1","A","SKU-B",1,"2026-10-02 00:00:00",2);
order(2,"demo","C1","A","SKU-B",1,"2026-10-01 00:00:00",3);
order(3,"demo","C1","A","SKU-A",1,"2026-09-01 00:00:00",7);
order(4,"demo","C2","A","SKU-A",1,"2026-10-03 00:00:00",5);
order(5,"demo","C2","A","ROOTED",1,"2026-09-01 00:00:00",9);
order(6,"demo","C2","A","VALIDATION",1,"2026-09-01 00:00:00",9);
sql("UPDATE ll_selfop_sync_stage SET observed_at_utc='2026-10-13 01:00:00' WHERE id=1");
sql("UPDATE ll_selfop_sync_task SET validation_root_task_id=99 WHERE id=5");
sql("UPDATE ll_selfop_sync_task SET execution_purpose='VALIDATION' WHERE id=6");
var rows=mapper.profileBatch("demo","A","C1","SKU-A");
assertEquals(2,rows.size());
assertEquals("C1",rows.get(0).getCustomerCode());assertEquals("SKU-B",rows.get(0).getSkuCode());
assertEquals(2L,rows.get(0).getEvidenceRunId());assertEquals(1L,rows.get(0).getLastSeenRunId());
assertEquals(LocalDateTime.of(2026,10,12,1,0),rows.get(0).getFirstSeenAtUtc());
assertEquals(LocalDateTime.of(2026,10,1,0,0),rows.get(0).getEarliestEvidenceAtUtc());
assertEquals("C2",rows.get(1).getCustomerCode());assertEquals("SKU-A",rows.get(1).getSkuCode());
assertEquals(1,mapper.profileBatch("demo","A","C1","SKU-B").size());
// H2 verifies result semantics but ignores MySQL hints; root separately verifies EXPLAIN and SHOW WARNINGS.
var statement=session.getConfiguration().getMappedStatement(OutboundAggregateMapper.class.getName()+".profileBatch");
String bound=statement.getBoundSql(Map.of("account","demo","warehouse","A","customer","C1","sku","SKU-A")).getSql();
assertTrue(bound.contains("JOIN_ORDER(o,i,s,r,t) INDEX(s idx_selfop_stage_fact_observation)"));
assertTrue(bound.indexOf("JOIN_ORDER(")<bound.indexOf("FROM ll_selfop_outbound_order o"));
}
@Test void databaseResultPagesAndMultiRowInsertsAreBounded() throws Exception {
// Insert synthetic local orders without any provider I/O.
try(Connection c=data.getConnection();PreparedStatement statement=c.prepareStatement("INSERT INTO ll_selfop_outbound_order VALUES (?,'demo','C1','A',1,'2026-10-01 00:00:00','2026-10-01','Asia/Shanghai','Asia/Shanghai',?)");