Skip to content

Commit f2c2562

Browse files
committed
Update golden query plan tests
(Changes are benign; just graph nodes being reordered)
1 parent 313c96e commit f2c2562

File tree

1 file changed

+133
-105
lines changed

1 file changed

+133
-105
lines changed

opsqueue/src/consumer/strategy.rs

Lines changed: 133 additions & 105 deletions
Original file line numberDiff line numberDiff line change
@@ -188,11 +188,11 @@ pub mod test {
188188

189189
assert_streaming_query(qb, &explained);
190190
insta::assert_snapshot!(explained, @r"
191-
1, 0, MERGE (UNION ALL)
192-
3, 1, LEFT
193-
7, 3, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
194-
26, 1, RIGHT
195-
30, 26, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
191+
1, 0, COMPOUND QUERY
192+
2, 1, LEFT-MOST SUBQUERY
193+
5, 2, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
194+
22, 1, UNION ALL
195+
25, 22, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
196196
");
197197
}
198198

@@ -219,12 +219,12 @@ pub mod test {
219219
12, 8, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
220220
18, 8, LIST SUBQUERY 2
221221
20, 18, SCAN json_each VIRTUAL TABLE INDEX 0:
222-
60, 1, UNION ALL
223-
63, 60, SCAN chunks
224-
66, 60, CORRELATED SCALAR SUBQUERY 6
225-
70, 66, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
226-
76, 66, LIST SUBQUERY 2
227-
78, 76, SCAN json_each VIRTUAL TABLE INDEX 0:
222+
63, 1, UNION ALL
223+
66, 63, SCAN chunks
224+
69, 63, CORRELATED SCALAR SUBQUERY 6
225+
73, 69, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
226+
79, 69, LIST SUBQUERY 2
227+
81, 79, SCAN json_each VIRTUAL TABLE INDEX 0:
228228
");
229229
}
230230

@@ -252,12 +252,12 @@ pub mod test {
252252
12, 8, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
253253
18, 8, LIST SUBQUERY 2
254254
20, 18, SCAN json_each VIRTUAL TABLE INDEX 0:
255-
60, 1, UNION ALL
256-
63, 60, SCAN chunks
257-
66, 60, CORRELATED SCALAR SUBQUERY 6
258-
70, 66, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
259-
76, 66, LIST SUBQUERY 2
260-
78, 76, SCAN json_each VIRTUAL TABLE INDEX 0:
255+
63, 1, UNION ALL
256+
66, 63, SCAN chunks
257+
69, 63, CORRELATED SCALAR SUBQUERY 6
258+
73, 69, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
259+
79, 69, LIST SUBQUERY 2
260+
81, 79, SCAN json_each VIRTUAL TABLE INDEX 0:
261261
");
262262
}
263263

@@ -279,29 +279,33 @@ pub mod test {
279279
insta::assert_snapshot!(explained, @r"
280280
1, 0, COMPOUND QUERY
281281
2, 1, LEFT-MOST SUBQUERY
282-
4, 2, CO-ROUTINE inner_company_id
283-
5, 4, MERGE (UNION ALL)
284-
7, 5, LEFT
285-
11, 7, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
286-
30, 5, RIGHT
287-
34, 30, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
288-
77, 2, SCAN inner_company_id
289-
81, 2, CORRELATED SCALAR SUBQUERY 5
290-
85, 81, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
291-
91, 81, LIST SUBQUERY 3
292-
93, 91, SCAN json_each VIRTUAL TABLE INDEX 0:
293-
127, 1, UNION ALL
294-
129, 127, CO-ROUTINE inner_company_id
295-
130, 129, MERGE (UNION ALL)
296-
132, 130, LEFT
297-
136, 132, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
298-
155, 130, RIGHT
299-
159, 155, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
300-
202, 127, SCAN inner_company_id
301-
206, 127, CORRELATED SCALAR SUBQUERY 7
302-
210, 206, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
303-
216, 206, LIST SUBQUERY 3
304-
218, 216, SCAN json_each VIRTUAL TABLE INDEX 0:
282+
3, 2, COMPOUND QUERY
283+
4, 3, LEFT-MOST SUBQUERY
284+
7, 4, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
285+
16, 4, CORRELATED SCALAR SUBQUERY 5
286+
20, 16, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
287+
26, 16, LIST SUBQUERY 3
288+
28, 26, SCAN json_each VIRTUAL TABLE INDEX 0:
289+
63, 3, UNION ALL
290+
66, 63, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
291+
76, 63, CORRELATED SCALAR SUBQUERY 5
292+
80, 76, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
293+
86, 76, LIST SUBQUERY 3
294+
88, 86, SCAN json_each VIRTUAL TABLE INDEX 0:
295+
123, 3, UNION ALL
296+
124, 123, COMPOUND QUERY
297+
125, 124, LEFT-MOST SUBQUERY
298+
128, 125, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
299+
137, 125, CORRELATED SCALAR SUBQUERY 7
300+
141, 137, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
301+
147, 137, LIST SUBQUERY 3
302+
149, 147, SCAN json_each VIRTUAL TABLE INDEX 0:
303+
184, 124, UNION ALL
304+
187, 184, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
305+
197, 184, CORRELATED SCALAR SUBQUERY 7
306+
201, 197, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
307+
207, 197, LIST SUBQUERY 3
308+
209, 207, SCAN json_each VIRTUAL TABLE INDEX 0:
305309
");
306310
}
307311

@@ -331,71 +335,95 @@ pub mod test {
331335
2, 1, LEFT-MOST SUBQUERY
332336
3, 2, COMPOUND QUERY
333337
4, 3, LEFT-MOST SUBQUERY
334-
6, 4, CO-ROUTINE inner_priority
335-
7, 6, MERGE (UNION ALL)
336-
9, 7, LEFT
337-
13, 9, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
338-
32, 7, RIGHT
339-
36, 32, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
340-
79, 4, SCAN inner_priority
341-
83, 4, CORRELATED SCALAR SUBQUERY 5
342-
87, 83, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
343-
93, 83, LIST SUBQUERY 3
344-
95, 93, SCAN json_each VIRTUAL TABLE INDEX 0:
345-
123, 4, CORRELATED SCALAR SUBQUERY 11
346-
127, 123, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
347-
133, 123, LIST SUBQUERY 9
348-
135, 133, SCAN json_each VIRTUAL TABLE INDEX 0:
349-
169, 3, UNION ALL
350-
171, 169, CO-ROUTINE inner_priority
351-
172, 171, MERGE (UNION ALL)
352-
174, 172, LEFT
353-
178, 174, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
354-
197, 172, RIGHT
355-
201, 197, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
356-
244, 169, SCAN inner_priority
357-
248, 169, CORRELATED SCALAR SUBQUERY 7
358-
252, 248, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
359-
258, 248, LIST SUBQUERY 3
360-
260, 258, SCAN json_each VIRTUAL TABLE INDEX 0:
361-
288, 169, CORRELATED SCALAR SUBQUERY 11
362-
292, 288, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
363-
298, 288, LIST SUBQUERY 9
364-
300, 298, SCAN json_each VIRTUAL TABLE INDEX 0:
365-
334, 3, UNION ALL
366-
335, 334, COMPOUND QUERY
367-
336, 335, LEFT-MOST SUBQUERY
368-
338, 336, CO-ROUTINE inner_priority
369-
339, 338, MERGE (UNION ALL)
370-
341, 339, LEFT
371-
345, 341, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
372-
364, 339, RIGHT
373-
368, 364, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
374-
411, 336, SCAN inner_priority
375-
415, 336, CORRELATED SCALAR SUBQUERY 5
376-
419, 415, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
377-
425, 415, LIST SUBQUERY 3
378-
427, 425, SCAN json_each VIRTUAL TABLE INDEX 0:
379-
455, 336, CORRELATED SCALAR SUBQUERY 13
380-
459, 455, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
381-
465, 455, LIST SUBQUERY 9
382-
467, 465, SCAN json_each VIRTUAL TABLE INDEX 0:
383-
501, 335, UNION ALL
384-
503, 501, CO-ROUTINE inner_priority
385-
504, 503, MERGE (UNION ALL)
386-
506, 504, LEFT
387-
510, 506, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
388-
529, 504, RIGHT
389-
533, 529, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
390-
576, 501, SCAN inner_priority
391-
580, 501, CORRELATED SCALAR SUBQUERY 7
392-
584, 580, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
393-
590, 580, LIST SUBQUERY 3
394-
592, 590, SCAN json_each VIRTUAL TABLE INDEX 0:
395-
620, 501, CORRELATED SCALAR SUBQUERY 13
396-
624, 620, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
397-
630, 620, LIST SUBQUERY 9
398-
632, 630, SCAN json_each VIRTUAL TABLE INDEX 0:
338+
5, 4, COMPOUND QUERY
339+
6, 5, LEFT-MOST SUBQUERY
340+
9, 6, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
341+
18, 6, CORRELATED SCALAR SUBQUERY 5
342+
22, 18, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
343+
28, 18, LIST SUBQUERY 3
344+
30, 28, SCAN json_each VIRTUAL TABLE INDEX 0:
345+
57, 6, CORRELATED SCALAR SUBQUERY 11
346+
61, 57, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
347+
67, 57, LIST SUBQUERY 9
348+
69, 67, SCAN json_each VIRTUAL TABLE INDEX 0:
349+
104, 5, UNION ALL
350+
107, 104, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
351+
117, 104, CORRELATED SCALAR SUBQUERY 5
352+
121, 117, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
353+
127, 117, LIST SUBQUERY 3
354+
129, 127, SCAN json_each VIRTUAL TABLE INDEX 0:
355+
156, 104, CORRELATED SCALAR SUBQUERY 11
356+
160, 156, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
357+
166, 156, LIST SUBQUERY 9
358+
168, 166, SCAN json_each VIRTUAL TABLE INDEX 0:
359+
203, 5, UNION ALL
360+
204, 203, COMPOUND QUERY
361+
205, 204, LEFT-MOST SUBQUERY
362+
208, 205, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
363+
217, 205, CORRELATED SCALAR SUBQUERY 7
364+
221, 217, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
365+
227, 217, LIST SUBQUERY 3
366+
229, 227, SCAN json_each VIRTUAL TABLE INDEX 0:
367+
256, 205, CORRELATED SCALAR SUBQUERY 11
368+
260, 256, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
369+
266, 256, LIST SUBQUERY 9
370+
268, 266, SCAN json_each VIRTUAL TABLE INDEX 0:
371+
303, 204, UNION ALL
372+
306, 303, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
373+
316, 303, CORRELATED SCALAR SUBQUERY 7
374+
320, 316, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
375+
326, 316, LIST SUBQUERY 3
376+
328, 326, SCAN json_each VIRTUAL TABLE INDEX 0:
377+
355, 303, CORRELATED SCALAR SUBQUERY 11
378+
359, 355, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
379+
365, 355, LIST SUBQUERY 9
380+
367, 365, SCAN json_each VIRTUAL TABLE INDEX 0:
381+
402, 204, UNION ALL
382+
403, 402, COMPOUND QUERY
383+
404, 403, LEFT-MOST SUBQUERY
384+
405, 404, COMPOUND QUERY
385+
406, 405, LEFT-MOST SUBQUERY
386+
409, 406, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
387+
418, 406, CORRELATED SCALAR SUBQUERY 5
388+
422, 418, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
389+
428, 418, LIST SUBQUERY 3
390+
430, 428, SCAN json_each VIRTUAL TABLE INDEX 0:
391+
457, 406, CORRELATED SCALAR SUBQUERY 13
392+
461, 457, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
393+
467, 457, LIST SUBQUERY 9
394+
469, 467, SCAN json_each VIRTUAL TABLE INDEX 0:
395+
504, 405, UNION ALL
396+
507, 504, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
397+
517, 504, CORRELATED SCALAR SUBQUERY 5
398+
521, 517, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
399+
527, 517, LIST SUBQUERY 3
400+
529, 527, SCAN json_each VIRTUAL TABLE INDEX 0:
401+
556, 504, CORRELATED SCALAR SUBQUERY 13
402+
560, 556, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
403+
566, 556, LIST SUBQUERY 9
404+
568, 566, SCAN json_each VIRTUAL TABLE INDEX 0:
405+
603, 405, UNION ALL
406+
604, 603, COMPOUND QUERY
407+
605, 604, LEFT-MOST SUBQUERY
408+
608, 605, SEARCH chunks USING INDEX random_chunks_order (random_order>?)
409+
617, 605, CORRELATED SCALAR SUBQUERY 7
410+
621, 617, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
411+
627, 617, LIST SUBQUERY 3
412+
629, 627, SCAN json_each VIRTUAL TABLE INDEX 0:
413+
656, 605, CORRELATED SCALAR SUBQUERY 13
414+
660, 656, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
415+
666, 656, LIST SUBQUERY 9
416+
668, 666, SCAN json_each VIRTUAL TABLE INDEX 0:
417+
703, 604, UNION ALL
418+
706, 703, SEARCH chunks USING INDEX random_chunks_order (random_order<?)
419+
716, 703, CORRELATED SCALAR SUBQUERY 7
420+
720, 716, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
421+
726, 716, LIST SUBQUERY 3
422+
728, 726, SCAN json_each VIRTUAL TABLE INDEX 0:
423+
755, 703, CORRELATED SCALAR SUBQUERY 13
424+
759, 755, SEARCH submissions_metadata USING COVERING INDEX lookup_submission_by_metadata (metadata_key=? AND metadata_value=? AND submission_id=?)
425+
765, 755, LIST SUBQUERY 9
426+
767, 765, SCAN json_each VIRTUAL TABLE INDEX 0:
399427
");
400428
}
401429

0 commit comments

Comments
 (0)