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

refactor: exhaust delete test scenarios

pull/24376/head
Nga Tran 2021-09-28 12:31:46 -04:00
parent 46363c7893
commit d7af1b8290
2 changed files with 208 additions and 607 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

759
query_tests/src/scenarios/delete.rs
View File

File diff suppressed because it is too large Load Diff

56
query_tests/src/sql.rs
View File

@ -854,25 +854,8 @@ async fn sql_select_with_delete_from_one_expr() {
"+-----+--------------------------------+", "+-----+--------------------------------+",
]; ];
// Data deleted when it is in MUB, and then moved to RUB and OS
run_sql_test_case( run_sql_test_case(
scenarios::delete::DeleteFromMubOneMeasurementOneChunk {}, scenarios::delete::OneDeleteSimpleExprOneChunk {},
"SELECT * from cpu",
&expected,
)
.await;
// Data deleted when it is in RUB, and then moved OS
run_sql_test_case(
scenarios::delete::DeleteFromRubOneMeasurementOneChunk {},
"SELECT * from cpu",
&expected,
)
.await;
// Data deleted when it is in OS
run_sql_test_case(
scenarios::delete::DeleteFromOsOneMeasurementOneChunk {},
"SELECT * from cpu", "SELECT * from cpu",
&expected, &expected,
) )
@ -890,25 +873,8 @@ async fn sql_select_with_delete_from_multi_exprs() {
"+-----+-----+--------------------------------+", "+-----+-----+--------------------------------+",
]; ];
// Data deleted when it is in MUB, and then moved to RUB and OS
run_sql_test_case( run_sql_test_case(
scenarios::delete::DeleteMultiExprsFromMubOneMeasurementOneChunk {}, scenarios::delete::OneDeleteMultiExprsOneChunk {},
"SELECT * from cpu",
&expected,
)
.await;
// Data deleted when it is in RUB, and then moved OS
run_sql_test_case(
scenarios::delete::DeleteMultiExprsFromRubOneMeasurementOneChunk {},
"SELECT * from cpu",
&expected,
)
.await;
// Data deleted when it is in OS
run_sql_test_case(
scenarios::delete::DeleteMultiExprsFromOsOneMeasurementOneChunk {},
"SELECT * from cpu", "SELECT * from cpu",
&expected, &expected,
) )
@ -927,23 +893,7 @@ async fn sql_select_with_two_deletes_from_multi_exprs() {
// Data deleted when it is in MUB, and then moved to RUB and OS // Data deleted when it is in MUB, and then moved to RUB and OS
run_sql_test_case( run_sql_test_case(
scenarios::delete::TwoDeleteMultiExprsFromMubOneMeasurementOneChunk {}, scenarios::delete::TwoDeletesMultiExprsOneChunk {},
"SELECT * from cpu",
&expected,
)
.await;
// Data deleted when it is in RUB, and then moved OS
run_sql_test_case(
scenarios::delete::TwoDeleteMultiExprsFromRubOneMeasurementOneChunk {},
"SELECT * from cpu",
&expected,
)
.await;
// Data deleted when it is in OS
run_sql_test_case(
scenarios::delete::TwoDeleteMultiExprsFromOsOneMeasurementOneChunk {},
"SELECT * from cpu", "SELECT * from cpu",
&expected, &expected,
) )