From fb9fc728a6b5822e65973d6cfe8551d86a4d6944 Mon Sep 17 00:00:00 2001 From: Sevenannn Date: Thu, 26 Dec 2024 12:40:24 -0800 Subject: [PATCH] update test to follow upstream fix: align to upstream changes and pass all tests# --- sources/sql/src/lib.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/sources/sql/src/lib.rs b/sources/sql/src/lib.rs index 1ee72c2..6f0728f 100644 --- a/sources/sql/src/lib.rs +++ b/sources/sql/src/lib.rs @@ -1004,10 +1004,10 @@ mod tests { "SELECT COUNT(CASE WHEN a > 0 THEN a ELSE 0 END) FROM app_table", r#"SELECT count(CASE WHEN (remote_table.a > 0) THEN remote_table.a ELSE 0 END) FROM remote_table"#, ), - // different tables in single aggregation expression + // // different tables in single aggregation expression ( - "SELECT COUNT(CASE WHEN app_table.a > 0 THEN app_table.a ELSE foo.df_table.a END) FROM app_table, foo.df_table", - r#"SELECT count(CASE WHEN (remote_table.a > 0) THEN remote_table.a ELSE remote_table.a END) FROM remote_table JOIN remote_table ON true"#, + "SELECT COUNT(CASE WHEN appt.a > 0 THEN appt.a ELSE dft.a END) FROM app_table as appt, foo.df_table as dft", + "SELECT count(CASE WHEN (appt.a > 0) THEN appt.a ELSE dft.a END) FROM remote_table AS appt JOIN remote_table AS dft" ), ]; @@ -1079,12 +1079,12 @@ mod tests { ) -> Result<(), datafusion::error::DataFusionError> { let data_frame = ctx.sql(sql_query).await?; - println!("before optimization: \n{:#?}", data_frame.logical_plan()); + // println!("before optimization: \n{:#?}", data_frame.logical_plan()); let mut known_rewrites = HashMap::new(); let rewritten_plan = rewrite_table_scans(data_frame.logical_plan(), &mut known_rewrites)?; - println!("rewritten_plan: \n{:#?}", rewritten_plan); + // println!("rewritten_plan: \n{:#?}", rewritten_plan); let unparsed_sql = plan_to_sql(&rewritten_plan)?;