Russian Qt Forum

Доброго времени суток.

У меня такая проблема. Есть приложение, которое взаимодействует с базой данных. База должна отправлять NOTIFY всем своим подписчикам (несколько запущенных программ). База не отправляет сообщение тому приложению, чьи действия повлекли возникновение сообщения. Тоесть если приложение изменило данные, то оно не получает сигнал, а все остальные приложения получают. Почему?

Код программы выкладываю. Это самый простой пример. Программа сама создаёт таблицу и тригер.

Использую:
OpenSUSE 12.1
PostgreSQL 8.4
Qt 4.8

На Windows всё работает отлично.

Ещё одно наблюдение. Такое чувство, что сигналы становятся в очередь и не обрабатываются. Их обработка происходит если другое приложение внесло изменения в базу. И обрабатываются они все сразу. Вот лог программы.


Здесь видно, что данное приложение два раза посылало запрос INSERT, а в итоге пришло три сигнала. Пришли они после того, как в другом приложении был выполнен аналогичный запрос INSERT.

BEGIN
       LISTEN classif_n;  -- Зачем триггер подписываете на получение сообщений? 
       NOTIFY classif_n;
       RETURN NULL; -- в таблицу ничего не добавилось, так и надо ?
END;

Насчет подписания тригера. Я точно не знаю, знающий человек сказал что в документации так описано. Впринципе без этого тоже работает корректно, скорее всего нужно убрать эту строчку.

Насчет возвращаемого значения. В таблицу добавилось, тригер срабатывает после внесения изменений в таблицу.

Вопрос не в этом. Данная программа является минимальным примером.

Я не могу поверить, что никто не сталкивался с данной проблемой. Была же тема уже такая. Только там так и не разобрались с данной проблемой.
Линуксоиды! Помогите!

Нужно призывать страшных линуксоидов и использовать дебаггер :)

PS я виндузятник :)

А что дебагить? Драйвера? Дебагил, работают правильно. Свой код? Дебагил, работает правильно. Куда дальше лезть? Единственный вариант остался QSocetNotify (если не ошибся с названием). Он обрабатывает сигналы. Если же и в нем будет всё нормально, тогда остаётся только база. Значит нужно искать исходники базы и колупать их, чего мне делать очень не хочется...

Дебажить надо свой код и код Qt. Да - да, тот класс который обрабатывает получаемые сообщения.

PS хотя логика есть в таком поведении. Это же linux. Программа изменила данные. Значит программа знает что делает. А если незнает, то плохая программа. (меняем программу на пользователь и получаем философию linux)

PPS а зафига вам, извиняюсь, сообщение об изменении программе, которая их вносит?

PPPS Мб это логика БД в linux?

Неправильно мыслишь. Части изменения и реагирования на изменения могут быть совсем не взаимосвязаны.

Все-таки напишите для начала "правильную" триггерную функцию

PS: у меня сервер по FreeBSD, клиент под XP - все работает как надо

Да кстати, при добавлении записи все-таки надо пользоваться транзакциями!

QSqlDatabase.transaction();
QSqlDatabase.commit();
QSqlDatabase.rollback();

нотифая не будет пока не закончится транзакция!

 

QSqlQuery внутри использует транзакцию на каждый exec, на сколько я помню.

Не поленился посмотрел исходники, не нашел нигде, чтобы QSqlQuery использовал QSqlDarabase.transaction()
и вообще с какого он должен использовать внутри транзакции? А если мне надо обернуть в транзакцию два инсерта в разные таблицы?

Или это только с SQLite было... Не помню уже. :)
А транзакция используется, если явной нет.

Вот это очень похоже, на то что висит незакрытая транзакция..... когда ее "захлопнули" пользователь получил чохом все три нотифая....

Решаю эту же проблему.
Я изменяю таблицу запросами внутри программы.
Попробовал засунуть выполнение запроса внутрь транзакции - ничего не вышло.

По идее нотифай в собственную сессию приходить не должен.
Это описано в документации (http://www.postgresql.org/docs/8.4/static/sql-notify.html) (последний абзац).
Поэтому не пойму, что за проблему вы решаете и зачем?

А вот откуда приходят два лишних нотифая, мне не ясно.

После долгих колупаний кода мы нашли одно интересное решение. Решение найдено пальцем в небо. В итоге нужно будет пересобрать драйвейра под БД.
Открываем проект драйверов. Находим файл qsql_psql.cpp. В методе subscribeToNotificationImplementation находим создание сокета:
d->sn = new QSocketNotifier(socket, QSocketNotifier::Read);
На винде это работает отлично, а вот на линуксе - не работает. Зато если поменять второй параметр в конструкторе на QSocketNotifier::Write, то на линуксе всё работает нормально, а на винде не работает.
Мы долго пытались понять что к чему, но ответа не нашли. Да и времени свободного нету.

Теорию насчет транзакций ещё не добрался проверить, но кажется мне, что не прокатит она..