clear cache

src/query/catalog/src/table_context.rs

@@ -261,6 +261,8 @@ pub trait TableContext: Send + Sync {
     async fn get_table(&self, catalog: &str, database: &str, table: &str)
     -> Result<Arc<dyn Table>>;
 
+    fn remove_table_from_cache(&self, catalog: &str, database: &str, table: &str);
+
     async fn get_table_with_batch(
         &self,
         catalog: &str,

src/query/service/src/sessions/query_ctx.rs

@@ -957,6 +957,11 @@ impl TableContext for QueryContext {
             .await
     }
 
+    fn remove_table_from_cache(&self, catalog: &str, database: &str, table: &str) {
+        self.shared
+            .remove_table_from_cache(catalog, database, table)
+    }
+
     #[async_backtrace::framed]
     async fn get_table_with_batch(
         &self,

src/query/service/src/sessions/query_ctx_shared.rs

@@ -353,6 +353,16 @@ impl QueryContextShared {
         Ok(res)
     }
 
+    pub fn remove_table_from_cache(&self, catalog_name: &str, database: &str, table: &str) {
+        let table_meta_key = (
+            catalog_name.to_string(),
+            database.to_string(),
+            table.to_string(),
+        );
+        let mut tables_refs = self.tables_refs.lock();
+        tables_refs.remove(&table_meta_key);
+    }
+
     #[async_backtrace::framed]
     async fn get_table_to_cache(
         &self,

src/query/service/tests/it/sql/exec/get_table_bind_test.rs

@@ -818,6 +818,10 @@ impl TableContext for CtxDelegation {
         }
     }
 
+    fn remove_table_from_cache(&self, catalog: &str, database: &str, table: &str) {
+        todo!()
+    }
+
     async fn get_table_with_batch(
         &self,
         catalog: &str,

src/query/service/tests/it/storages/fuse/operations/commit.rs

@@ -697,6 +697,10 @@ impl TableContext for CtxDelegation {
         todo!()
     }
 
+    fn remove_table_from_cache(&self, catalog: &str, database: &str, table: &str) {
+        todo!()
+    }
+
     async fn get_table_with_batch(
         &self,
         _catalog: &str,

src/query/sql/src/planner/binder/bind_query/bind.rs

@@ -184,10 +184,11 @@ impl Binder {
             Engine::Memory
         };
         let database = self.ctx.get_current_database();
+        let catalog = self.ctx.get_current_catalog();
         let create_table_stmt = CreateTableStmt {
             create_option: CreateOption::CreateOrReplace,
-            catalog: None,
-            database: Some(Identifier::from_name(Span::None, database)),
+            catalog: Some(Identifier::from_name(Span::None, catalog.clone())),
+            database: Some(Identifier::from_name(Span::None, database.clone())),
             table: cte.alias.name.clone(),
             source: None,
             engine: Some(engine),
@@ -210,7 +211,8 @@ impl Binder {
         };
 
         // Todo: clear the table with the same name in table cache
-
+        self.ctx
+            .remove_table_from_cache(&catalog, &database, &cte.alias.name.name);
         Ok(())
     }
 }