17 #include "windowstatestorage.h"
19 #include <QtConcurrent>
21 #include <QFutureSynchronizer>
27 QMutex WindowStateStorage::s_mutex;
29 WindowStateStorage::WindowStateStorage(QObject *parent):
32 QString dbPath = QDir::homePath() +
"/.cache/unity8/";
33 m_db = QSqlDatabase::addDatabase(QStringLiteral(
"QSQLITE"));
36 m_db.setDatabaseName(dbPath +
"windowstatestorage.sqlite");
40 WindowStateStorage::~WindowStateStorage()
42 QFutureSynchronizer<void> futureSync;
43 for (
int i = 0; i < m_asyncQueries.count(); ++i) {
44 futureSync.addFuture(m_asyncQueries[i]);
46 futureSync.waitForFinished();
50 void WindowStateStorage::saveState(
const QString &windowId, WindowStateStorage::WindowState state)
52 const QString queryString = QStringLiteral(
"INSERT OR REPLACE INTO state (windowId, state) values ('%1', '%2');")
56 saveValue(queryString);
59 WindowStateStorage::WindowState WindowStateStorage::getState(
const QString &windowId, WindowStateStorage::WindowState defaultValue)
const
61 const QString queryString = QStringLiteral(
"SELECT * FROM state WHERE windowId = '%1';")
64 QSqlQuery query = getValue(queryString);
69 return (WindowState)query.value(
"state").toInt();
72 void WindowStateStorage::saveGeometry(
const QString &windowId,
const QRect &rect)
74 const QString queryString = QStringLiteral(
"INSERT OR REPLACE INTO geometry (windowId, x, y, width, height) values ('%1', '%2', '%3', '%4', '%5');")
81 saveValue(queryString);
84 void WindowStateStorage::executeAsyncQuery(
const QString &queryString)
86 QMutexLocker l(&s_mutex);
89 bool ok = query.exec(queryString);
91 qWarning() <<
"Error executing query" << queryString
92 <<
"Driver error:" << query.lastError().driverText()
93 <<
"Database error:" << query.lastError().databaseText();
97 QRect WindowStateStorage::getGeometry(
const QString &windowId,
const QRect &defaultValue)
const
99 QString queryString = QStringLiteral(
"SELECT * FROM geometry WHERE windowId = '%1';")
102 QSqlQuery query = getValue(queryString);
104 if (!query.first()) {
107 return QRect(query.value(QStringLiteral(
"x")).toInt(), query.value(QStringLiteral(
"y")).toInt(), query.value(QStringLiteral(
"width")).toInt(), query.value(QStringLiteral(
"height")).toInt());
110 void WindowStateStorage::initdb()
114 qWarning() <<
"Error opening state database:" << m_db.lastError().driverText() << m_db.lastError().databaseText();
118 if (!m_db.tables().contains(QStringLiteral(
"geometry"))) {
120 query.exec(QStringLiteral(
"CREATE TABLE geometry(windowId TEXT UNIQUE, x INTEGER, y INTEGER, width INTEGER, height INTEGER);"));
123 if (!m_db.tables().contains(
"state")) {
125 query.exec(
"CREATE TABLE state(windowId TEXT UNIQUE, state INTEGER);");
129 void WindowStateStorage::saveValue(
const QString &queryString)
131 QMutexLocker mutexLocker(&s_mutex);
133 QFuture<void> future = QtConcurrent::run(executeAsyncQuery, queryString);
134 m_asyncQueries.append(future);
136 QFutureWatcher<void> *futureWatcher =
new QFutureWatcher<void>();
137 futureWatcher->setFuture(future);
138 connect(futureWatcher, &QFutureWatcher<void>::finished,
140 [=](){ m_asyncQueries.removeAll(futureWatcher->future());
141 futureWatcher->deleteLater(); });
144 QSqlQuery WindowStateStorage::getValue(
const QString &queryString)
const
146 QMutexLocker l(&s_mutex);
149 bool ok = query.exec(queryString);
151 qWarning() <<
"Error retrieving database query:" << queryString
152 <<
"Driver error:" << query.lastError().driverText()
153 <<
"Database error:" << query.lastError().databaseText();