From e7cbd34a29ff31d5861d44d0045d9e6749fe26a5 Mon Sep 17 00:00:00 2001 From: Alexey Milovidov Date: Tue, 27 Aug 2019 23:43:35 +0300 Subject: [PATCH] Improve table locks (incomplete) --- dbms/src/Interpreters/InterpreterRenameQuery.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dbms/src/Interpreters/InterpreterRenameQuery.cpp b/dbms/src/Interpreters/InterpreterRenameQuery.cpp index 97b17c6afd7..a3b21063ad7 100644 --- a/dbms/src/Interpreters/InterpreterRenameQuery.cpp +++ b/dbms/src/Interpreters/InterpreterRenameQuery.cpp @@ -93,7 +93,7 @@ BlockIO InterpreterRenameQuery::execute() if (auto table = context.tryGetTable(from.database_name, from.table_name)) tables_from_locks.emplace(from, table->lockExclusively(context.getCurrentQueryId())); - descriptions.back().table_lock = tables_from_locks[from]; + descriptions.back().from_table_lock = tables_from_locks[from]; if (!table_guards.count(from)) table_guards.emplace(from, context.getDDLGuard(from.database_name, from.table_name)); @@ -118,7 +118,7 @@ BlockIO InterpreterRenameQuery::execute() context.assertTableDoesntExist(elem.to_database_name, elem.to_table_name); context.getDatabase(elem.from_database_name)->renameTable( - context, elem.from_table_name, *context.getDatabase(elem.to_database_name), elem.to_table_name, elem.table_lock); + context, elem.from_table_name, *context.getDatabase(elem.to_database_name), elem.to_table_name, elem.from_table_lock); } return {};