Differential D22143 Diff 62526 src/common/database/Database.cpp

Changeset View

Standalone View

View Options

src/common/database/Database.cpp

Show All 29 Lines
30#include <QSqlDriver> 30​#include <QSqlDriver>
31#include <QThread> 31​#include <QThread>
32#include <QDebug> 32​#include <QDebug>
33 33​
34#include <memory> 34​#include <memory>
35#include <mutex> 35​#include <mutex>
36#include <map> 36​#include <map>
37 37​
38​#include "kactivities-stat-logsettings.h"
39​
38namespace Common { 40​namespace Common {
39 41​
40namespace { 42​namespace {
41#ifdef QT_DEBUG 43​#ifdef QT_DEBUG
42 QString lastExecutedQuery; 44​ QString lastExecutedQuery;
43#endif 45​#endif
44 46​
45 std::mutex databases_mutex; 47​ std::mutex databases_mutex;
▲ Show 20 Lines • Show All 41 Lines • ▼ Show 20 Line(s)74 {
87 } 89​ }
88 90​
89 // We are allowing the database file to be overridden mostly for testing purposes 91​ // We are allowing the database file to be overridden mostly for testing purposes
90 m_database.setDatabaseName(ResourcesDatabaseSchema::path()); 92​ m_database.setDatabaseName(ResourcesDatabaseSchema::path());
91 93​
92 m_open = m_database.open(); 94​ m_open = m_database.open();
93 95​
94 if (!m_open) { 96​ if (!m_open) {
95 qWarning() << "KActivities: Database is not open: " 97​ qCWarning(KACTIVITY_STAT_LOG) << "KActivities: Database is not open: "
96 << m_database.connectionName() 98​ << m_database.connectionName()
97 << m_database.databaseName() 99​ << m_database.databaseName()
98 << m_database.lastError(); 100​ << m_database.lastError();
99 101​
100 if (info.openMode == Database::ReadWrite) { 102​ if (info.openMode == Database::ReadWrite) {
101 qFatal("KActivities: Opening the database in RW mode should always succeed"); 103​ qFatal("KActivities: Opening the database in RW mode should always succeed");
102 } 104​ }
103 } 105​ }
104 } 106​ }
105 107​
106 ~QSqlDatabaseWrapper() 108​ ~QSqlDatabaseWrapper()
107 { 109​ {
108 qDebug() << "Closing SQL connection: " << m_connectionName; 110​ qCDebug(KACTIVITY_STAT_LOG) << "Closing SQL connection: " << m_connectionName;
109 } 111​ }
110 112​
111 QSqlDatabase &get() 113​ QSqlDatabase &get()
112 { 114​ {
113 return m_database; 115​ return m_database;
114 } 116​ }
115 117​
116 bool isOpen() const 118​ bool isOpen() const
▲ Show 20 Lines • Show All 80 Lines • ▼ Show 20 Line(s)198 } else {
197 // Using the write-ahead log and sync = NORMAL for faster writes 199​ // Using the write-ahead log and sync = NORMAL for faster writes
198 ptr->setPragma(QStringLiteral("synchronous = 1")); 200​ ptr->setPragma(QStringLiteral("synchronous = 1"));
199 } 201​ }
200 202​
201 // Maybe we should use the write-ahead log 203​ // Maybe we should use the write-ahead log
202 auto walResult = ptr->pragma(QStringLiteral("journal_mode = WAL")); 204​ auto walResult = ptr->pragma(QStringLiteral("journal_mode = WAL"));
203 205​
204 if (walResult != QLatin1String("wal")) { 206​ if (walResult != QLatin1String("wal")) {
205 qWarning("KActivities: Database can not be opened in WAL mode. Check the " 207​ qCWarning(KACTIVITY_STAT_LOG) << "KActivities: Database can not be opened in WAL mode. Check the "
206 "SQLite version (required >3.7.0). And whether your filesystem " 208​ "SQLite version (required >3.7.0). And whether your filesystem "
207 "supports shared memory"); 209​ "supports shared memory";
208 210​
209 return nullptr; 211​ return nullptr;
210 } 212​ }
211 213​
212 // We don't have a big database, lets flush the WAL when 214​ // We don't have a big database, lets flush the WAL when
213 // it reaches 400k, not 4M as is default 215​ // it reaches 400k, not 4M as is default
214 ptr->setPragma(QStringLiteral("wal_autocheckpoint = 100")); 216​ ptr->setPragma(QStringLiteral("wal_autocheckpoint = 100"));
215 217​
216 qDebug() << "KActivities: Database connection: " << ptr->d->database->connectionName() 218​ qCDebug(KACTIVITY_STAT_LOG) << "KActivities: Database connection: " << ptr->d->database->connectionName()
217 << "\n query_only: " << ptr->pragma(QStringLiteral("query_only")) 219​ << "\n query_only: " << ptr->pragma(QStringLiteral("query_only"))
218 << "\n journal_mode: " << ptr->pragma(QStringLiteral("journal_mode")) 220​ << "\n journal_mode: " << ptr->pragma(QStringLiteral("journal_mode"))
219 << "\n wal_autocheckpoint: " << ptr->pragma(QStringLiteral("wal_autocheckpoint")) 221​ << "\n wal_autocheckpoint: " << ptr->pragma(QStringLiteral("wal_autocheckpoint"))
220 << "\n synchronous: " << ptr->pragma(QStringLiteral("synchronous")) 222​ << "\n synchronous: " << ptr->pragma(QStringLiteral("synchronous"))
221 ; 223​ ;
222 224​
223 return ptr; 225​ return ptr;
224} 226​}
Show All 25 Lines251#ifdef QT_NO_DEBUG
250 Q_UNUSED(ignoreErrors); 252​ Q_UNUSED(ignoreErrors);
251 return d->query(query); 253​ return d->query(query);
252#else 254​#else
253 auto result = d->query(query); 255​ auto result = d->query(query);
254 256​
255 lastExecutedQuery = query; 257​ lastExecutedQuery = query;
256 258​
257 if (!ignoreErrors && result.lastError().isValid()) { 259​ if (!ignoreErrors && result.lastError().isValid()) {
258 qWarning() << "SQL: " 260​ qCWarning(KACTIVITY_STAT_LOG) << "SQL: "
259 << "\n error: " << result.lastError() 261​ << "\n error: " << result.lastError()
260 << "\n query: " << query; 262​ << "\n query: " << query;
261 } 263​ }
262 264​
263 return result; 265​ return result;
264#endif 266​#endif
265} 267​}
266 268​
Show All 29 Lines