{

QMutexLocker locker( queryMutex() );

m_queries.append(query);

{

QMutexLocker locker( queryMutex() );

m_queries.removeAll(query);

{

QMutexLocker locker( monitorMutex() );

m_monitors.append(monitor);

{

QMutexLocker locker( monitorMutex() );

m_monitors.removeAll(monitor);

{

QMutexLocker locker( queryMutex() );

return m_queries.size();

{

QMutexLocker locker( queryMutex() );

//The debug lines are intentionally qDebug and not SQLDEBUG

qDebug() << "Live queries: ";

Q_FOREACH(SqlQuery *query, m_queries) {

qDebug() << query->lastQuery();

}

{

QMutexLocker locker( monitorMutex() );

return m_monitors.size();

{

QMutexLocker locker( monitorMutex() );

//The debug lines are intentionally qDebug and not SQLDEBUG

qDebug() << "Active monitors: ";

Q_FOREACH(SqlMonitor *monitor, m_monitors) {

qDebug() << "Tables: " << monitor->monitoredTables() << " Values: " << monitor->monitoredValues();

}

{

QMutexLocker queryLocker( queryMutex() );

QMutexLocker monitorLocker( monitorMutex() );

//store all the queries and their bound values

QMap<SqlQuery*, QMap<QString, QVariant> > allBoundValues;

Q_FOREACH(SqlQuery* q, m_queries) {

if (q->connectionName() != db.connectionName() )

continue;

allBoundValues[q] = q->boundValues();

}

int retryCount = 0;

while ( !db.isOpen() || !db.isValid() ) {

if ( QThread::currentThread() == QCoreApplication::instance()->thread() ) {

#if 0

if ( QMessageBox::question( 0, QObject::tr("Database connection error"),

QObject::tr("<qt>The database is not available.<br/><br/>Press <b>Retry</b> to try again or <b>Abort</b> to terminate the application.<br />\

Unsaved changes are lost if you Abort.\

<br/><br/>If the problem persist, please inform your system administrator.</qt>"), QMessageBox::Retry | QMessageBox::Abort, QMessageBox::Retry ) == QMessageBox::Abort ) {

::exit(1) ;

}

#endif

::exit(1);

}

retryCount++;

if (retryCount > 10 ) { //give up at some point

return;

}

if ( db.open() ) {

SqlQueryCache::clear(); // reconnected, so all cached queries are now invalid

//if the connection was dropped and recreated all the prepared queries are invalid, so we need to reconstruct them

//using the lastQuery() string and the saved bound values

Q_FOREACH(SqlQuery* q, m_queries ) {

if (q->connectionName() != db.connectionName() )

continue;

if ( !q->lastQuery().isEmpty() ) {

QString str = q->lastQuery();

q->prepareWithoutCheck( str ); //TODO: this generates a runtime warning as the old stored query (prepare) cannot be cleaned up as it got lost. I have no idea what to do.

QMap<QString, QVariant> boundValues = allBoundValues[q];

QMap<QString, QVariant>::const_iterator it;

for (it = boundValues.constBegin(); it != boundValues.constEnd(); ++it) {

q->bindValue( it.key(), it.value() );

}

}

}

//unsubscribe from all the notifications. Important to do it here for all notifications of the db, as

//the QPSQL implementation will not recreate the QSocketNotifier otherwise and we will not get any notifications

QStringList notifications = db.driver()->subscribedToNotifications();

Q_FOREACH(QString notification, notifications) {

db.driver()->unsubscribeFromNotification(notification);

}

//subscribe again to the db notifications

Q_FOREACH(SqlMonitor* monitor, m_monitors ) {

if (monitor->database().connectionName() != db.connectionName() )

continue;

monitor->resubscribe();

}

}

}