{
Q_ASSERT_X(d->thread == QThread::currentThread(), "threads", "DB used from different thread");
- QSqlQuery query = prepareOneShot(sql);
+ if (!d->db.isOpen())
+ {
+ disconnect();
+ if (!connect())
+ return false;
+ }
+
+ QSqlQuery query = QSqlQuery(d->db);
+
+ if (!query.exec(sql))
+ return checkError(query);
- return exec(query);
+ return true;
}
bool Database::checkError(QSqlQuery &query, bool prepared)
return false;
}
+
bool Database::notify(const QString ¬ification)
{
return exec("NOTIFY " + notification);