Skip to content

Commit 98c2b7b

Browse files
committed
fix the tests
1 parent aa4096d commit 98c2b7b

File tree

1 file changed

+3
-3
lines changed
  • src/sql/sql_provider_datafusion

1 file changed

+3
-3
lines changed

src/sql/sql_provider_datafusion/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -395,7 +395,7 @@ mod tests {
395395
tracing::dispatcher::set_default(&dispatch)
396396
}
397397

398-
mod sql_table_tests {
398+
mod sql_table_plan_to_sql_tests {
399399
use std::any::Any;
400400

401401
use arrow_schema::{DataType, Field, Schema, TimeUnit};
@@ -476,7 +476,7 @@ mod tests {
476476
async fn test_sql_to_string() -> Result<(), Box<dyn Error + Send + Sync>> {
477477
let sql_table = new_sql_table("users", Some(Engine::SQLite))?;
478478
let result = sql_table.scan_to_sql(Some(&vec![0]), &[], None)?;
479-
assert_eq!(result, r#"SELECT "name" FROM users "#);
479+
assert_eq!(result, r#"SELECT `users`.`name` FROM `users`"#);
480480
Ok(())
481481
}
482482

@@ -488,7 +488,7 @@ mod tests {
488488
let result = sql_table.scan_to_sql(Some(&vec![0, 1]), &filters, Some(3))?;
489489
assert_eq!(
490490
result,
491-
r#"SELECT "name", age FROM users WHERE ((age >= 30) AND ("name" = 'x')) LIMIT 3"#
491+
r#"SELECT `users`.`name`, `users`.`age` FROM `users` WHERE ((`users`.`age` >= 30) AND (`users`.`name` = 'x')) LIMIT 3"#
492492
);
493493
Ok(())
494494
}

0 commit comments

Comments
 (0)