thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-11 17:02:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove dropTable of temp table from InterpreterDropQuery.

Browse Source
This commit is contained in:
Roman Vasin 2023-02-14 17:03:36 +00:00
parent b0ced21c30
commit f410834bfb
2 changed files with 3 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Interpreters/DatabaseCatalog.cpp
View File

@ -121,14 +121,9 @@ TemporaryTableHolder::~TemporaryTableHolder()
{ {
if (id != UUIDHelpers::Nil) if (id != UUIDHelpers::Nil)
{ {
/// Table maybe dropped before by DROP TEMPORARY TABLE auto table = getTable();
/// Thus we need to verify the existence of the table before calling dropTable table->flushAndShutdown();
auto table = temporary_tables->tryGetTable("_tmp_" + toString(id), getContext()); temporary_tables->dropTable(getContext(), "_tmp_" + toString(id));
if (table && !table->is_dropped)
{
table->flushAndShutdown();
temporary_tables->dropTable(getContext(), "_tmp_" + toString(id));
}
} }
} }

6
src/Interpreters/InterpreterDropQuery.cpp
View File

@ -282,12 +282,6 @@ BlockIO InterpreterDropQuery::executeToTemporaryTable(const String & table_name,
else if (kind == ASTDropQuery::Kind::Drop) else if (kind == ASTDropQuery::Kind::Drop)
{ {
context_handle->removeExternalTable(table_name); context_handle->removeExternalTable(table_name);
table->flushAndShutdown();
auto table_lock = table->lockExclusively(getContext()->getCurrentQueryId(), getContext()->getSettingsRef().lock_acquire_timeout);
/// Delete table data
DatabasePtr database = DatabaseCatalog::instance().getDatabase(DatabaseCatalog::TEMPORARY_DATABASE);
UUID table_uuid = table->getStorageID().uuid;
database->dropTable(getContext(), "_tmp_" + toString(table_uuid));
} }
else if (kind == ASTDropQuery::Kind::Detach) else if (kind == ASTDropQuery::Kind::Detach)
{ {