diff --git a/dbms/programs/server/TCPHandler.cpp b/dbms/programs/server/TCPHandler.cpp
index cb215eb0af8733535fbb574567c5795ecb35652a..366d282f09882c5aef8fe22436ef863eb3c21472 100644
--- a/dbms/programs/server/TCPHandler.cpp
+++ b/dbms/programs/server/TCPHandler.cpp
@@ -993,7 +993,7 @@ bool TCPHandler::receiveData(bool scalar)
                 if (!(storage = query_context->tryGetExternalTable(name)))
                 {
                     NamesAndTypesList columns = block.getNamesAndTypesList();
-                    storage = StorageMemory::create("_external", name, ColumnsDescription{columns}, ConstraintsDescription{});
+                    storage = StorageMemory::create(StorageID("_external", name), ColumnsDescription{columns}, ConstraintsDescription{});
                     storage->startup();
                     query_context->addExternalTable(name, storage);
                 }
diff --git a/dbms/src/Core/ExternalTable.cpp b/dbms/src/Core/ExternalTable.cpp
index 8befb4e054c642ba62c159be97c58a6c95492c80..e87bc3b513bc06dfad4dd5f5fa149a42eb9e9fc4 100644
--- a/dbms/src/Core/ExternalTable.cpp
+++ b/dbms/src/Core/ExternalTable.cpp
@@ -160,7 +160,7 @@ void ExternalTablesHandler::handlePart(const Poco::Net::MessageHeader & header,
 
     /// Create table
     NamesAndTypesList columns = sample_block.getNamesAndTypesList();
-    StoragePtr storage = StorageMemory::create("_external", data.second, ColumnsDescription{columns}, ConstraintsDescription{});
+    StoragePtr storage = StorageMemory::create(StorageID("_external", data.second), ColumnsDescription{columns}, ConstraintsDescription{});
     storage->startup();
     context.addExternalTable(data.second, storage);
     BlockOutputStreamPtr output = storage->write(ASTPtr(), context);
diff --git a/dbms/src/DataStreams/PushingToViewsBlockOutputStream.cpp b/dbms/src/DataStreams/PushingToViewsBlockOutputStream.cpp
index d7fb7bad343c052f8264af58ba79efc750040c19..a630757b9a5b9e726681c18ceae26e3049a545e4 100644
--- a/dbms/src/DataStreams/PushingToViewsBlockOutputStream.cpp
+++ b/dbms/src/DataStreams/PushingToViewsBlockOutputStream.cpp
@@ -223,7 +223,7 @@ void PushingToViewsBlockOutputStream::process(const Block & block, size_t view_n
             /// InterpreterSelectQuery will do processing of alias columns.
             Context local_context = *views_context;
             local_context.addViewSource(
-                    StorageValues::create(storage->getDatabaseName(), storage->getTableName(), storage->getColumns(),
+                    StorageValues::create(StorageID(storage->getDatabaseName(), storage->getTableName()), storage->getColumns(),   //FIXME
                                           block));
             select.emplace(view.query, local_context, SelectQueryOptions());
             in = std::make_shared<MaterializingBlockInputStream>(select->execute().in);
diff --git a/dbms/src/Databases/DatabaseDictionary.cpp b/dbms/src/Databases/DatabaseDictionary.cpp
index 9409fdc584abed16a459cbc96bb959e29d727913..898e3d9f5e2f27ae25a781f2153393fb90a6b199 100644
--- a/dbms/src/Databases/DatabaseDictionary.cpp
+++ b/dbms/src/Databases/DatabaseDictionary.cpp
@@ -52,7 +52,7 @@ Tables DatabaseDictionary::listTables(const Context & context, const FilterByNam
             auto dict_name = dict_ptr->getName();
             const DictionaryStructure & dictionary_structure = dict_ptr->getStructure();
             auto columns = StorageDictionary::getNamesAndTypes(dictionary_structure);
-            tables[dict_name] = StorageDictionary::create(getDatabaseName(), dict_name, ColumnsDescription{columns}, context, true, dict_name);
+            tables[dict_name] = StorageDictionary::create(StorageID(getDatabaseName(), dict_name), ColumnsDescription{columns}, context, true, dict_name);
         }
     }
     return tables;
@@ -74,7 +74,7 @@ StoragePtr DatabaseDictionary::tryGetTable(
     {
         const DictionaryStructure & dictionary_structure = dict_ptr->getStructure();
         auto columns = StorageDictionary::getNamesAndTypes(dictionary_structure);
-        return StorageDictionary::create(getDatabaseName(), table_name, ColumnsDescription{columns}, context, true, table_name);
+        return StorageDictionary::create(StorageID(getDatabaseName(), table_name), ColumnsDescription{columns}, context, true, table_name);
     }
 
     return {};
diff --git a/dbms/src/Databases/DatabaseMySQL.cpp b/dbms/src/Databases/DatabaseMySQL.cpp
index 9ae42f08d8a6434e0e57864c79a7e5982692ff68..a3a85abba4f8444d4a47953f67f305a70f98087a 100644
--- a/dbms/src/Databases/DatabaseMySQL.cpp
+++ b/dbms/src/Databases/DatabaseMySQL.cpp
@@ -239,7 +239,7 @@ void DatabaseMySQL::fetchLatestTablesStructureIntoCache(const std::map<String, U
         }
 
         local_tables_cache[table_name] = std::make_pair(table_modification_time, StorageMySQL::create(
-            database_name, table_name, std::move(mysql_pool), database_name_in_mysql, table_name,
+            StorageID(database_name, table_name), std::move(mysql_pool), database_name_in_mysql, table_name,
             false, "", ColumnsDescription{columns_name_and_type}, ConstraintsDescription{}, global_context));
     }
 }
diff --git a/dbms/src/Databases/DatabaseOnDisk.cpp b/dbms/src/Databases/DatabaseOnDisk.cpp
index dfeb8746a2f17439b3030b18a26ad9e953e1c9cd..e7f45bdb702f916022a4f43520676144603de09a 100644
--- a/dbms/src/Databases/DatabaseOnDisk.cpp
+++ b/dbms/src/Databases/DatabaseOnDisk.cpp
@@ -68,9 +68,12 @@ std::pair<String, StoragePtr> createTableFromAST(
         ast_create_query.table,
         StorageFactory::instance().get(
             ast_create_query,
-            table_data_path_relative, ast_create_query.table, database_name, context, context.getGlobalContext(),
-            columns, constraints,
-            true, has_force_restore_data_flag)
+            table_data_path_relative,
+            context,
+            context.getGlobalContext(),
+            columns,
+            constraints,
+            has_force_restore_data_flag)
     };
 }
 
diff --git a/dbms/src/Databases/DatabaseWithDictionaries.cpp b/dbms/src/Databases/DatabaseWithDictionaries.cpp
index a10348b31efae3bca2e42bd16adf58623cbf52f3..ce21b27d6c3d1fc13bb1bf920e3400e1e976304f 100644
--- a/dbms/src/Databases/DatabaseWithDictionaries.cpp
+++ b/dbms/src/Databases/DatabaseWithDictionaries.cpp
@@ -226,7 +226,7 @@ StoragePtr DatabaseWithDictionaries::getDictionaryStorage(const Context & contex
     {
         const DictionaryStructure & dictionary_structure = dict_ptr->getStructure();
         auto columns = StorageDictionary::getNamesAndTypes(dictionary_structure);
-        return StorageDictionary::create(database_name, table_name, ColumnsDescription{columns}, context, true, dict_name);
+        return StorageDictionary::create(StorageID(database_name, table_name), ColumnsDescription{columns}, context, true, dict_name);
     }
     return nullptr;
 }
diff --git a/dbms/src/Interpreters/GlobalSubqueriesVisitor.h b/dbms/src/Interpreters/GlobalSubqueriesVisitor.h
index 6c380162af40cfb1356690d2d066682c2b4e997b..d49f4c8f4e566d7f16162f9a1d5fb9c2f1b86b28 100644
--- a/dbms/src/Interpreters/GlobalSubqueriesVisitor.h
+++ b/dbms/src/Interpreters/GlobalSubqueriesVisitor.h
@@ -95,7 +95,7 @@ public:
             Block sample = interpreter->getSampleBlock();
             NamesAndTypesList columns = sample.getNamesAndTypesList();
 
-            StoragePtr external_storage = StorageMemory::create("_external", external_table_name, ColumnsDescription{columns}, ConstraintsDescription{});
+            StoragePtr external_storage = StorageMemory::create(StorageID("_external", external_table_name), ColumnsDescription{columns}, ConstraintsDescription{});
             external_storage->startup();
 
             /** We replace the subquery with the name of the temporary table.
diff --git a/dbms/src/Interpreters/InterpreterCreateQuery.cpp b/dbms/src/Interpreters/InterpreterCreateQuery.cpp
index 2a2160ca058550cb3f087fbe100eace5b1448189..dd1236bc8b49565c0d9ab5ea9dcd7265827c756e 100644
--- a/dbms/src/Interpreters/InterpreterCreateQuery.cpp
+++ b/dbms/src/Interpreters/InterpreterCreateQuery.cpp
@@ -631,13 +631,10 @@ bool InterpreterCreateQuery::doCreateTable(const ASTCreateQuery & create,
     {
         res = StorageFactory::instance().get(create,
             database ? database->getTableDataPath(create) : "",
-            table_name,
-            create.database,
             context,
             context.getGlobalContext(),
             properties.columns,
             properties.constraints,
-            create.attach,
             false);
     }
 
diff --git a/dbms/src/Interpreters/InterpreterSystemQuery.cpp b/dbms/src/Interpreters/InterpreterSystemQuery.cpp
index 3ef0dc2f0853032a909d617ed1075c468c34afb8..6d9c7c66aa8bdd2fab7d068fe350704d83c66572 100644
--- a/dbms/src/Interpreters/InterpreterSystemQuery.cpp
+++ b/dbms/src/Interpreters/InterpreterSystemQuery.cpp
@@ -295,13 +295,10 @@ StoragePtr InterpreterSystemQuery::tryRestartReplica(const String & database_nam
 
         StoragePtr table = StorageFactory::instance().get(create,
             database->getTableDataPath(create),
-            table_name,
-            database_name,
             system_context,
             system_context.getGlobalContext(),
             columns,
             constraints,
-            create.attach,
             false);
 
         database->createTable(system_context, table_name, table, create_ast);
diff --git a/dbms/src/Parsers/ASTQueryWithTableAndOutput.h b/dbms/src/Parsers/ASTQueryWithTableAndOutput.h
index 594876ace7b8215cf483a4575616e4595d7bbad1..5068db1edb71c30d618c51b43c98528f52d48d25 100644
--- a/dbms/src/Parsers/ASTQueryWithTableAndOutput.h
+++ b/dbms/src/Parsers/ASTQueryWithTableAndOutput.h
@@ -15,6 +15,7 @@ class ASTQueryWithTableAndOutput : public ASTQueryWithOutput
 public:
     String database;
     String table;
+    String uuid;
     bool temporary{false};
 
 protected:
diff --git a/dbms/src/Storages/Kafka/StorageKafka.cpp b/dbms/src/Storages/Kafka/StorageKafka.cpp
index c404ba3aa12de894251dffc7cb3782013c93c6bc..c5e83dd5b88c9dc8571fc63efba877072f2b7d0b 100644
--- a/dbms/src/Storages/Kafka/StorageKafka.cpp
+++ b/dbms/src/Storages/Kafka/StorageKafka.cpp
@@ -75,8 +75,7 @@ namespace
 }
 
 StorageKafka::StorageKafka(
-    const std::string & table_name_,
-    const std::string & database_name_,
+    const StorageID & table_id_,
     Context & context_,
     const ColumnsDescription & columns_,
     const String & brokers_,
@@ -89,7 +88,7 @@ StorageKafka::StorageKafka(
     UInt64 max_block_size_,
     size_t skip_broken_,
     bool intermediate_commit_)
-    : IStorage({database_name_, table_name_},
+    : IStorage(table_id_,
         ColumnsDescription({{"_topic", std::make_shared<DataTypeString>()},
                             {"_key", std::make_shared<DataTypeString>()},
                             {"_offset", std::make_shared<DataTypeUInt64>()},
@@ -105,7 +104,7 @@ StorageKafka::StorageKafka(
     , schema_name(global_context.getMacros()->expand(schema_name_))
     , num_consumers(num_consumers_)
     , max_block_size(max_block_size_)
-    , log(&Logger::get("StorageKafka (" + table_name_ + ")"))
+    , log(&Logger::get("StorageKafka (" + table_id_.table_name + ")"))
     , semaphore(0, num_consumers_)
     , skip_broken(skip_broken_)
     , intermediate_commit(intermediate_commit_)
@@ -645,7 +644,7 @@ void registerStorageKafka(StorageFactory & factory)
         }
 
         return StorageKafka::create(
-            args.table_name, args.database_name, args.context, args.columns,
+            args.table_id, args.context, args.columns,
             brokers, group, topics, format, row_delimiter, schema, num_consumers, max_block_size, skip_broken, intermediate_commit);
     });
 }
diff --git a/dbms/src/Storages/Kafka/StorageKafka.h b/dbms/src/Storages/Kafka/StorageKafka.h
index 7426f5b8fb495fab0d2a2f554e1d1cc1d8e8b4ca..586ccb717c846cfad7d3bc10c2f8dea8c3222bb2 100644
--- a/dbms/src/Storages/Kafka/StorageKafka.h
+++ b/dbms/src/Storages/Kafka/StorageKafka.h
@@ -64,13 +64,18 @@ public:
 
 protected:
     StorageKafka(
-        const std::string & table_name_,
-        const std::string & database_name_,
+        const StorageID & table_id_,
         Context & context_,
         const ColumnsDescription & columns_,
-        const String & brokers_, const String & group_, const Names & topics_,
-        const String & format_name_, char row_delimiter_, const String & schema_name_,
-        size_t num_consumers_, UInt64 max_block_size_, size_t skip_broken,
+        const String & brokers_,
+        const String & group_,
+        const Names & topics_,
+        const String & format_name_,
+        char row_delimiter_,
+        const String & schema_name_,
+        size_t num_consumers_,
+        UInt64 max_block_size_,
+        size_t skip_broken,
         bool intermediate_commit_);
 
 private:
diff --git a/dbms/src/Storages/LiveView/StorageLiveView.cpp b/dbms/src/Storages/LiveView/StorageLiveView.cpp
index fb2462a176a26e1de01dca6b1f38ad565ab33f8a..42c09373f106beea84f2de68717567abbd168c6b 100644
--- a/dbms/src/Storages/LiveView/StorageLiveView.cpp
+++ b/dbms/src/Storages/LiveView/StorageLiveView.cpp
@@ -193,12 +193,11 @@ void StorageLiveView::writeIntoLiveView(
 
 
 StorageLiveView::StorageLiveView(
-    const String & table_name_,
-    const String & database_name_,
+    const StorageID & table_id_,
     Context & local_context,
     const ASTCreateQuery & query,
     const ColumnsDescription & columns_)
-    : IStorage({database_name_, table_name_}), global_context(local_context.getGlobalContext())
+    : IStorage(table_id_), global_context(local_context.getGlobalContext())
 {
     setColumns(columns_);
 
@@ -224,7 +223,7 @@ StorageLiveView::StorageLiveView(
 
     global_context.addDependency(
         DatabaseAndTableName(select_database_name, select_table_name),
-        DatabaseAndTableName(database_name_, table_name_));   //FIXME
+        DatabaseAndTableName(table_id_.database_name, table_id_.table_name));   //FIXME
 
     is_temporary = query.temporary;
     temporary_live_view_timeout = local_context.getSettingsRef().temporary_live_view_timeout.totalSeconds();
@@ -599,7 +598,7 @@ void registerStorageLiveView(StorageFactory & factory)
         if (!args.attach && !args.local_context.getSettingsRef().allow_experimental_live_view)
             throw Exception("Experimental LIVE VIEW feature is not enabled (the setting 'allow_experimental_live_view')", ErrorCodes::SUPPORT_IS_DISABLED);
 
-        return StorageLiveView::create(args.table_name, args.database_name, args.local_context, args.query, args.columns);
+        return StorageLiveView::create(args.table_id, args.local_context, args.query, args.columns);
     });
 }
 
diff --git a/dbms/src/Storages/LiveView/StorageLiveView.h b/dbms/src/Storages/LiveView/StorageLiveView.h
index 54722a22ff9a3802057483b820f394b032c12229..63a923df2ccc41281712ff199dffafd63eb6ba0a 100644
--- a/dbms/src/Storages/LiveView/StorageLiveView.h
+++ b/dbms/src/Storages/LiveView/StorageLiveView.h
@@ -173,8 +173,7 @@ private:
     UInt64 temporary_live_view_timeout;
 
     StorageLiveView(
-        const String & table_name_,
-        const String & database_name_,
+        const StorageID & table_id_,
         Context & local_context,
         const ASTCreateQuery & query,
         const ColumnsDescription & columns
diff --git a/dbms/src/Storages/MergeTree/MergeTreeData.cpp b/dbms/src/Storages/MergeTree/MergeTreeData.cpp
index f11f385135594f73b9b36374e2455fb94bb9ebc4..7dae60a78f4dfa2ad8c45c6f66502c35853252e6 100644
--- a/dbms/src/Storages/MergeTree/MergeTreeData.cpp
+++ b/dbms/src/Storages/MergeTree/MergeTreeData.cpp
@@ -110,8 +110,7 @@ namespace
 
 
 MergeTreeData::MergeTreeData(
-    const String & database_,
-    const String & table_,
+    const StorageID & table_id_,
     const String & relative_data_path_,
     const ColumnsDescription & columns_,
     const IndicesDescription & indices_,
@@ -128,7 +127,7 @@ MergeTreeData::MergeTreeData(
     bool require_part_metadata_,
     bool attach,
     BrokenPartCallback broken_part_callback_)
-    : IStorage({database_, table_})
+    : IStorage(table_id_)
     , global_context(context_)
     , merging_params(merging_params_)
     , partition_by_ast(partition_by_ast_)
@@ -136,7 +135,7 @@ MergeTreeData::MergeTreeData(
     , require_part_metadata(require_part_metadata_)
     , relative_data_path(relative_data_path_)
     , broken_part_callback(broken_part_callback_)
-    , log_name(database_ + "." + table_)
+    , log_name(table_id_.getNameForLogs())
     , log(&Logger::get(log_name))
     , storage_settings(std::move(storage_settings_))
     , storage_policy(context_.getStoragePolicy(getSettings()->storage_policy))
diff --git a/dbms/src/Storages/MergeTree/MergeTreeData.h b/dbms/src/Storages/MergeTree/MergeTreeData.h
index 7af7dbc4747557273df6db853c5c913f84d41279..bb554918cddeed658970fc8389c316eb3552ac81 100644
--- a/dbms/src/Storages/MergeTree/MergeTreeData.h
+++ b/dbms/src/Storages/MergeTree/MergeTreeData.h
@@ -330,7 +330,7 @@ public:
     ///
     /// require_part_metadata - should checksums.txt and columns.txt exist in the part directory.
     /// attach - whether the existing table is attached or the new table is created.
-    MergeTreeData(const String & database_, const String & table_,
+    MergeTreeData(const StorageID & table_id_,
                   const String & relative_data_path_,
                   const ColumnsDescription & columns_,
                   const IndicesDescription & indices_,
diff --git a/dbms/src/Storages/MergeTree/StorageFromMergeTreeDataPart.h b/dbms/src/Storages/MergeTree/StorageFromMergeTreeDataPart.h
index 195fa899175f2ed0e2f40a08a9b638581d62d178..e04749e86cc640b83bba762926171af2c69c7839 100644
--- a/dbms/src/Storages/MergeTree/StorageFromMergeTreeDataPart.h
+++ b/dbms/src/Storages/MergeTree/StorageFromMergeTreeDataPart.h
@@ -49,8 +49,12 @@ public:
 
 protected:
     StorageFromMergeTreeDataPart(const MergeTreeData::DataPartPtr & part_)
-        : IStorage({part_->storage.getDatabaseName(), part_->storage.getTableName() + " (part " + part_->name + ")"},
-                   part_->storage.getVirtuals()), part(part_)
+        : IStorage({
+                      part_->storage.getDatabaseName(),
+                      part_->storage.getTableName() + " (part " + part_->name + ")"
+                   }
+        , part_->storage.getVirtuals())
+        , part(part_)
     {
         setColumns(part_->storage.getColumns());
         setIndices(part_->storage.getIndices());
diff --git a/dbms/src/Storages/MergeTree/registerStorageMergeTree.cpp b/dbms/src/Storages/MergeTree/registerStorageMergeTree.cpp
index 633699d15294fea0456bae52a64c8af9a1f3ae4c..46e55b75b4f2e6952c14bd60d2f6150c62086393 100644
--- a/dbms/src/Storages/MergeTree/registerStorageMergeTree.cpp
+++ b/dbms/src/Storages/MergeTree/registerStorageMergeTree.cpp
@@ -639,14 +639,14 @@ static StoragePtr create(const StorageFactory::Arguments & args)
 
     if (replicated)
         return StorageReplicatedMergeTree::create(
-            zookeeper_path, replica_name, args.attach, args.database_name, args.table_name, args.relative_data_path,
+            zookeeper_path, replica_name, args.attach, args.table_id, args.relative_data_path,
             args.columns, indices_description, args.constraints,
             args.context, date_column_name, partition_by_ast, order_by_ast, primary_key_ast,
             sample_by_ast, ttl_table_ast, merging_params, std::move(storage_settings),
             args.has_force_restore_data_flag);
     else
         return StorageMergeTree::create(
-            args.database_name, args.table_name, args.relative_data_path, args.columns, indices_description,
+            args.table_id, args.relative_data_path, args.columns, indices_description,
             args.constraints, args.attach, args.context, date_column_name, partition_by_ast, order_by_ast,
             primary_key_ast, sample_by_ast, ttl_table_ast, merging_params, std::move(storage_settings),
             args.has_force_restore_data_flag);
diff --git a/dbms/src/Storages/StorageBuffer.cpp b/dbms/src/Storages/StorageBuffer.cpp
index 50454a0634ff2e777e7dafadf436c65db843c3df..afd3a1fd7f0b968e875078065f008be8041b3c88 100644
--- a/dbms/src/Storages/StorageBuffer.cpp
+++ b/dbms/src/Storages/StorageBuffer.cpp
@@ -56,18 +56,27 @@ namespace ErrorCodes
 }
 
 
-StorageBuffer::StorageBuffer(const std::string & database_name_, const std::string & table_name_,
-    const ColumnsDescription & columns_, const ConstraintsDescription & constraints_,
+StorageBuffer::StorageBuffer(
+    const StorageID & table_id_,
+    const ColumnsDescription & columns_,
+    const ConstraintsDescription & constraints_,
     Context & context_,
-    size_t num_shards_, const Thresholds & min_thresholds_, const Thresholds & max_thresholds_,
-    const String & destination_database_, const String & destination_table_, bool allow_materialized_)
-    : IStorage({database_name_, table_name_}),
-    global_context(context_),
-    num_shards(num_shards_), buffers(num_shards_),
-    min_thresholds(min_thresholds_), max_thresholds(max_thresholds_),
-    destination_database(destination_database_), destination_table(destination_table_),
-    no_destination(destination_database.empty() && destination_table.empty()),
-    allow_materialized(allow_materialized_), log(&Logger::get("StorageBuffer (" + table_name_ + ")"))
+    size_t num_shards_,
+    const Thresholds & min_thresholds_,
+    const Thresholds & max_thresholds_,
+    const String & destination_database_,
+    const String & destination_table_,
+    bool allow_materialized_)
+    : IStorage(table_id_)
+    , global_context(context_)
+    , num_shards(num_shards_), buffers(num_shards_)
+    , min_thresholds(min_thresholds_)
+    , max_thresholds(max_thresholds_)
+    , destination_database(destination_database_)
+    , destination_table(destination_table_)
+    , no_destination(destination_database.empty() && destination_table.empty())
+    , allow_materialized(allow_materialized_)
+    , log(&Logger::get("StorageBuffer (" + table_id_.getFullTableName() + ")"))
 {
     setColumns(columns_);
     setConstraints(constraints_);
@@ -753,8 +762,9 @@ void registerStorageBuffer(StorageFactory & factory)
         UInt64 max_bytes = applyVisitor(FieldVisitorConvertToNumber<UInt64>(), engine_args[8]->as<ASTLiteral &>().value);
 
         return StorageBuffer::create(
-            args.database_name,
-            args.table_name, args.columns, args.constraints,
+            args.table_id,
+            args.columns,
+            args.constraints,
             args.context,
             num_buckets,
             StorageBuffer::Thresholds{min_time, min_rows, min_bytes},
diff --git a/dbms/src/Storages/StorageBuffer.h b/dbms/src/Storages/StorageBuffer.h
index ea08a9bd61afcfb92a967d41e16af7681c40aa35..9c27412e849c3323b0a56f22be22f3961b3ff7dc 100644
--- a/dbms/src/Storages/StorageBuffer.h
+++ b/dbms/src/Storages/StorageBuffer.h
@@ -135,11 +135,17 @@ protected:
     /** num_shards - the level of internal parallelism (the number of independent buffers)
       * The buffer is flushed if all minimum thresholds or at least one of the maximum thresholds are exceeded.
       */
-    StorageBuffer(const std::string & database_name_, const std::string & table_name_,
-        const ColumnsDescription & columns_, const ConstraintsDescription & constraints_,
+    StorageBuffer(
+        const StorageID & table_id_,
+        const ColumnsDescription & columns_,
+        const ConstraintsDescription & constraints_,
         Context & context_,
-        size_t num_shards_, const Thresholds & min_thresholds_, const Thresholds & max_thresholds_,
-        const String & destination_database_, const String & destination_table_, bool allow_materialized_);
+        size_t num_shards_,
+        const Thresholds & min_thresholds_,
+        const Thresholds & max_thresholds_,
+        const String & destination_database_,
+        const String & destination_table_,
+        bool allow_materialized_);
 };
 
 }
diff --git a/dbms/src/Storages/StorageDictionary.cpp b/dbms/src/Storages/StorageDictionary.cpp
index 1bfa0e86b144cf1cccca02ad032f973950dba149..51914b53ae626edb6da88d8216c9ff75a4760baf 100644
--- a/dbms/src/Storages/StorageDictionary.cpp
+++ b/dbms/src/Storages/StorageDictionary.cpp
@@ -24,15 +24,14 @@ namespace ErrorCodes
 
 
 StorageDictionary::StorageDictionary(
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const Context & context,
     bool attach,
     const String & dictionary_name_)
-    : IStorage({database_name_, table_name_}),
-    dictionary_name(dictionary_name_),
-    logger(&Poco::Logger::get("StorageDictionary"))
+    : IStorage(table_id_)
+    , dictionary_name(dictionary_name_)
+    , logger(&Poco::Logger::get("StorageDictionary"))
 {
     setColumns(columns_);
 
@@ -107,7 +106,7 @@ void registerStorageDictionary(StorageFactory & factory)
         String dictionary_name = args.engine_args[0]->as<ASTLiteral &>().value.safeGet<String>();
 
         return StorageDictionary::create(
-            args.database_name, args.table_name, args.columns, args.context, args.attach, dictionary_name);
+            args.table_id, args.columns, args.context, args.attach, dictionary_name);
     });
 }
 
diff --git a/dbms/src/Storages/StorageDictionary.h b/dbms/src/Storages/StorageDictionary.h
index 57f8a3d29072360398bb597f05215cb1801eb77d..1e741a0509477de1a8471747f53f1376b7d502b0 100644
--- a/dbms/src/Storages/StorageDictionary.h
+++ b/dbms/src/Storages/StorageDictionary.h
@@ -64,8 +64,7 @@ private:
 
 protected:
     StorageDictionary(
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const Context & context,
         bool attach,
diff --git a/dbms/src/Storages/StorageDistributed.cpp b/dbms/src/Storages/StorageDistributed.cpp
index 5d08648265dff681f29e6cf11f9dacb0241cb729..73742c3d739dec68d117da7ed79ac734656f3759 100644
--- a/dbms/src/Storages/StorageDistributed.cpp
+++ b/dbms/src/Storages/StorageDistributed.cpp
@@ -205,8 +205,7 @@ static ExpressionActionsPtr buildShardingKeyExpression(const ASTPtr & sharding_k
 }
 
 StorageDistributed::StorageDistributed(
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     const String & remote_database_,
@@ -216,12 +215,18 @@ StorageDistributed::StorageDistributed(
     const ASTPtr & sharding_key_,
     const String & relative_data_path_,
     bool attach_)
-    : IStorage({database_name_, table_name_}, ColumnsDescription({
-        {"_shard_num", std::make_shared<DataTypeUInt32>()},
-    }, true)),
-    remote_database(remote_database_), remote_table(remote_table_),
-    global_context(context_), cluster_name(global_context.getMacros()->expand(cluster_name_)), has_sharding_key(sharding_key_),
-    path(relative_data_path_.empty() ? "" : (context_.getPath() + relative_data_path_))
+    : IStorage(id_,
+               ColumnsDescription(
+                   {
+                       {"_shard_num", std::make_shared<DataTypeUInt32>()},
+                   },
+               true))
+    , remote_database(remote_database_)
+    , remote_table(remote_table_)
+    , global_context(context_)
+    , cluster_name(global_context.getMacros()->expand(cluster_name_))
+    , has_sharding_key(sharding_key_)
+    , path(relative_data_path_.empty() ? "" : (context_.getPath() + relative_data_path_))
 {
     setColumns(columns_);
     setConstraints(constraints_);
@@ -236,15 +241,14 @@ StorageDistributed::StorageDistributed(
     if (!attach_ && !cluster_name.empty())
     {
         size_t num_local_shards = global_context.getCluster(cluster_name)->getLocalShardCount();
-        if (num_local_shards && remote_database == database_name_ && remote_table == table_name_)
-            throw Exception("Distributed table " + table_name_ + " looks at itself", ErrorCodes::INFINITE_LOOP);
+        if (num_local_shards && remote_database == id_.database_name && remote_table == id_.table_name)
+            throw Exception("Distributed table " + id_.table_name + " looks at itself", ErrorCodes::INFINITE_LOOP);
     }
 }
 
 
 StorageDistributed::StorageDistributed(
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     ASTPtr remote_table_function_ptr_,
@@ -253,34 +257,34 @@ StorageDistributed::StorageDistributed(
     const ASTPtr & sharding_key_,
     const String & relative_data_path_,
     bool attach)
-    : StorageDistributed(database_name_, table_name_, columns_, constraints_, String{}, String{}, cluster_name_, context_, sharding_key_, relative_data_path_, attach)
+    : StorageDistributed(id_, columns_, constraints_, String{}, String{}, cluster_name_, context_, sharding_key_, relative_data_path_, attach)
 {
-    remote_table_function_ptr = remote_table_function_ptr_;
+    remote_table_function_ptr = std::move(remote_table_function_ptr_);
 }
 
 
 StoragePtr StorageDistributed::createWithOwnCluster(
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const String & remote_database_,       /// database on remote servers.
     const String & remote_table_,          /// The name of the table on the remote servers.
     ClusterPtr owned_cluster_,
     const Context & context_)
 {
-    auto res = create(String{}, table_name_, columns_, ConstraintsDescription{}, remote_database_, remote_table_, String{}, context_, ASTPtr(), String(), false);
-    res->owned_cluster = owned_cluster_;
+    auto res = create(table_id_, columns_, ConstraintsDescription{}, remote_database_, remote_table_, String{}, context_, ASTPtr(), String(), false);
+    res->owned_cluster = std::move(owned_cluster_);
     return res;
 }
 
 
 StoragePtr StorageDistributed::createWithOwnCluster(
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     ASTPtr & remote_table_function_ptr_,
     ClusterPtr & owned_cluster_,
     const Context & context_)
 {
-    auto res = create(String{}, table_name_, columns_, ConstraintsDescription{}, remote_table_function_ptr_, String{}, context_, ASTPtr(), String(), false);
+    auto res = create(table_id_, columns_, ConstraintsDescription{}, remote_table_function_ptr_, String{}, context_, ASTPtr(), String(), false);
     res->owned_cluster = owned_cluster_;
     return res;
 }
@@ -662,7 +666,7 @@ void registerStorageDistributed(StorageFactory & factory)
         }
 
         return StorageDistributed::create(
-            args.database_name, args.table_name, args.columns, args.constraints,
+            args.table_id, args.columns, args.constraints,
             remote_database, remote_table, cluster_name,
             args.context, sharding_key, args.relative_data_path,
             args.attach);
diff --git a/dbms/src/Storages/StorageDistributed.h b/dbms/src/Storages/StorageDistributed.h
index 2de7f8d7ab24960bf7156dd95f38f9737c7eb328..83fc1c5ee0bcc10c87cf5c79951664f40be2d648 100644
--- a/dbms/src/Storages/StorageDistributed.h
+++ b/dbms/src/Storages/StorageDistributed.h
@@ -37,7 +37,7 @@ public:
     ~StorageDistributed() override;
 
     static StoragePtr createWithOwnCluster(
-        const std::string & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const String & remote_database_,       /// database on remote servers.
         const String & remote_table_,          /// The name of the table on the remote servers.
@@ -45,7 +45,7 @@ public:
         const Context & context_);
 
     static StoragePtr createWithOwnCluster(
-        const std::string & table_name_,
+            const StorageID & table_id_,
         const ColumnsDescription & columns_,
         ASTPtr & remote_table_function_ptr_,     /// Table function ptr.
         ClusterPtr & owned_cluster_,
@@ -155,8 +155,7 @@ public:
 
 protected:
     StorageDistributed(
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         const String & remote_database_,
@@ -168,8 +167,7 @@ protected:
         bool attach_);
 
     StorageDistributed(
-        const String & database_name,
-        const String & table_name_,
+        const StorageID & id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         ASTPtr remote_table_function_ptr_,
diff --git a/dbms/src/Storages/StorageFactory.cpp b/dbms/src/Storages/StorageFactory.cpp
index 23efcd8aa3930f0ebd089a9e8d9c93265d5436ae..b63e0b9e7c325cbfed691ef04dde6f3bc28572fc 100644
--- a/dbms/src/Storages/StorageFactory.cpp
+++ b/dbms/src/Storages/StorageFactory.cpp
@@ -5,6 +5,7 @@
 #include <Common/Exception.h>
 #include <Common/StringUtils/StringUtils.h>
 #include <IO/WriteHelpers.h>
+#include <Storages/IStorage.h>
 
 namespace DB
 {
@@ -41,13 +42,10 @@ void StorageFactory::registerStorage(const std::string & name, Creator creator)
 StoragePtr StorageFactory::get(
     const ASTCreateQuery & query,
     const String & relative_data_path,
-    const String & table_name,
-    const String & database_name,
     Context & local_context,
     Context & context,
     const ColumnsDescription & columns,
     const ConstraintsDescription & constraints,
-    bool attach,
     bool has_force_restore_data_flag) const
 {
     String name;
@@ -151,13 +149,12 @@ StoragePtr StorageFactory::get(
         .storage_def = storage_def,
         .query = query,
         .relative_data_path = relative_data_path,
-        .table_name = table_name,
-        .database_name = database_name,
+        .table_id = StorageID(query.database, query.table, query.uuid),
         .local_context = local_context,
         .context = context,
         .columns = columns,
         .constraints = constraints,
-        .attach = attach,
+        .attach = query.attach,
         .has_force_restore_data_flag = has_force_restore_data_flag
     };
 
diff --git a/dbms/src/Storages/StorageFactory.h b/dbms/src/Storages/StorageFactory.h
index 205096147c8a07a8221939530e7f2913f598a3f1..6f45613ae1d4bda4a048cd5bd24f01242092f921 100644
--- a/dbms/src/Storages/StorageFactory.h
+++ b/dbms/src/Storages/StorageFactory.h
@@ -15,6 +15,7 @@ namespace DB
 class Context;
 class ASTCreateQuery;
 class ASTStorage;
+struct StorageID;
 
 
 /** Allows to create a table by the name and parameters of the engine.
@@ -36,8 +37,7 @@ public:
         /// Path to table data.
         /// Relative to <path> from server config (possibly <path> of some <disk> of some <volume> for *MergeTree)
         const String & relative_data_path;
-        const String & table_name;
-        const String & database_name;
+        const StorageID & table_id;
         Context & local_context;
         Context & context;
         const ColumnsDescription & columns;
@@ -51,13 +51,10 @@ public:
     StoragePtr get(
         const ASTCreateQuery & query,
         const String & relative_data_path,
-        const String & table_name,
-        const String & database_name,
         Context & local_context,
         Context & context,
         const ColumnsDescription & columns,
         const ConstraintsDescription & constraints,
-        bool attach,
         bool has_force_restore_data_flag) const;
 
     /// Register a table engine by its name.
diff --git a/dbms/src/Storages/StorageFile.cpp b/dbms/src/Storages/StorageFile.cpp
index ec440b1c09a467911e46979029724685bae35299..d79ecaf9da1b3ef3a506ef4ce4414aa601b0b71f 100644
--- a/dbms/src/Storages/StorageFile.cpp
+++ b/dbms/src/Storages/StorageFile.cpp
@@ -165,8 +165,10 @@ StorageFile::StorageFile(const std::string & relative_table_dir_path, CommonArgu
 }
 
 StorageFile::StorageFile(CommonArguments args)
-    : IStorage({args.database_name, args.table_name}), format_name(args.format_name),
-      compression_method(args.compression_method), base_path(args.context.getPath())
+    : IStorage(args.table_id)
+    , format_name(args.format_name)
+    , compression_method(args.compression_method)
+    , base_path(args.context.getPath())
 {
     setColumns(args.columns);
     setConstraints(args.constraints);
@@ -378,7 +380,7 @@ void registerStorageFile(StorageFactory & factory)
         String format_name = engine_args[0]->as<ASTLiteral &>().value.safeGet<String>();
 
         String compression_method;
-        StorageFile::CommonArguments common_args{args.database_name, args.table_name, format_name, compression_method,
+        StorageFile::CommonArguments common_args{args.table_id, format_name, compression_method,
                                                  args.columns, args.constraints, args.context};
 
         if (engine_args.size() == 1)    /// Table in database
diff --git a/dbms/src/Storages/StorageFile.h b/dbms/src/Storages/StorageFile.h
index bbe75b1021714d4600142eeccf77e0320cfaabbd..a2f3af21e2085866a07f67721aae23deba51e293 100644
--- a/dbms/src/Storages/StorageFile.h
+++ b/dbms/src/Storages/StorageFile.h
@@ -42,8 +42,7 @@ public:
 
     struct CommonArguments
     {
-        const std::string & database_name;
-        const std::string & table_name;
+        const StorageID & table_id;
         const std::string & format_name;
         const std::string & compression_method;
         const ColumnsDescription & columns;
diff --git a/dbms/src/Storages/StorageHDFS.cpp b/dbms/src/Storages/StorageHDFS.cpp
index 73cde47e9e5fe7a524226d8f4edaa30d63619458..f0de9bf3894a9a53cf156c60fb865433f798c216 100644
--- a/dbms/src/Storages/StorageHDFS.cpp
+++ b/dbms/src/Storages/StorageHDFS.cpp
@@ -35,14 +35,13 @@ namespace ErrorCodes
 }
 
 StorageHDFS::StorageHDFS(const String & uri_,
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const String & format_name_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     Context & context_,
     const String & compression_method_ = "")
-    : IStorage({database_name_, table_name_})
+    : IStorage(table_id_)
     , uri(uri_)
     , format_name(format_name_)
     , context(context_)
@@ -252,7 +251,7 @@ void registerStorageHDFS(StorageFactory & factory)
             compression_method = engine_args[2]->as<ASTLiteral &>().value.safeGet<String>();
         } else compression_method = "auto";
 
-        return StorageHDFS::create(url, args.database_name, args.table_name, format_name, args.columns, args.constraints, args.context, compression_method);
+        return StorageHDFS::create(url, args.table_id, format_name, args.columns, args.constraints, args.context, compression_method);
     });
 }
 
diff --git a/dbms/src/Storages/StorageHDFS.h b/dbms/src/Storages/StorageHDFS.h
index 1ce2163099a6e3beb2edc3b732b4eaba15973f8e..42f1891597ecca2c6512c4b7f9c826a60e55cbd0 100644
--- a/dbms/src/Storages/StorageHDFS.h
+++ b/dbms/src/Storages/StorageHDFS.h
@@ -30,8 +30,7 @@ public:
 
 protected:
     StorageHDFS(const String & uri_,
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const String & format_name_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
diff --git a/dbms/src/Storages/StorageInput.cpp b/dbms/src/Storages/StorageInput.cpp
index eece306a20a5498a68ae63e07aba052a6837cecf..4f41ba20dfaf1d7708fc1544e02e683ed7c683fa 100644
--- a/dbms/src/Storages/StorageInput.cpp
+++ b/dbms/src/Storages/StorageInput.cpp
@@ -15,7 +15,7 @@ namespace ErrorCodes
     extern const int INVALID_USAGE_OF_INPUT;
 }
 
-StorageInput::StorageInput(const String &table_name_, const ColumnsDescription & columns_)
+StorageInput::StorageInput(const String & table_name_, const ColumnsDescription & columns_)
     : IStorage({"", table_name_}, columns_)
 {
     setColumns(columns_);
diff --git a/dbms/src/Storages/StorageJoin.cpp b/dbms/src/Storages/StorageJoin.cpp
index dde7d672bbd64509ca1870a593644c65fb2f5738..c651a0ba261a94d64a034f97a605e5eee84330a5 100644
--- a/dbms/src/Storages/StorageJoin.cpp
+++ b/dbms/src/Storages/StorageJoin.cpp
@@ -29,8 +29,7 @@ namespace ErrorCodes
 
 StorageJoin::StorageJoin(
     const String & relative_path_,
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const Names & key_names_,
     bool use_nulls_,
     SizeLimits limits_,
@@ -40,7 +39,7 @@ StorageJoin::StorageJoin(
     const ConstraintsDescription & constraints_,
     bool overwrite,
     const Context & context_)
-    : StorageSetOrJoinBase{relative_path_, database_name_, table_name_, columns_, constraints_, context_}
+    : StorageSetOrJoinBase{relative_path_, table_id_, columns_, constraints_, context_}
     , key_names(key_names_)
     , use_nulls(use_nulls_)
     , limits(limits_)
@@ -172,8 +171,7 @@ void registerStorageJoin(StorageFactory & factory)
 
         return StorageJoin::create(
             args.relative_data_path,
-            args.database_name,
-            args.table_name,
+            args.table_id,
             key_names,
             join_use_nulls,
             SizeLimits{max_rows_in_join, max_bytes_in_join, join_overflow_mode},
diff --git a/dbms/src/Storages/StorageJoin.h b/dbms/src/Storages/StorageJoin.h
index ebd0c5ff0d57051807fee749e6e315629534d38f..22500a23baa0ef717bc41107360a9879c6b95991 100644
--- a/dbms/src/Storages/StorageJoin.h
+++ b/dbms/src/Storages/StorageJoin.h
@@ -62,8 +62,7 @@ private:
 protected:
     StorageJoin(
         const String & relative_path_,
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const Names & key_names_,
         bool use_nulls_,
         SizeLimits limits_,
diff --git a/dbms/src/Storages/StorageLog.cpp b/dbms/src/Storages/StorageLog.cpp
index 7a948eda2005c34335d86fd43422c612b0325466..6dc544e2c00180f5f19ece81ff531922dbd86902 100644
--- a/dbms/src/Storages/StorageLog.cpp
+++ b/dbms/src/Storages/StorageLog.cpp
@@ -419,15 +419,16 @@ void LogBlockOutputStream::writeMarks(MarksForColumns && marks)
 
 StorageLog::StorageLog(
     const std::string & relative_path_,
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     size_t max_compress_block_size_,
     const Context & context_)
-    : IStorage({database_name_, table_name_}), base_path(context_.getPath()), path(base_path + relative_path_),
-    max_compress_block_size(max_compress_block_size_),
-    file_checker(path + "sizes.json")
+    : IStorage(table_id_)
+    , base_path(context_.getPath())
+    , path(base_path + relative_path_)
+    , max_compress_block_size(max_compress_block_size_)
+    , file_checker(path + "sizes.json")
 {
     setColumns(columns_);
     setConstraints(constraints_);
@@ -648,7 +649,7 @@ void registerStorageLog(StorageFactory & factory)
                 ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
 
         return StorageLog::create(
-            args.relative_data_path, args.database_name, args.table_name, args.columns, args.constraints,
+            args.relative_data_path, args.table_id, args.columns, args.constraints,
             args.context.getSettings().max_compress_block_size, args.context);
     });
 }
diff --git a/dbms/src/Storages/StorageLog.h b/dbms/src/Storages/StorageLog.h
index 6cea51f96e44ceea97e0a4c12574df7cb3f2fe7b..4d223312832e50ca84f0c636d0dffcfd183bddc6 100644
--- a/dbms/src/Storages/StorageLog.h
+++ b/dbms/src/Storages/StorageLog.h
@@ -53,8 +53,7 @@ protected:
       */
     StorageLog(
         const std::string & relative_path_,
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         size_t max_compress_block_size_,
diff --git a/dbms/src/Storages/StorageMaterializedView.cpp b/dbms/src/Storages/StorageMaterializedView.cpp
index 39bd4238ea4cb47d9ff1890a57dd53d43ab667e1..88e5399234a2341e5d76ffab6410f6317e3c3cb0 100644
--- a/dbms/src/Storages/StorageMaterializedView.cpp
+++ b/dbms/src/Storages/StorageMaterializedView.cpp
@@ -94,13 +94,12 @@ static void checkAllowedQueries(const ASTSelectQuery & query)
 
 
 StorageMaterializedView::StorageMaterializedView(
-    const String & table_name_,
-    const String & database_name_,
+    const StorageID & table_id_,
     Context & local_context,
     const ASTCreateQuery & query,
     const ColumnsDescription & columns_,
     bool attach_)
-    : IStorage({database_name_, table_name_}), global_context(local_context.getGlobalContext())
+    : IStorage(table_id_), global_context(local_context.getGlobalContext())
 {
     setColumns(columns_);
 
@@ -126,7 +125,7 @@ StorageMaterializedView::StorageMaterializedView(
     if (!select_table_name.empty())
         global_context.addDependency(
             DatabaseAndTableName(select_database_name, select_table_name),
-            DatabaseAndTableName(database_name_, table_name_));   //FIXME
+            DatabaseAndTableName(table_id_.database_name, table_id_.table_name));   //FIXME
 
     // If the destination table is not set, use inner table
     if (!query.to_table.empty())
@@ -136,8 +135,8 @@ StorageMaterializedView::StorageMaterializedView(
     }
     else
     {
-        target_database_name = database_name_;
-        target_table_name = generateInnerTableName(table_name_);
+        target_database_name = table_id_.database_name;
+        target_table_name = generateInnerTableName(table_id_.table_name);
         has_inner_table = true;
     }
 
@@ -168,7 +167,7 @@ StorageMaterializedView::StorageMaterializedView(
             if (!select_table_name.empty())
                 global_context.removeDependency(
                     DatabaseAndTableName(select_database_name, select_table_name),
-                    DatabaseAndTableName(database_name_, table_name_)); //FIXME
+                    DatabaseAndTableName(table_id_.database_name, table_id_.table_name)); //FIXME
 
             throw;
         }
@@ -390,7 +389,7 @@ void registerStorageMaterializedView(StorageFactory & factory)
     {
         /// Pass local_context here to convey setting for inner table
         return StorageMaterializedView::create(
-            args.table_name, args.database_name, args.local_context, args.query,
+            args.table_id, args.local_context, args.query,
             args.columns, args.attach);
     });
 }
diff --git a/dbms/src/Storages/StorageMaterializedView.h b/dbms/src/Storages/StorageMaterializedView.h
index e4e118d41f5418c21a9c879ca00cf1d5f8860613..cac32d978de2ad0d1fd7caf888f164eb97dc2332 100644
--- a/dbms/src/Storages/StorageMaterializedView.h
+++ b/dbms/src/Storages/StorageMaterializedView.h
@@ -78,8 +78,7 @@ private:
 
 protected:
     StorageMaterializedView(
-        const String & table_name_,
-        const String & database_name_,
+        const StorageID & table_id_,
         Context & local_context,
         const ASTCreateQuery & query,
         const ColumnsDescription & columns_,
diff --git a/dbms/src/Storages/StorageMemory.cpp b/dbms/src/Storages/StorageMemory.cpp
index 0489f7bb1152aff2873f3dd514d65da8a947994d..b2cb5682f6d90dad382e429f74a3f16c4cc61fef 100644
--- a/dbms/src/Storages/StorageMemory.cpp
+++ b/dbms/src/Storages/StorageMemory.cpp
@@ -74,8 +74,8 @@ private:
 };
 
 
-StorageMemory::StorageMemory(String database_name_, String table_name_, ColumnsDescription columns_description_, ConstraintsDescription constraints_)
-    : IStorage({database_name_, table_name_})
+StorageMemory::StorageMemory(const StorageID & table_id_, ColumnsDescription columns_description_, ConstraintsDescription constraints_)
+    : IStorage(table_id_)
 {
     setColumns(std::move(columns_description_));
     setConstraints(std::move(constraints_));
@@ -145,7 +145,7 @@ void registerStorageMemory(StorageFactory & factory)
                 "Engine " + args.engine_name + " doesn't support any arguments (" + toString(args.engine_args.size()) + " given)",
                 ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
 
-        return StorageMemory::create(args.database_name, args.table_name, args.columns, args.constraints);
+        return StorageMemory::create(args.table_id, args.columns, args.constraints);
     });
 }
 
diff --git a/dbms/src/Storages/StorageMemory.h b/dbms/src/Storages/StorageMemory.h
index d6eb40ef7d0bb0ab165f7b1a21ef9c3cbd2562e7..1e66b17606b32172319132f611574a70ecaf95d3 100644
--- a/dbms/src/Storages/StorageMemory.h
+++ b/dbms/src/Storages/StorageMemory.h
@@ -49,7 +49,7 @@ private:
     std::mutex mutex;
 
 protected:
-    StorageMemory(String database_name_, String table_name_, ColumnsDescription columns_description_, ConstraintsDescription constraints_);
+    StorageMemory(const StorageID & table_id_, ColumnsDescription columns_description_, ConstraintsDescription constraints_);
 };
 
 }
diff --git a/dbms/src/Storages/StorageMerge.cpp b/dbms/src/Storages/StorageMerge.cpp
index d2d95edd22080923b20f53d4a54deacb8102a09a..c39a3f003ad3d02b9622d976d2d4c3689b68019f 100644
--- a/dbms/src/Storages/StorageMerge.cpp
+++ b/dbms/src/Storages/StorageMerge.cpp
@@ -46,13 +46,12 @@ namespace ErrorCodes
 
 
 StorageMerge::StorageMerge(
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const String & source_database_,
     const String & table_name_regexp_,
     const Context & context_)
-    : IStorage({database_name_, table_name_}, ColumnsDescription({{"_table", std::make_shared<DataTypeString>()}}, true))
+    : IStorage(table_id_, ColumnsDescription({{"_table", std::make_shared<DataTypeString>()}}, true))
     , source_database(source_database_)
     , table_name_regexp(table_name_regexp_)
     , global_context(context_)
@@ -512,7 +511,7 @@ void registerStorageMerge(StorageFactory & factory)
         String table_name_regexp = engine_args[1]->as<ASTLiteral &>().value.safeGet<String>();
 
         return StorageMerge::create(
-            args.database_name, args.table_name, args.columns,
+            args.table_id, args.columns,
             source_database, table_name_regexp, args.context);
     });
 }
diff --git a/dbms/src/Storages/StorageMerge.h b/dbms/src/Storages/StorageMerge.h
index b14e8972dffaae6978f4edec3345f30272895213..b212af5500931bccc6e1f2f0b7393ae4a504f8db 100644
--- a/dbms/src/Storages/StorageMerge.h
+++ b/dbms/src/Storages/StorageMerge.h
@@ -65,8 +65,7 @@ private:
 
 protected:
     StorageMerge(
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const String & source_database_,
         const String & table_name_regexp_,
diff --git a/dbms/src/Storages/StorageMergeTree.cpp b/dbms/src/Storages/StorageMergeTree.cpp
index 8b2ccb8ff0770b3a33bab8e288a5a4564f624204..f074ff618030015d11d2244575c1454a3a7ed505 100644
--- a/dbms/src/Storages/StorageMergeTree.cpp
+++ b/dbms/src/Storages/StorageMergeTree.cpp
@@ -53,8 +53,7 @@ namespace ActionLocks
 
 
 StorageMergeTree::StorageMergeTree(
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const String & relative_data_path_,
     const ColumnsDescription & columns_,
     const IndicesDescription & indices_,
@@ -70,13 +69,25 @@ StorageMergeTree::StorageMergeTree(
     const MergingParams & merging_params_,
     std::unique_ptr<MergeTreeSettings> storage_settings_,
     bool has_force_restore_data_flag)
-        : MergeTreeData(database_name_, table_name_, relative_data_path_,
-            columns_, indices_, constraints_,
-            context_, date_column_name, partition_by_ast_, order_by_ast_, primary_key_ast_,
-            sample_by_ast_, ttl_table_ast_, merging_params_,
-            std::move(storage_settings_), false, attach),
-        reader(*this), writer(*this),
-        merger_mutator(*this, global_context.getBackgroundPool().getNumberOfThreads())
+        : MergeTreeData(table_id_,
+                        relative_data_path_,
+                        columns_,
+                        indices_,
+                        constraints_,
+                        context_,
+                        date_column_name,
+                        partition_by_ast_,
+                        order_by_ast_,
+                        primary_key_ast_,
+                        sample_by_ast_,
+                        ttl_table_ast_,
+                        merging_params_,
+                        std::move(storage_settings_),
+                        false,      /// require_part_metadata
+                        attach)
+        , reader(*this)
+        , writer(*this)
+        , merger_mutator(*this, global_context.getBackgroundPool().getNumberOfThreads())
 {
     loadDataParts(has_force_restore_data_flag);
 
diff --git a/dbms/src/Storages/StorageMergeTree.h b/dbms/src/Storages/StorageMergeTree.h
index 6db02ec065e9ba63e497d9384b98bd4c01c9ee6f..57b188668450df2c94e0d98956e7a6ddc4bec584 100644
--- a/dbms/src/Storages/StorageMergeTree.h
+++ b/dbms/src/Storages/StorageMergeTree.h
@@ -156,8 +156,7 @@ protected:
       * See MergeTreeData constructor for comments on parameters.
       */
     StorageMergeTree(
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const String & relative_data_path_,
         const ColumnsDescription & columns_,
         const IndicesDescription & indices_,
diff --git a/dbms/src/Storages/StorageMySQL.cpp b/dbms/src/Storages/StorageMySQL.cpp
index 2b224978b33f33a39ab008c0e0e12af945462639..6f3c6d5b5ae6c0652202aadd6cc1010b6b3f1381 100644
--- a/dbms/src/Storages/StorageMySQL.cpp
+++ b/dbms/src/Storages/StorageMySQL.cpp
@@ -37,8 +37,7 @@ static String backQuoteMySQL(const String & x)
 }
 
 StorageMySQL::StorageMySQL(
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     mysqlxx::Pool && pool_,
     const std::string & remote_database_name_,
     const std::string & remote_table_name_,
@@ -47,7 +46,7 @@ StorageMySQL::StorageMySQL(
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     const Context & context_)
-    : IStorage({database_name_, table_name_})
+    : IStorage(table_id_)
     , remote_database_name(remote_database_name_)
     , remote_table_name(remote_table_name_)
     , replace_query{replace_query_}
@@ -234,8 +233,7 @@ void registerStorageMySQL(StorageFactory & factory)
                 ErrorCodes::BAD_ARGUMENTS);
 
         return StorageMySQL::create(
-            args.database_name,
-            args.table_name,
+            args.table_id,
             std::move(pool),
             remote_database,
             remote_table,
diff --git a/dbms/src/Storages/StorageMySQL.h b/dbms/src/Storages/StorageMySQL.h
index af486cbd9647a4e7ecf67759f7f78e38407ab4a8..574221377dc593004f9e7f4e23d575a588cc3a4f 100644
--- a/dbms/src/Storages/StorageMySQL.h
+++ b/dbms/src/Storages/StorageMySQL.h
@@ -21,8 +21,7 @@ class StorageMySQL : public ext::shared_ptr_helper<StorageMySQL>, public IStorag
     friend struct ext::shared_ptr_helper<StorageMySQL>;
 public:
     StorageMySQL(
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & table_id_,
         mysqlxx::Pool && pool_,
         const std::string & remote_database_name_,
         const std::string & remote_table_name_,
diff --git a/dbms/src/Storages/StorageNull.cpp b/dbms/src/Storages/StorageNull.cpp
index 67d2ea0e48ee0837f022acbd9ff24a099e6629f6..5979a00497b9952692f3faead08ee7a06ecf263c 100644
--- a/dbms/src/Storages/StorageNull.cpp
+++ b/dbms/src/Storages/StorageNull.cpp
@@ -26,7 +26,7 @@ void registerStorageNull(StorageFactory & factory)
                 "Engine " + args.engine_name + " doesn't support any arguments (" + toString(args.engine_args.size()) + " given)",
                 ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
 
-        return StorageNull::create(args.database_name, args.table_name, args.columns, args.constraints);
+        return StorageNull::create(args.table_id, args.columns, args.constraints);
     });
 }
 
diff --git a/dbms/src/Storages/StorageNull.h b/dbms/src/Storages/StorageNull.h
index f52780c9993ef315eaa1dbf9dd87c44de5764329..ec0503decfb5edb00e7826abfcc2a7b16777eefd 100644
--- a/dbms/src/Storages/StorageNull.h
+++ b/dbms/src/Storages/StorageNull.h
@@ -42,8 +42,8 @@ public:
 private:
 
 protected:
-    StorageNull(String database_name_, String table_name_, ColumnsDescription columns_description_, ConstraintsDescription constraints_)
-        : IStorage({database_name_, table_name_})
+    StorageNull(const StorageID & table_id_, ColumnsDescription columns_description_, ConstraintsDescription constraints_)
+        : IStorage(table_id_)
     {
         setColumns(std::move(columns_description_));
         setConstraints(std::move(constraints_));
diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp
index f0b579456547d4ecf7f117956ec1aa4099a34ede..b4be727615ffe40d9d6643267024d99dfc10caa7 100644
--- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp
+++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp
@@ -191,8 +191,7 @@ StorageReplicatedMergeTree::StorageReplicatedMergeTree(
     const String & zookeeper_path_,
     const String & replica_name_,
     bool attach,
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const String & relative_data_path_,
     const ColumnsDescription & columns_,
     const IndicesDescription & indices_,
@@ -207,17 +206,34 @@ StorageReplicatedMergeTree::StorageReplicatedMergeTree(
     const MergingParams & merging_params_,
     std::unique_ptr<MergeTreeSettings> settings_,
     bool has_force_restore_data_flag)
-        : MergeTreeData(database_name_, table_name_, relative_data_path_,
-            columns_, indices_, constraints_,
-            context_, date_column_name, partition_by_ast_, order_by_ast_, primary_key_ast_,
-            sample_by_ast_, ttl_table_ast_, merging_params_,
-            std::move(settings_), true, attach,
-            [this] (const std::string & name) { enqueuePartForCheck(name); }),
-        zookeeper_path(global_context.getMacros()->expand(zookeeper_path_, database_name_, table_name_)),
-        replica_name(global_context.getMacros()->expand(replica_name_, database_name_, table_name_)),
-        reader(*this), writer(*this), merger_mutator(*this, global_context.getBackgroundPool().getNumberOfThreads()),
-        queue(*this), fetcher(*this), cleanup_thread(*this), alter_thread(*this),
-        part_check_thread(*this), restarting_thread(*this)
+        : MergeTreeData(table_id_,
+                        relative_data_path_,
+                        columns_,
+                        indices_,
+                        constraints_,
+                        context_,
+                        date_column_name,
+                        partition_by_ast_,
+                        order_by_ast_,
+                        primary_key_ast_,
+                        sample_by_ast_,
+                        ttl_table_ast_,
+                        merging_params_,
+                        std::move(settings_),
+                        true,                   /// require_part_metadata
+                        attach,
+                        [this] (const std::string & name) { enqueuePartForCheck(name); })
+        , zookeeper_path(global_context.getMacros()->expand(zookeeper_path_, table_id_.database_name, table_id_.table_name))
+        , replica_name(global_context.getMacros()->expand(replica_name_, table_id_.database_name, table_id_.table_name))
+        , reader(*this)
+        , writer(*this)
+        , merger_mutator(*this, global_context.getBackgroundPool().getNumberOfThreads())
+        , queue(*this)
+        , fetcher(*this)
+        , cleanup_thread(*this)
+        , alter_thread(*this)
+        , part_check_thread(*this)
+        , restarting_thread(*this)
 {
     if (!zookeeper_path.empty() && zookeeper_path.back() == '/')
         zookeeper_path.resize(zookeeper_path.size() - 1);
diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.h b/dbms/src/Storages/StorageReplicatedMergeTree.h
index 741455d034ccd99cf131094d5f367f7863b6a6a3..ccd8b8028c3a365077ef672409a8fcbf8df4e2cc 100644
--- a/dbms/src/Storages/StorageReplicatedMergeTree.h
+++ b/dbms/src/Storages/StorageReplicatedMergeTree.h
@@ -541,7 +541,7 @@ protected:
         const String & zookeeper_path_,
         const String & replica_name_,
         bool attach,
-        const String & database_name_, const String & name_,
+        const StorageID & table_id_,
         const String & relative_data_path_,
         const ColumnsDescription & columns_,
         const IndicesDescription & indices_,
diff --git a/dbms/src/Storages/StorageS3.cpp b/dbms/src/Storages/StorageS3.cpp
index 04b1f049d08803db2eb0f13e8bbd448de268f74c..b0996c763bc4f2eea23305c8db4200d0fcedb377 100644
--- a/dbms/src/Storages/StorageS3.cpp
+++ b/dbms/src/Storages/StorageS3.cpp
@@ -132,18 +132,18 @@ namespace
 }
 
 
-StorageS3::StorageS3(const S3::URI & uri_,
+StorageS3::StorageS3(
+    const S3::URI & uri_,
     const String & access_key_id_,
     const String & secret_access_key_,
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const String & format_name_,
     UInt64 min_upload_part_size_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     Context & context_,
     const String & compression_method_ = "")
-    : IStorage({database_name_, table_name_}, columns_)
+    : IStorage({table_id_}, columns_)
     , uri(uri_)
     , context_global(context_)
     , format_name(format_name_)
@@ -225,7 +225,7 @@ void registerStorageS3(StorageFactory & factory)
         else
             compression_method = "auto";
 
-        return StorageS3::create(s3_uri, access_key_id, secret_access_key, args.database_name, args.table_name, format_name, min_upload_part_size, args.columns, args.constraints, args.context);
+        return StorageS3::create(s3_uri, access_key_id, secret_access_key, args.table_id, format_name, min_upload_part_size, args.columns, args.constraints, args.context);
     });
 }
 
diff --git a/dbms/src/Storages/StorageS3.h b/dbms/src/Storages/StorageS3.h
index 76ee8c08004bdedd80e22b0a5b0d3766c73d5cbb..9854f70a733a95ce21dfaea9719bda768eb882cd 100644
--- a/dbms/src/Storages/StorageS3.h
+++ b/dbms/src/Storages/StorageS3.h
@@ -28,8 +28,7 @@ public:
     StorageS3(const S3::URI & uri,
         const String & access_key_id,
         const String & secret_access_key,
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const String & format_name_,
         UInt64 min_upload_part_size_,
         const ColumnsDescription & columns_,
diff --git a/dbms/src/Storages/StorageSet.cpp b/dbms/src/Storages/StorageSet.cpp
index 81267cbc4f680476f2c2300fb5b708eb1fd17a0a..30f20b7df57b97e7244b5d6ba2612571b574b544 100644
--- a/dbms/src/Storages/StorageSet.cpp
+++ b/dbms/src/Storages/StorageSet.cpp
@@ -89,12 +89,11 @@ BlockOutputStreamPtr StorageSetOrJoinBase::write(const ASTPtr & /*query*/, const
 
 StorageSetOrJoinBase::StorageSetOrJoinBase(
     const String & relative_path_,
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     const Context & context_)
-    : IStorage({database_name_, table_name_})
+    : IStorage(table_id_)
 {
     setColumns(columns_);
     setConstraints(constraints_);
@@ -110,12 +109,11 @@ StorageSetOrJoinBase::StorageSetOrJoinBase(
 
 StorageSet::StorageSet(
     const String & relative_path_,
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     const Context & context_)
-    : StorageSetOrJoinBase{relative_path_, database_name_, table_name_, columns_, constraints_, context_},
+    : StorageSetOrJoinBase{relative_path_, table_id_, columns_, constraints_, context_},
     set(std::make_shared<Set>(SizeLimits(), false))
 {
     Block header = getSampleBlock();
@@ -222,7 +220,7 @@ void registerStorageSet(StorageFactory & factory)
                 "Engine " + args.engine_name + " doesn't support any arguments (" + toString(args.engine_args.size()) + " given)",
                 ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
 
-        return StorageSet::create(args.relative_data_path, args.database_name, args.table_name, args.columns, args.constraints, args.context);
+        return StorageSet::create(args.relative_data_path, args.table_id, args.columns, args.constraints, args.context);
     });
 }
 
diff --git a/dbms/src/Storages/StorageSet.h b/dbms/src/Storages/StorageSet.h
index 8934b16cd7d11dce04c1dfc6e4b4cbeb67b0058d..41e2e9ccdd6defb6d84545b064826cd093c2ce1b 100644
--- a/dbms/src/Storages/StorageSet.h
+++ b/dbms/src/Storages/StorageSet.h
@@ -28,8 +28,7 @@ public:
 protected:
     StorageSetOrJoinBase(
         const String & relative_path_,
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         const Context & context_);
@@ -80,8 +79,7 @@ private:
 protected:
     StorageSet(
         const String & relative_path_,
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         const Context & context_);
diff --git a/dbms/src/Storages/StorageStripeLog.cpp b/dbms/src/Storages/StorageStripeLog.cpp
index 7a79570835aca62bbe0b21839dc77a17a9c0fc2a..f7a90f2239afd2d327c16ae04af845fa3b83b756 100644
--- a/dbms/src/Storages/StorageStripeLog.cpp
+++ b/dbms/src/Storages/StorageStripeLog.cpp
@@ -195,18 +195,18 @@ private:
 
 StorageStripeLog::StorageStripeLog(
     const std::string & relative_path_,
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     bool attach,
     size_t max_compress_block_size_,
     const Context & context_)
-    : IStorage({database_name_, table_name_}),
-    base_path(context_.getPath()), path(base_path + relative_path_),
-    max_compress_block_size(max_compress_block_size_),
-    file_checker(path + "sizes.json"),
-    log(&Logger::get("StorageStripeLog"))
+    : IStorage(table_id_)
+    , base_path(context_.getPath())
+    , path(base_path + relative_path_)
+    , max_compress_block_size(max_compress_block_size_)
+    , file_checker(path + "sizes.json")
+    , log(&Logger::get("StorageStripeLog"))
 {
     setColumns(columns_);
     setConstraints(constraints_);
@@ -315,7 +315,7 @@ void registerStorageStripeLog(StorageFactory & factory)
                 ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
 
         return StorageStripeLog::create(
-            args.relative_data_path, args.database_name, args.table_name, args.columns, args.constraints,
+            args.relative_data_path, args.table_id, args.columns, args.constraints,
             args.attach, args.context.getSettings().max_compress_block_size, args.context);
     });
 }
diff --git a/dbms/src/Storages/StorageStripeLog.h b/dbms/src/Storages/StorageStripeLog.h
index 5d31c73989604bc0394327c865f6f2b05f8b5c3d..0b863c0c4dd0b30e9c392a38ff0012c42bdd9c65 100644
--- a/dbms/src/Storages/StorageStripeLog.h
+++ b/dbms/src/Storages/StorageStripeLog.h
@@ -69,8 +69,7 @@ private:
 protected:
     StorageStripeLog(
         const std::string & relative_path_,
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         bool attach,
diff --git a/dbms/src/Storages/StorageTinyLog.cpp b/dbms/src/Storages/StorageTinyLog.cpp
index 826b260579ca8e6d8ae230e1076b87f1507b4fc1..b249a09bdb70c0900037c13e0124ff024c06ed9c 100644
--- a/dbms/src/Storages/StorageTinyLog.cpp
+++ b/dbms/src/Storages/StorageTinyLog.cpp
@@ -324,17 +324,18 @@ void TinyLogBlockOutputStream::write(const Block & block)
 
 StorageTinyLog::StorageTinyLog(
     const std::string & relative_path_,
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     bool attach,
     size_t max_compress_block_size_,
     const Context & context_)
-    : IStorage({database_name_, table_name_}), base_path(context_.getPath()), path(base_path + relative_path_),
-    max_compress_block_size(max_compress_block_size_),
-    file_checker(path + "sizes.json"),
-    log(&Logger::get("StorageTinyLog"))
+    : IStorage(table_id_)
+    , base_path(context_.getPath())
+    , path(base_path + relative_path_)
+    , max_compress_block_size(max_compress_block_size_)
+    , file_checker(path + "sizes.json")
+    , log(&Logger::get("StorageTinyLog"))
 {
     setColumns(columns_);
     setConstraints(constraints_);
@@ -448,7 +449,7 @@ void registerStorageTinyLog(StorageFactory & factory)
                 ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
 
         return StorageTinyLog::create(
-            args.relative_data_path, args.database_name, args.table_name, args.columns, args.constraints,
+            args.relative_data_path, args.table_id, args.columns, args.constraints,
             args.attach, args.context.getSettings().max_compress_block_size, args.context);
     });
 }
diff --git a/dbms/src/Storages/StorageTinyLog.h b/dbms/src/Storages/StorageTinyLog.h
index 17b5e6e94cca67a206df0f74598045af6e0cca93..1e40efc11839a38589e7fcf64d6561a9afb17ec9 100644
--- a/dbms/src/Storages/StorageTinyLog.h
+++ b/dbms/src/Storages/StorageTinyLog.h
@@ -72,8 +72,7 @@ private:
 protected:
     StorageTinyLog(
         const std::string & relative_path_,
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & table_id_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         bool attach,
diff --git a/dbms/src/Storages/StorageURL.cpp b/dbms/src/Storages/StorageURL.cpp
index a31b04222d8c137b1b76c4abcac3b69d723bedfb..bbbef06b55c971289ae6d78963684d2fc2fd82c2 100644
--- a/dbms/src/Storages/StorageURL.cpp
+++ b/dbms/src/Storages/StorageURL.cpp
@@ -30,13 +30,16 @@ namespace ErrorCodes
 IStorageURLBase::IStorageURLBase(
     const Poco::URI & uri_,
     const Context & context_,
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const String & format_name_,
     const ColumnsDescription & columns_,
     const ConstraintsDescription & constraints_,
     const String & compression_method_)
-    : IStorage({database_name_, table_name_}), uri(uri_), context_global(context_), compression_method(compression_method_), format_name(format_name_)
+    : IStorage(table_id_)
+    , uri(uri_)
+    , context_global(context_)
+    , compression_method(compression_method_)
+    , format_name(format_name_)
 {
     context_global.getRemoteHostFilter().checkURL(uri);
     setColumns(columns_);
@@ -240,7 +243,7 @@ void registerStorageURL(StorageFactory & factory)
 
         return StorageURL::create(
             uri,
-            args.database_name, args.table_name,
+            args.table_id,
             format_name,
             args.columns, args.constraints, args.context,
             compression_method);
diff --git a/dbms/src/Storages/StorageURL.h b/dbms/src/Storages/StorageURL.h
index 4f752ea4ec4b79e2693213a376c8cc58f4a47b33..b0fec1527c10538789952b9e4be062ed821215f6 100644
--- a/dbms/src/Storages/StorageURL.h
+++ b/dbms/src/Storages/StorageURL.h
@@ -30,8 +30,7 @@ protected:
     IStorageURLBase(
         const Poco::URI & uri_,
         const Context & context_,
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & id_,
         const String & format_name_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
@@ -70,14 +69,13 @@ class StorageURL : public ext::shared_ptr_helper<StorageURL>, public IStorageURL
 public:
     StorageURL(
         const Poco::URI & uri_,
-        const std::string & database_name_,
-        const std::string & table_name_,
+        const StorageID & table_id_,
         const String & format_name_,
         const ColumnsDescription & columns_,
         const ConstraintsDescription & constraints_,
         Context & context_,
         const String & compression_method_)
-        : IStorageURLBase(uri_, context_, database_name_, table_name_, format_name_, columns_, constraints_, compression_method_)
+        : IStorageURLBase(uri_, context_, table_id_, format_name_, columns_, constraints_, compression_method_)
     {
     }
 
diff --git a/dbms/src/Storages/StorageValues.cpp b/dbms/src/Storages/StorageValues.cpp
index ec9cf82a7e7f584278f3d7af92f86452914fa3ef..080343a0956fc868825e9e084ce4d57e749a20c7 100644
--- a/dbms/src/Storages/StorageValues.cpp
+++ b/dbms/src/Storages/StorageValues.cpp
@@ -7,8 +7,8 @@
 namespace DB
 {
 
-StorageValues::StorageValues(const std::string & database_name_, const std::string & table_name_, const ColumnsDescription & columns_, const Block & res_block_)
-    : IStorage({database_name_, table_name_}), res_block(res_block_)
+StorageValues::StorageValues(const StorageID & table_id_, const ColumnsDescription & columns_, const Block & res_block_)
+    : IStorage(table_id_), res_block(res_block_)
 {
     setColumns(columns_);
 }
diff --git a/dbms/src/Storages/StorageValues.h b/dbms/src/Storages/StorageValues.h
index 67858516213e719fe2e7c34db223ad600717c5cb..14f8e2cb4e3ea3b82d0b1f4a9a9a15fbd905beba 100644
--- a/dbms/src/Storages/StorageValues.h
+++ b/dbms/src/Storages/StorageValues.h
@@ -27,7 +27,7 @@ private:
     Block res_block;
 
 protected:
-    StorageValues(const std::string & database_name_, const std::string & table_name_, const ColumnsDescription & columns_, const Block & res_block_);
+    StorageValues(const StorageID & table_id_, const ColumnsDescription & columns_, const Block & res_block_);
 };
 
 }
diff --git a/dbms/src/Storages/StorageView.cpp b/dbms/src/Storages/StorageView.cpp
index 6289db957264f28ce99ad150c5070fd2c741594a..d083e0966a1e09c4147409600006bc5d560bc73e 100644
--- a/dbms/src/Storages/StorageView.cpp
+++ b/dbms/src/Storages/StorageView.cpp
@@ -27,11 +27,10 @@ namespace ErrorCodes
 
 
 StorageView::StorageView(
-    const String & database_name_,
-    const String & table_name_,
+    const StorageID & table_id_,
     const ASTCreateQuery & query,
     const ColumnsDescription & columns_)
-    : IStorage({database_name_, table_name_})
+    : IStorage(table_id_)
 {
     setColumns(columns_);
 
@@ -106,7 +105,7 @@ void registerStorageView(StorageFactory & factory)
         if (args.query.storage)
             throw Exception("Specifying ENGINE is not allowed for a View", ErrorCodes::INCORRECT_QUERY);
 
-        return StorageView::create(args.database_name, args.table_name, args.query, args.columns);
+        return StorageView::create(args.table_id, args.query, args.columns);
     });
 }
 
diff --git a/dbms/src/Storages/StorageView.h b/dbms/src/Storages/StorageView.h
index 709082b58efd28a210aaae1385c5c35df658a9f3..3a78c47445629cc0c7e0b0a65df2612aa6825685 100644
--- a/dbms/src/Storages/StorageView.h
+++ b/dbms/src/Storages/StorageView.h
@@ -35,8 +35,7 @@ private:
 
 protected:
     StorageView(
-        const String & database_name_,
-        const String & table_name_,
+        const StorageID & table_id_,
         const ASTCreateQuery & query,
         const ColumnsDescription & columns_);
 };
diff --git a/dbms/src/Storages/StorageXDBC.cpp b/dbms/src/Storages/StorageXDBC.cpp
index 222eebd637714d4d857b5fa10959fbc9039edee8..aa9c7c9afba0b4ff063f7ba2da35d9d927f01e24 100644
--- a/dbms/src/Storages/StorageXDBC.cpp
+++ b/dbms/src/Storages/StorageXDBC.cpp
@@ -25,15 +25,20 @@ namespace ErrorCodes
 
 
 StorageXDBC::StorageXDBC(
-    const std::string & database_name_,
-    const std::string & table_name_,
+    const StorageID & table_id_,
     const std::string & remote_database_name_,
     const std::string & remote_table_name_,
     const ColumnsDescription & columns_,
     const Context & context_,
     const BridgeHelperPtr bridge_helper_)
     /// Please add support for constraints as soon as StorageODBC or JDBC will support insertion.
-    : IStorageURLBase(Poco::URI(), context_, database_name_, table_name_, IXDBCBridgeHelper::DEFAULT_FORMAT, columns_, ConstraintsDescription{}, "" /* CompressionMethod */)
+    : IStorageURLBase(Poco::URI(),
+                      context_,
+                      table_id_,
+                      IXDBCBridgeHelper::DEFAULT_FORMAT,
+                      columns_,
+                      ConstraintsDescription{},
+                      "" /* CompressionMethod */)
     , bridge_helper(bridge_helper_)
     , remote_database_name(remote_database_name_)
     , remote_table_name(remote_table_name_)
@@ -121,7 +126,7 @@ namespace
             BridgeHelperPtr bridge_helper = std::make_shared<XDBCBridgeHelper<BridgeHelperMixin>>(args.context,
                 args.context.getSettingsRef().http_receive_timeout.value,
                 engine_args[0]->as<ASTLiteral &>().value.safeGet<String>());
-            return std::make_shared<StorageXDBC>(args.database_name, args.table_name,
+            return std::make_shared<StorageXDBC>(args.table_id,
                 engine_args[1]->as<ASTLiteral &>().value.safeGet<String>(),
                 engine_args[2]->as<ASTLiteral &>().value.safeGet<String>(),
                 args.columns,
diff --git a/dbms/src/Storages/StorageXDBC.h b/dbms/src/Storages/StorageXDBC.h
index c658fc5c8a1268a7760660479fd0efc93145d35d..e7cf293278531a99785a1e1d522382937697ceae 100644
--- a/dbms/src/Storages/StorageXDBC.h
+++ b/dbms/src/Storages/StorageXDBC.h
@@ -24,8 +24,7 @@ public:
                             unsigned num_streams) override;
 
 
-    StorageXDBC(const std::string & database_name_,
-                const std::string & table_name_,
+    StorageXDBC(const StorageID & table_id_,
                 const std::string & remote_database_name,
                 const std::string & remote_table_name,
                 const ColumnsDescription & columns_,
diff --git a/dbms/src/Storages/tests/gtest_transform_query_for_external_database.cpp b/dbms/src/Storages/tests/gtest_transform_query_for_external_database.cpp
index b346bdbb0332294257e22222acbed33c0938c757..21cbecc167e7f829b3b55097ba603f728e238d3b 100644
--- a/dbms/src/Storages/tests/gtest_transform_query_for_external_database.cpp
+++ b/dbms/src/Storages/tests/gtest_transform_query_for_external_database.cpp
@@ -30,7 +30,7 @@ struct State
     {
         registerFunctions();
         DatabasePtr database = std::make_shared<DatabaseMemory>("test");
-        database->attachTable("table", StorageMemory::create("test", "table", ColumnsDescription{columns}, ConstraintsDescription{}));
+        database->attachTable("table", StorageMemory::create(StorageID("test", "table"), ColumnsDescription{columns}, ConstraintsDescription{}));
         context.makeGlobalContext();
         context.addDatabase("test", database);
         context.setCurrentDatabase("test");
diff --git a/dbms/src/Storages/tests/storage_log.cpp b/dbms/src/Storages/tests/storage_log.cpp
index f06988504f7c98d8f56d045715d2907c262c0c73..cd5f1ff849cec327a04557719b1b872a2b8bce1d 100644
--- a/dbms/src/Storages/tests/storage_log.cpp
+++ b/dbms/src/Storages/tests/storage_log.cpp
@@ -29,7 +29,7 @@ try
     context.makeGlobalContext();
     context.setPath("./");
 
-    StoragePtr table = StorageLog::create("./", "test", "test", ColumnsDescription{names_and_types}, ConstraintsDescription{}, 1048576, context);
+    StoragePtr table = StorageLog::create("./", StorageID("test", "test"), ColumnsDescription{names_and_types}, ConstraintsDescription{}, 1048576, context);
     table->startup();
 
     /// write into it
diff --git a/dbms/src/TableFunctions/ITableFunctionXDBC.cpp b/dbms/src/TableFunctions/ITableFunctionXDBC.cpp
index af48388644552f0c34ccd09a64b1369168b53992..29a29eb1312d8cf20b50ed8bcd274e2f07ed7d5f 100644
--- a/dbms/src/TableFunctions/ITableFunctionXDBC.cpp
+++ b/dbms/src/TableFunctions/ITableFunctionXDBC.cpp
@@ -81,7 +81,7 @@ StoragePtr ITableFunctionXDBC::executeImpl(const ASTPtr & ast_function, const Co
     readStringBinary(columns_info, buf);
     NamesAndTypesList columns = NamesAndTypesList::parse(columns_info);
 
-    auto result = std::make_shared<StorageXDBC>(getDatabaseName(), table_name, schema_name, remote_table_name, ColumnsDescription{columns}, context, helper);
+    auto result = std::make_shared<StorageXDBC>(StorageID(getDatabaseName(), table_name), schema_name, remote_table_name, ColumnsDescription{columns}, context, helper);
 
     if (!result)
         throw Exception("Failed to instantiate storage from table function " + getName(), ErrorCodes::UNKNOWN_EXCEPTION);
diff --git a/dbms/src/TableFunctions/TableFunctionFile.cpp b/dbms/src/TableFunctions/TableFunctionFile.cpp
index 75c2847732a16235fce31fbe7efe497a7a79130a..d5304392c3bdcf68bfffe0086e11057b2319da69 100644
--- a/dbms/src/TableFunctions/TableFunctionFile.cpp
+++ b/dbms/src/TableFunctions/TableFunctionFile.cpp
@@ -9,7 +9,7 @@ namespace DB
 StoragePtr TableFunctionFile::getStorage(
     const String & source, const String & format, const ColumnsDescription & columns, Context & global_context, const std::string & table_name, const std::string & compression_method) const
 {
-    StorageFile::CommonArguments args{getDatabaseName(), table_name, format, compression_method, columns, ConstraintsDescription{}, global_context};
+    StorageFile::CommonArguments args{StorageID(getDatabaseName(), table_name), format, compression_method, columns, ConstraintsDescription{}, global_context};
 
     return StorageFile::create(source, global_context.getUserFilesPath(), args);
 }
diff --git a/dbms/src/TableFunctions/TableFunctionHDFS.cpp b/dbms/src/TableFunctions/TableFunctionHDFS.cpp
index ae4a220fbbe1765f4648c4473df58ac30b2d1a54..740857cd0681240c0d0dd44cdb22687453aeeabb 100644
--- a/dbms/src/TableFunctions/TableFunctionHDFS.cpp
+++ b/dbms/src/TableFunctions/TableFunctionHDFS.cpp
@@ -13,8 +13,7 @@ StoragePtr TableFunctionHDFS::getStorage(
     const String & source, const String & format, const ColumnsDescription & columns, Context & global_context, const std::string & table_name, const String & compression_method) const
 {
     return StorageHDFS::create(source,
-        getDatabaseName(),
-        table_name,
+        StorageID(getDatabaseName(), table_name),
         format,
         columns,
         ConstraintsDescription{},
diff --git a/dbms/src/TableFunctions/TableFunctionMerge.cpp b/dbms/src/TableFunctions/TableFunctionMerge.cpp
index ad18cd8676c41bc7412e99235fd72d666e58b25d..bb99dee165105da29591e7ed89b38a183986ab5e 100644
--- a/dbms/src/TableFunctions/TableFunctionMerge.cpp
+++ b/dbms/src/TableFunctions/TableFunctionMerge.cpp
@@ -68,8 +68,7 @@ StoragePtr TableFunctionMerge::executeImpl(const ASTPtr & ast_function, const Co
     String table_name_regexp = args[1]->as<ASTLiteral &>().value.safeGet<String>();
 
     auto res = StorageMerge::create(
-        getDatabaseName(),
-        table_name,
+        StorageID(getDatabaseName(), table_name),
         ColumnsDescription{chooseColumns(source_database, table_name_regexp, context)},
         source_database,
         table_name_regexp,
diff --git a/dbms/src/TableFunctions/TableFunctionMySQL.cpp b/dbms/src/TableFunctions/TableFunctionMySQL.cpp
index 833d0afc90d235209799a2cc3649eb56231a92b9..9a0b04d975302910a18e6b489ba6bbf189d1f786 100644
--- a/dbms/src/TableFunctions/TableFunctionMySQL.cpp
+++ b/dbms/src/TableFunctions/TableFunctionMySQL.cpp
@@ -115,8 +115,7 @@ StoragePtr TableFunctionMySQL::executeImpl(const ASTPtr & ast_function, const Co
         throw Exception("MySQL table " + backQuoteIfNeed(remote_database_name) + "." + backQuoteIfNeed(remote_table_name) + " doesn't exist.", ErrorCodes::UNKNOWN_TABLE);
 
     auto res = StorageMySQL::create(
-        getDatabaseName(),
-        table_name,
+        StorageID(getDatabaseName(), table_name),
         std::move(pool),
         remote_database_name,
         remote_table_name,
diff --git a/dbms/src/TableFunctions/TableFunctionRemote.cpp b/dbms/src/TableFunctions/TableFunctionRemote.cpp
index 87c8989cbe29ed91ae26170fa83f1c11516835c9..e62b4ed31c667a1b0c4e49b031355f15e7c77d72 100644
--- a/dbms/src/TableFunctions/TableFunctionRemote.cpp
+++ b/dbms/src/TableFunctions/TableFunctionRemote.cpp
@@ -177,13 +177,13 @@ StoragePtr TableFunctionRemote::executeImpl(const ASTPtr & ast_function, const C
 
     StoragePtr res = remote_table_function_ptr
         ? StorageDistributed::createWithOwnCluster(
-            table_name,
+            StorageID("", table_name),
             structure_remote_table,
             remote_table_function_ptr,
             cluster,
             context)
         : StorageDistributed::createWithOwnCluster(
-            table_name,
+            StorageID("", table_name),
             structure_remote_table,
             remote_database,
             remote_table,
diff --git a/dbms/src/TableFunctions/TableFunctionS3.cpp b/dbms/src/TableFunctions/TableFunctionS3.cpp
index c739af30a686123a58613b748e7337b52c95ac3e..42199d83ed62c6bbde4a3fa9514fa60c63394bbc 100644
--- a/dbms/src/TableFunctions/TableFunctionS3.cpp
+++ b/dbms/src/TableFunctions/TableFunctionS3.cpp
@@ -85,7 +85,7 @@ StoragePtr TableFunctionS3::getStorage(
     S3::URI s3_uri (uri);
 
     UInt64 min_upload_part_size = global_context.getSettingsRef().s3_min_upload_part_size;
-    return StorageS3::create(s3_uri, access_key_id, secret_access_key, getDatabaseName(), table_name, format, min_upload_part_size, columns, ConstraintsDescription{}, global_context, compression_method);
+    return StorageS3::create(s3_uri, access_key_id, secret_access_key, StorageID(getDatabaseName(), table_name), format, min_upload_part_size, columns, ConstraintsDescription{}, global_context, compression_method);
 }
 
 void registerTableFunctionS3(TableFunctionFactory & factory)
diff --git a/dbms/src/TableFunctions/TableFunctionURL.cpp b/dbms/src/TableFunctions/TableFunctionURL.cpp
index a338aad3839cd52edd61127129058ba2c6f54943..98134ed753997f35796c02e70863a35dfc62a04e 100644
--- a/dbms/src/TableFunctions/TableFunctionURL.cpp
+++ b/dbms/src/TableFunctions/TableFunctionURL.cpp
@@ -12,7 +12,7 @@ StoragePtr TableFunctionURL::getStorage(
     const String & source, const String & format, const ColumnsDescription & columns, Context & global_context, const std::string & table_name, const String & compression_method) const
 {
     Poco::URI uri(source);
-    return StorageURL::create(uri, getDatabaseName(), table_name, format, columns, ConstraintsDescription{}, global_context, compression_method);
+    return StorageURL::create(uri, StorageID(getDatabaseName(), table_name), format, columns, ConstraintsDescription{}, global_context, compression_method);
 }
 
 void registerTableFunctionURL(TableFunctionFactory & factory)
diff --git a/dbms/src/TableFunctions/TableFunctionValues.cpp b/dbms/src/TableFunctions/TableFunctionValues.cpp
index 40237d6c3f3e6aa9a54f409934620474f994f9d0..f72783d6dd4259c2d50a55251e1966cfb6e302b5 100644
--- a/dbms/src/TableFunctions/TableFunctionValues.cpp
+++ b/dbms/src/TableFunctions/TableFunctionValues.cpp
@@ -88,7 +88,7 @@ StoragePtr TableFunctionValues::executeImpl(const ASTPtr & ast_function, const C
 
     Block res_block = sample_block.cloneWithColumns(std::move(res_columns));
 
-    auto res = StorageValues::create(getDatabaseName(), table_name, columns, res_block);
+    auto res = StorageValues::create(StorageID(getDatabaseName(), table_name), columns, res_block);
     res->startup();
     return res;
 }