Проверка состояния подключения к БД.

[ksergey85]

Пользователи драйвера QODBC, подскажите пожалуйста как вы проверяете состояние коннекта к БД на предмет умерло/не умерло? Не дело ведь это выполнять "SELECT 1" после каждого неудачно выполненного запроса только для того, чтобы проверить не отвалился ли коннект. Или как-то по коду ошибки QSqlError все-таки можно догадаться, что запрос обломался именно по причине отпавшего коннекта. 
Погуглив, нашел только вот что https://bugreports.qt.io/browse/QTBUG-223. Закрыто в 2013. Никаких вразумительных комментариев.

[Old]

Не знаю что там есть для ODBC, а для postgresql и mysql я в отдельном потоке с заданным интервалом проверяю валидность соединения и при его разрыве посылаю сигнал об этом.

[ksergey85]

Не знаю что там есть для ODBC, а для postgresql и mysql я в отдельном потоке с заданным интервалом проверяю валидность соединения и при его разрыве посылаю сигнал об этом.

Как проверяете? Можно кода?

[Old]

Как проверяете? Можно кода?

Кода можно будет только завтра, сейчас смогу только на словах.
Создаем отдельное тестовое подключение, запускаем поток, в котором по таймеру выполняется слот.
В слоте проверяем валидность подключения проверяя открыто ли соединение и пытаясь выполнить запрос "SELECT TRUE", если все нормально - выходим из слота. Иначе посылаем сигнал об отключении базы и пытаемся переподключиться.

[Nidxogg]

В слоте проверяем валидность подключения проверяя открыто ли соединение

Если речь про isOpen, то оно true выдает даже после разрыва связи с БД. Разве нет?

и пытаясь выполнить запрос "SELECT TRUE", если все нормально - выходим из слота.

Результат запроса (false) у вас сразу приходит или с таймаутом каким-то?

[Old]

Если речь про isOpen, то оно true выдает даже после разрыва связи с БД. Разве нет?

Да, поэтому и нужен второй запрос.

Результат запроса (false) у вас сразу приходит или с таймаутом каким-то?

Сразу. Отдельная нитка нужна, что бы попытка переподключения не блокировала основную нить и не морозила UI. Открытие соединения с не отвечающим сервером БД заметно тормозит нить.

[Nidxogg]

Понятно, тогда тоже +1 к посмотреть код
(интересует как сама нитка создается и подключение в ней)

[Old]

Понятно, тогда тоже +1 к посмотреть код
(интересует как сама нитка создается и подключение в ней)

Если я утром забуду, напишите сообщение в этой теме еще раз (или в личку) - я выложу.

[Old]

Код

C++ (Qt)
class DbWatcher : public QThread
{
	Q_OBJECT
public:
	explicit DbWatcher();
	explicit DbWatcher( int interval, QSqlDatabase db );
 
			int			interval() const;
			void			setInterval( int val );
 
			bool			isConnected() const;
			QSqlDatabase	connection() const;
			void			setConnection( QSqlDatabase db );
 
signals:
			void			connected();
			void			disconnected();
 
protected slots:
			void			reconnect();
 
protected:
	virtual	void			run();
 
	int					m_interval;
	QSqlDatabase			m_db;
	QTimer				*m_timer;
	bool					m_connOk;
	mutable QMutex		m_mutex;
};
 

Код

C++ (Qt)
DbWatcher::DbWatcher() :
	QThread( 0 ),
	m_interval( 0 ),
	m_db(),
	m_timer( 0 ),
	m_connOk( false )
{
	moveToThread( this );
}
 
DbWatcher::DbWatcher( int interval, QSqlDatabase db ) :
	QThread( 0 ),
	m_interval( interval ),
	m_db( db ),
	m_timer( 0 ),
	m_connOk( false )
{
	moveToThread( this );
}
 
int DbWatcher::interval() const
{
	QMutexLocker lock( &m_mutex );
	return m_interval;
}
 
void DbWatcher::setInterval( int val )
{
	QMutexLocker lock( &m_mutex );
	m_interval = val;
}
 
bool DbWatcher::isConnected() const
{
	QMutexLocker lock( &m_mutex );
	return m_db.isOpen() && m_db.exec( "SELECT TRUE" ).isActive();
}
 
QSqlDatabase DbWatcher::connection() const
{
	QMutexLocker lock( &m_mutex );
	return m_db;
}
 
void DbWatcher::setConnection( QSqlDatabase db )
{
	QMutexLocker lock( &m_mutex );
	m_db = db;
}
 
void DbWatcher::reconnect()
{
	Q_ASSERT( m_timer );
 
	if( isConnected() )
		return;
 
	m_timer->stop();
 
	if( m_connOk )
	{
		m_connOk = false;
		emit disconnected();
	}
 
	m_db.open();
 
	if( isConnected() )
	{
		m_connOk = true;
		emit connected();
	}
 
	m_timer->start();
}
 
void DbWatcher::run()
{
	m_timer = new QTimer;
	connect( m_timer, SIGNAL(timeout()), SLOT(reconnect()) );
	m_timer->setSingleShot( false );
	m_timer->setInterval( m_interval * 1000 );
	m_timer->start();
 
	QMetaObject::invokeMethod( this, "reconnect", Qt::QueuedConnection );
 
	exec();
 
	m_timer->stop();
	delete m_timer;
}
 

[Nidxogg]

Создаем отдельное тестовое подключение

Имеется ввиду addDatabase?
Судя по вашему коду используется defaultConnection?

[Old]

Создаем отдельное тестовое подключение

Имеется ввиду addDatabase?
Судя по вашему коду используется defaultConnection?

Нет. Мы передаем соединение, которое будет использоваться для тестирования.
Я создаю рабочее соединение, клонирую его и клон передаю ватчеру для проверки. Для каждого потока нужно отдельное соединение.

[Nidxogg]

А если в процессе работы требуется отключиться от БД

void QSqlDatabase::removeDatabase ( const QString & connectionName )

и подключиться с другими параметрами - потребуется ли пересоздать ватчер?

[Old]

А если в процессе работы требуется отключиться от БД

void QSqlDatabase::removeDatabase ( const QString & connectionName )

и подключиться с другими параметрами - потребуется ли пересоздать ватчер?

Нет. Достаточно будет сделать setConnection с клоном нового подключения.

[Nidxogg]

Спасибо за информацию

[Nidxogg]

del