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

dbms: more easy startup after server fault [#CONV-2944].

Browse Source
This commit is contained in:
Alexey Milovidov 2013-09-15 01:41:09 +00:00
parent 8fc69c2a8e
commit df9f14ac3b
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
dbms/src/Interpreters/loadMetadata.cpp
View File

@ -52,6 +52,8 @@ void loadMetadata(Context & context)
{
/// Создадим все таблицы атомарно (иначе какой-нибудь движок таблицы может успеть в фоновом потоке попытаться выполнить запрос).
Poco::ScopedLock<Poco::Mutex> lock(context.getMutex());
Logger * log = &Logger::get("loadMetadata");
/// Здесь хранятся определения таблиц
String path = context.getPath() + "metadata";
@ -67,7 +69,7 @@ void loadMetadata(Context & context)
if (it.name().at(0) == '.')
continue;
LOG_INFO(&Logger::get("loadMetadata"), "Loading database " << it.name());
LOG_INFO(log, "Loading database " << it.name());
executeCreateQuery("ATTACH DATABASE " + it.name(), context, it.name(), it->path());
@ -87,7 +89,7 @@ void loadMetadata(Context & context)
tables.push_back(jt->path());
}
LOG_INFO(&Logger::get("loadMetadata"), "Found " << tables.size() << " tables.");
LOG_INFO(log, "Found " << tables.size() << " tables.");
/** Таблицы быстрее грузятся, если их грузить в сортированном (по именам) порядке.
* Иначе (для файловой системы ext4) DirectoryIterator перебирает их в некотором порядке,
@ -102,7 +104,7 @@ void loadMetadata(Context & context)
/// Сообщения, чтобы было не скучно ждать, когда сервер долго загружается.
if (j % 256 == 0 && watch.elapsedSeconds() > 5)
{
LOG_INFO(&Logger::get("loadMetadata"), std::fixed << std::setprecision(2) << j * 100.0 / size << "%");
LOG_INFO(log, std::fixed << std::setprecision(2) << j * 100.0 / size << "%");
watch.restart();
}
@ -115,6 +117,16 @@ void loadMetadata(Context & context)
copyData(in, out);
}
/** Пустые файлы с метаданными образуются после грубого перезапуска сервера.
* Удаляем эти файлы, чтобы чуть-чуть уменьшить работу админов по запуску.
*/
if (s.empty())
{
LOG_ERROR(log, "File " << tables[j] << " is empty. Removing.");
Poco::File(tables[j]).remove();
continue;
}
try
{
executeCreateQuery(s, context, it.name(), tables[j]);