data: Added exception handling to database index

This commit is contained in:
Eberhard Graether
2017-05-31 14:07:21 +02:00
parent b79891693b
commit 8ab0abbe69
+24 -6
View File
@@ -1,5 +1,7 @@
#include "data/SqliteDatabaseIndex.h"
#include "utility/logging/logging.h"
SqliteDatabaseIndex::SqliteDatabaseIndex(const std::string& indexName, const std::string& indexTarget)
: m_indexName(indexName)
, m_indexTarget(indexTarget)
@@ -12,14 +14,30 @@ SqliteDatabaseIndex::~SqliteDatabaseIndex()
void SqliteDatabaseIndex::createOnDatabase(CppSQLite3DB& database)
{
database.execDML((
"CREATE INDEX IF NOT EXISTS " + m_indexName + " ON " + m_indexTarget + ";"
).c_str());
try
{
LOG_INFO_STREAM(<< "Creating database index \"" << m_indexName << "\"");
database.execDML((
"CREATE INDEX IF NOT EXISTS " + m_indexName + " ON " + m_indexTarget + ";"
).c_str());
}
catch (CppSQLite3Exception e)
{
LOG_ERROR(std::to_string(e.errorCode()) + ": " + e.errorMessage());
}
}
void SqliteDatabaseIndex::removeFromDatabase(CppSQLite3DB& database)
{
database.execDML((
"DROP INDEX IF EXISTS main." + m_indexName + ";"
).c_str());
try
{
LOG_INFO_STREAM(<< "Removing database index \"" << m_indexName << "\"");
database.execDML((
"DROP INDEX IF EXISTS main." + m_indexName + ";"
).c_str());
}
catch (CppSQLite3Exception e)
{
LOG_ERROR(std::to_string(e.errorCode()) + ": " + e.errorMessage());
}
}