specify database name

databendlabs · Nov 25, 2024 · 47c52bd · 47c52bd
1 parent 9b5d9a1
commit 47c52bd
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/query/sql/src/planner/binder/bind_query/bind.rs b/src/query/sql/src/planner/binder/bind_query/bind.rs
@@ -18,11 +18,13 @@ use databend_common_ast::ast::CreateOption;
 use databend_common_ast::ast::CreateTableStmt;
 use databend_common_ast::ast::Engine;
 use databend_common_ast::ast::Expr;
+use databend_common_ast::ast::Identifier;
 use databend_common_ast::ast::Query;
 use databend_common_ast::ast::SetExpr;
 use databend_common_ast::ast::TableType;
 use databend_common_ast::ast::With;
 use databend_common_ast::ast::CTE;
+use databend_common_ast::Span;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 
@@ -181,11 +183,11 @@ impl Binder {
         } else {
             Engine::Memory
         };
-
+        let database = self.ctx.get_current_database();
         let create_table_stmt = CreateTableStmt {
             create_option: CreateOption::CreateOrReplace,
             catalog: None,
-            database: None,
+            database: Some(Identifier::from_name(Span::None, database)),
             table: cte.alias.name.clone(),
             source: None,
             engine: Some(engine),