frodovdr/hyperion.ng
1
0
Fork 0
mirror of https://github.com/hyperion-project/hyperion.ng.git synced 2025-03-01 10:33:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

unique sql database connection is created on different threads

Browse Source 
Signed-off-by: Paulchen-Panther <Paulchen-Panter@protonmail.com>
This commit is contained in:
Paulchen-Panther
2019-07-16 23:11:53 +02:00
parent 90599e820a
commit c676b640f1
3 changed files with 15 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/db/DBManager.h
View File

@@ -32,7 +32,7 @@ public:
/// set root path
void setRootPath(const QString& rootPath);
/// define the database to work with
void setDB(const QString& dbn);
void setDatabaseName(const QString& dbn) { _dbn = dbn; };
/// set a table to work with
void setTable(const QString& table);

2
include/db/InstanceTable.h
View File

@@ -19,7 +19,7 @@ public:
{
// Init Hyperion database usage
setRootPath(rootPath);
setDB("hyperion");
setDatabaseName("hyperion");
// Init instance table
setTable("instances");

36
libsrc/db/DBManager.cpp
View File

@@ -4,10 +4,13 @@
#include <QSqlError>
#include <QSqlQuery>
#include <QSqlRecord>
#include <QThreadStorage>
#include <QUuid>
#include <QDir>
// not in header because of linking
static QString _rootPath;
static QThreadStorage<QSqlDatabase> _databasePool;
DBManager::DBManager(QObject* parent)
: QObject(parent)
@@ -26,22 +29,6 @@ void DBManager::setRootPath(const QString& rootPath)
QDir().mkpath(_rootPath+"/db");
}
void DBManager::setDB(const QString& dbn)
{
_dbn = dbn;
// new database connection if not found
if(!QSqlDatabase::contains(dbn))
{
QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE",dbn);
db.setDatabaseName(_rootPath+"/db/"+dbn+".db");
if(!db.open())
{
Error(_log, QSTRING_CSTR(db.lastError().text()));
throw std::runtime_error("Failed to open database connection!");
}
}
}
void DBManager::setTable(const QString& table)
{
_table = table;
@@ -49,17 +36,20 @@ void DBManager::setTable(const QString& table)
QSqlDatabase DBManager::getDB() const
{
QSqlDatabase db = QSqlDatabase::database(_dbn);
if (db.isOpen() && db.isValid())
return db;
if(_databasePool.hasLocalData())
return _databasePool.localData();
else
{
db = QSqlDatabase::addDatabase("QSQLITE", _dbn);
auto db = QSqlDatabase::addDatabase("QSQLITE", QUuid::createUuid().toString());
_databasePool.setLocalData(db);
db.setDatabaseName(_rootPath+"/db/"+_dbn+".db");
if(!db.open())
{
Error(_log, QSTRING_CSTR(db.lastError().text()));
throw std::runtime_error("Failed to open database connection!");
}
return db;
}
return db;
}
bool DBManager::createRecord(const VectorPair& conditions, const QVariantMap& columns) const