Не доходят NOTIFY от базы PostgreSQL на линуксе

[MetalKrot]

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

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

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

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

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

[MetalKrot]

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

Код:

CREATE TABLE true 
CREATE TRIGGER true 
subscribeToNotification true 
connect true 
INSERT true 
INSERT true 
test
test
test

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

[fte]

Код:

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

[MetalKrot]

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

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

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

[MetalKrot]

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

[Bepec]

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

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

[MetalKrot]

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

[Bepec]

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

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

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

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

[Пантер]

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

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

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

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

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

[fte]

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

Код:

BEGIN
       NOTIFY classif_n;
       RETURN new;
END;

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

[fte]

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

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

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

 

[Пантер]

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

[fte]

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

[Пантер]

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

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

[fte]

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

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