crtxcr/looqs
1
0
Fork 0
Code Issues Pull Requests 1 Releases Wiki Activity

Added databasefactory to create database connections

Browse Source
This commit is contained in:
Albert S. 2019-04-16 08:47:30 +02:00
parent dce13706e1
commit d2712e5293
2 changed files with 55 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
cli/databasefactory.cpp Normal file
View File

@ -0,0 +1,39 @@
#include <QThread>
#include "databasefactory.h"
#include "logger.h"
DatabaseFactory::DatabaseFactory(QString connectionString)
{
this->connectionString = connectionString;
}
static QThreadStorage<QSqlDatabase> dbStore;
//TODO: not threadsafe
QSqlDatabase DatabaseFactory::createNew()
{
static int counter = 0;
QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE", "QSS" + QString::number(counter++));
db.setDatabaseName(this->connectionString);
if(!db.open())
{
Logger::error() << "Failed to open the database: " << this->connectionString << endl;
throw QSSGeneralException("Failed to create open new connection");
}
return db;
}
QSqlDatabase DatabaseFactory::forCurrentThread()
{
if(dbStore.hasLocalData())
{
return dbStore.localData();
}
QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE", "QSS" + QString::number((quint64)QThread::currentThread(), 16));
db.setDatabaseName(this->connectionString);
if(!db.open())
{
Logger::error() << "Failed to open the database: " << this->connectionString << endl;
throw QSSGeneralException("Failed to create open new connection");
}
dbStore.setLocalData(db);
return db;
}

16
cli/databasefactory.h Normal file
View File

@ -0,0 +1,16 @@
#ifndef DATABASEFACTORY_H
#define DATABASEFACTORY_H
#include <QSqlDatabase>
#include <QThreadStorage>
#include "utils.h"
class DatabaseFactory
{
private:
QString connectionString;
public:
DatabaseFactory(QString connectionString);
QSqlDatabase createNew();
QSqlDatabase forCurrentThread();
};
#endif // DATABASEFACTORY_H