You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by al...@apache.org on 2021/11/15 12:04:41 UTC
[arrow-datafusion] branch master updated: improve error message for invalid create table statement (#1294)
This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/master by this push:
new ab72703 improve error message for invalid create table statement (#1294)
ab72703 is described below
commit ab72703f2e2b787400f1f8d21ca69eed2c8a233d
Author: QP Hou <qp...@scribd.com>
AuthorDate: Mon Nov 15 04:04:38 2021 -0800
improve error message for invalid create table statement (#1294)
* improve error message for invalid create table statement
* handle different create table cases using match
---
datafusion/src/sql/planner.rs | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/datafusion/src/sql/planner.rs b/datafusion/src/sql/planner.rs
index 3e1e76d..77eee29 100644
--- a/datafusion/src/sql/planner.rs
+++ b/datafusion/src/sql/planner.rs
@@ -162,6 +162,10 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
input: Arc::new(plan),
})
}
+ Statement::CreateTable { .. } => Err(DataFusionError::NotImplemented(
+ "Only `CREATE TABLE table_name AS SELECT ...` statement is supported"
+ .to_string(),
+ )),
Statement::Drop {
object_type: ObjectType::Table,
@@ -185,9 +189,10 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
table_name,
filter,
} => self.show_columns_to_plan(*extended, *full, table_name, filter.as_ref()),
- _ => Err(DataFusionError::NotImplemented(
- "Only SELECT statements are implemented".to_string(),
- )),
+ _ => Err(DataFusionError::NotImplemented(format!(
+ "Unsupported SQL statement: {:?}",
+ sql
+ ))),
}
}