Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: Additional subquery tests

pull/24376/head
Stuart Carnie 2023-05-12 12:49:26 +10:00
parent 9560e50fa2
commit 248f596bda
No known key found for this signature in database
GPG Key ID: 848D9C9718D78B4F
1 changed files with 49 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
iox_query_influxql/src/plan/rewriter.rs
View File

@ -1721,6 +1721,7 @@ mod test {
Ok(stmt.select.into())
}
/// Validate the data types of the fields of a [`Select`].
#[test]
fn projection_schema() {
let namespace = MockSchemaProvider::default();
@ -2113,6 +2114,54 @@ mod test {
stmt.to_string(),
"SELECT time::timestamp AS time, cpu::tag AS cpu, foo::tag AS foo, usage_system::float AS usage_system FROM (SELECT time::timestamp AS time, cpu::tag AS foo, usage_system::float AS usage_system FROM cpu GROUP BY cpu)"
);
// Projects non-existent foo as a tag in the outer query
let stmt = parse_select(
"SELECT * FROM (SELECT usage_idle FROM cpu GROUP BY foo) GROUP BY cpu",
);
let stmt = rewrite_select_statement(&namespace, &stmt).unwrap();
assert_eq!(
stmt.to_string(),
"SELECT time::timestamp AS time, foo::tag AS foo, usage_idle::float AS usage_idle FROM (SELECT time::timestamp AS time, usage_idle::float AS usage_idle FROM cpu GROUP BY foo) GROUP BY cpu"
);
// Projects non-existent tag, "bytes_free" from cpu and also bytes_free field from disk
// NOTE: InfluxQL OG does something really strange and arguably incorrect
//
// ```
// SELECT * FROM (SELECT usage_idle FROM cpu GROUP BY bytes_free), (SELECT bytes_free FROM disk) GROUP BY cpu
// ```
//
// The output shows that InfluxQL expanded the non-existent bytes_free tag (bytes_free1)
// from the cpu measurement, and the bytes_free field from the disk measurement as two
// separate columns but when producing the results, read the data from the `bytes_free`
// field for the disk table.
//
// ```
// name: cpu
// tags: cpu=cpu-total
// time bytes_free bytes_free_1 usage_idle
// ---- ---------- ------------ ----------
// 1667181600000000000 2.98
// 1667181610000000000 2.99
// ... trimmed for brevity
//
// name: disk
// tags: cpu=
// time bytes_free bytes_free_1 usage_idle
// ---- ---------- ------------ ----------
// 1667181600000000000 1234 1234
// 1667181600000000000 3234 3234
// ... trimmed for brevity
// ```
let stmt = parse_select(
"SELECT * FROM (SELECT usage_idle FROM cpu GROUP BY bytes_free), (SELECT bytes_free FROM disk) GROUP BY cpu",
);
let stmt = rewrite_select_statement(&namespace, &stmt).unwrap();
assert_eq!(
stmt.to_string(),
"SELECT time::timestamp AS time, bytes_free::integer AS bytes_free, bytes_free::tag AS bytes_free_1, usage_idle::float AS usage_idle FROM (SELECT time::timestamp AS time, usage_idle::float AS usage_idle FROM cpu GROUP BY bytes_free), (SELECT time::timestamp AS time, bytes_free::integer AS bytes_free FROM disk) GROUP BY cpu"
);
}
/// `DISTINCT` clause and `distinct` function