aboutsummaryrefslogtreecommitdiff
path: root/src/server/shared/Updater/DBUpdater.cpp
diff options
context:
space:
mode:
authorNaios <naios-dev@live.de>2015-04-04 23:59:28 +0200
committerNaios <naios-dev@live.de>2015-04-05 00:25:20 +0200
commit455eee9392ac5fd170bae7a1c1e1229e0881ba07 (patch)
tree28215dfc6fa8ee196a91f0ca0811ade10279418d /src/server/shared/Updater/DBUpdater.cpp
parent2b6c0865769b8b8166d6afa36dd55cdb6cf98f45 (diff)
Core/DBUpdater: Exit clean if a query failed to apply.
* Fix some \W4 warnings about constructors. (cherry picked from commit de490674ff1205d908301b94f5644247562b43cb)
Diffstat (limited to 'src/server/shared/Updater/DBUpdater.cpp')
-rw-r--r--src/server/shared/Updater/DBUpdater.cpp27
1 files changed, 21 insertions, 6 deletions
diff --git a/src/server/shared/Updater/DBUpdater.cpp b/src/server/shared/Updater/DBUpdater.cpp
index 10119e08deb..73873c59775 100644
--- a/src/server/shared/Updater/DBUpdater.cpp
+++ b/src/server/shared/Updater/DBUpdater.cpp
@@ -272,11 +272,19 @@ bool DBUpdater<T>::Update(DatabaseWorkerPool<T>& pool)
[&](Path const& file) { DBUpdater<T>::ApplyFile(pool, file); },
[&](std::string const& query) -> QueryResult { return DBUpdater<T>::Retrieve(pool, query); });
- uint32 const count = updateFetcher.Update(
- sConfigMgr->GetBoolDefault("Updates.Redundancy", true),
- sConfigMgr->GetBoolDefault("Updates.AllowRehash", true),
- sConfigMgr->GetBoolDefault("Updates.ArchivedRedundancy", false),
- sConfigMgr->GetIntDefault("Updates.CleanDeadRefMaxCount", 3));
+ uint32 count;
+ try
+ {
+ count = updateFetcher.Update(
+ sConfigMgr->GetBoolDefault("Updates.Redundancy", true),
+ sConfigMgr->GetBoolDefault("Updates.AllowRehash", true),
+ sConfigMgr->GetBoolDefault("Updates.ArchivedRedundancy", false),
+ sConfigMgr->GetIntDefault("Updates.CleanDeadRefMaxCount", 3));
+ }
+ catch (UpdateException&)
+ {
+ return false;
+ }
if (!count)
TC_LOG_INFO("sql.updates", ">> %s database is up-to-date!", DBUpdater<T>::GetTableName().c_str());
@@ -331,7 +339,14 @@ bool DBUpdater<T>::Populate(DatabaseWorkerPool<T>& pool)
// Update database
TC_LOG_INFO("sql.updates", ">> Applying \'%s\'...", base.generic_string().c_str());
- ApplyFile(pool, base);
+ try
+ {
+ ApplyFile(pool, base);
+ }
+ catch (UpdateException&)
+ {
+ return false;
+ }
TC_LOG_INFO("sql.updates", ">> Done!");
return true;