Skip to content

Commit 7ff78a3

Browse files
committed
[FIXUP] test fixes for double aggregation in measures
1 parent 210ab29 commit 7ff78a3

File tree

2 files changed

+24
-23
lines changed

2 files changed

+24
-23
lines changed

rust/cubesql/cubesql/src/compile/mod.rs

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -7265,62 +7265,62 @@ ORDER BY
72657265
"cube_name": "WideCube",
72667266
"alias": "max_source_measu",
72677267
"cube_params": ["WideCube"],
7268-
"expr": "MAX(${WideCube.measure1})",
7268+
"expr": "${WideCube.measure1}",
72697269
"grouping_set": null,
72707270
})
72717271
.to_string(),
72727272
json!({
72737273
"cube_name": "WideCube",
72747274
"alias": "max_source_measu_1",
72757275
"cube_params": ["WideCube"],
7276-
"expr": "MAX(${WideCube.measure2})",
7276+
"expr": "${WideCube.measure2}",
72777277
"grouping_set": null,
72787278
})
72797279
.to_string(),
72807280
json!({
72817281
"cube_name": "WideCube",
72827282
"alias": "sum_source_measu",
72837283
"cube_params": ["WideCube"],
7284-
"expr": "SUM(${WideCube.measure3})",
7284+
"expr": "${WideCube.measure3}",
72857285
"grouping_set": null,
72867286
})
72877287
.to_string(),
72887288
json!({
72897289
"cube_name": "WideCube",
72907290
"alias": "max_source_measu_2",
72917291
"cube_params": ["WideCube"],
7292-
"expr": "MAX(${WideCube.measure4})",
7292+
"expr": "${WideCube.measure4}",
72937293
"grouping_set": null,
72947294
})
72957295
.to_string(),
72967296
]),
72977297
dimensions: Some(vec![
7298-
trivial_member_expr("WideCube", "dim2", "source_dim2"),
7299-
trivial_member_expr("WideCube", "dim3", "source_dim3"),
7300-
trivial_member_expr("WideCube", "dim4", "source_dim4"),
7298+
trivial_member_expr("WideCube", "dim2", "dim2"),
7299+
trivial_member_expr("WideCube", "dim3", "dim3"),
7300+
trivial_member_expr("WideCube", "dim4", "dim4"),
73017301
json!({
73027302
"cube_name": "WideCube",
7303-
"alias": "source_pivot_gro",
7303+
"alias": "pivot_grouping",
73047304
"cube_params": ["WideCube"],
73057305
"expr": "0",
73067306
"grouping_set": null,
73077307
})
73087308
.to_string()
73097309
]),
7310-
segments: Some(vec![json!({
7311-
"cube_name": "WideCube",
7312-
"alias": "widecube_dim1___",
7313-
"cube_params": ["WideCube"],
7314-
"expr": "(${WideCube.dim1} = $0$)",
7315-
"grouping_set": null,
7316-
})
7317-
.to_string()]),
7310+
segments: Some(vec![]),
73187311
order: Some(vec![
7319-
vec!["source_dim2".to_string(), "asc".to_string(),],
7320-
vec!["source_dim3".to_string(), "asc".to_string(),],
7321-
vec!["source_dim4".to_string(), "asc".to_string(),],
7322-
vec!["source_pivot_gro".to_string(), "asc".to_string(),],
7312+
vec!["dim2".to_string(), "asc".to_string(),],
7313+
vec!["dim3".to_string(), "asc".to_string(),],
7314+
vec!["dim4".to_string(), "asc".to_string(),],
7315+
vec!["pivot_grouping".to_string(), "asc".to_string(),],
73237316
]),
7317+
filters: Some(vec![V1LoadRequestQueryFilterItem {
7318+
member: Some("WideCube.dim1".to_string()),
7319+
operator: Some("equals".to_string()),
7320+
values: Some(vec!["foo".to_string()]),
7321+
or: None,
7322+
and: None,
7323+
},]),
73247324
..Default::default()
73257325
}
73267326
);
@@ -12768,7 +12768,7 @@ ORDER BY "source"."str0" ASC
1276812768
"cube_name": "KibanaSampleDataEcommerce",
1276912769
"alias": "avg_kibanasample",
1277012770
"cube_params": ["KibanaSampleDataEcommerce"],
12771-
"expr": "AVG(${KibanaSampleDataEcommerce.avgPrice})",
12771+
"expr": "${KibanaSampleDataEcommerce.avgPrice}",
1277212772
"grouping_set": null,
1277312773
}).to_string(),
1277412774
]),

rust/cubesql/cubesql/src/compile/test/test_wrapper.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1043,8 +1043,9 @@ async fn test_wrapper_filter_flatten() {
10431043
"cube_name": "KibanaSampleDataEcommerce",
10441044
"alias": "sum_kibanasample",
10451045
"cube_params": ["KibanaSampleDataEcommerce"],
1046-
// This SUM(sumPrice) is invalid in grouped query
1047-
"expr": "SUM(${KibanaSampleDataEcommerce.sumPrice})",
1046+
// This is grouped query, KibanaSampleDataEcommerce.sumPrice is correct in this context
1047+
// SUM(sumPrice) will be incrrect here, it would lead to SUM(SUM(sql)) in generated query
1048+
"expr": "${KibanaSampleDataEcommerce.sumPrice}",
10481049
"grouping_set": null,
10491050
})
10501051
.to_string(),]),

0 commit comments

Comments
 (0)