Как получить уведомления о базе данных MySQL в Delphi?

Question

Я разрабатываю приложение Delphi XE7 с данными, хранящимися в онлайн-базе данных Mysql. Для доступа к базе данных я использую FireDAC. Поскольку приложение может использоваться на нескольких компьютерах одновременно, мне нужно получить уведомление, когда таблица будет изменена, поэтому я могу обновить отображаемую информацию на каждом компьютере. FireDAC имеет компонент под названием TFDEventAlerted, который звучал точно так, как мне нужно для этого. Но этот компонент дает ошибку при активации (Call Register): [FireDAC] [Phys] [MySQL] -303. Способность не поддерживается. Я не уверен, что это значит, но, прочитав больше о компоненте, кажется, что Mysql не поддерживает этот тип событий? Если это так: может ли кто-нибудь сказать мне, есть ли другое решение для достижения того же?

Любая помощь будет оценена, поскольку я не могу найти подходящее решение.

Answer 1

У родного MySQL нет функции push-уведомления, которую вы надеетесь использовать. Чтобы выполнить эту работу, вам нужно будет опросить (чтобы регулярно запускать запрос), чтобы искать изменения.

Есть несколько способов преодолеть это ограничение, если масштаб вашей системы делает опрос неосуществимым. Вы можете добавить определенную пользователем функцию на свой сервер MySQL, как этот для отправки сообщений: https://github.com/mysqludf/lib_mysqludf_stomp#readme

Это не сработает, если у вас нет сервера MySQL; большинство хостинговых услуг не позволят вам устанавливать UDF.

Или вы можете создать приложение для публикации/подписания сообщения. Это довольно легко сделать с простой службой массового обслуживания Amazon или с помощью rabbitmq. Но это другой вид системного дизайна, из которого вы, вероятно, привыкли.

Answer 2

В моем article series около Firebird Database Events Я предложил решение на основе ориентированного на сообщения промежуточного программного обеспечения. Средний уровень вашего приложения затем уведомит все заинтересованные стороны о некоторых событиях базы данных. Код среднего уровня будет независимым от базы данных, все, что вам нужно, это брокер сообщений, который специализируется на надежной доставке сообщений. Мнимый пример для «» после поста обработчика события приведен ниже:

procedure TAppDataModule.PurchaseOrderAfterPost(DataSet: TDataSet); 
var 
    Notification: INotification; 
begin 
    Notification := NotificationService.CreateNotification(PURCHASE_ORDER_TABLE_UPDATED); 
    Notification.SetIntProperty(PURCHASE_ORDER_ID, PurchaseOrderID.AsInteger); 
    NotificationService.Send(Notification); 
end; 

Популярных брокеров сообщения бесплатно/НЬги с открытым исходным кодом, например Apache ActiveMQ и RabbitMQ.

Answer 3

TFDEventAlerted Управление не для базы данных MySQL. Эта база данных не поддерживает модель событий. Если вы хотите обновлять данные в «режиме реального времени», то вы должны добавить вручную запрос на измененных данных

Вот шаги:

1. Добавить новое поле в таблице базы данных, как «LAST_UPDATED»;

2. Заполните это поле значением now() при обновлении или вводе действий (по триггеру или sql);

3. Добавить таймер в приложение delphi и добавить запрос для последнего обновленного времени;

4. Если это время новое, тогда запрашивают обновленные данные на SELECT * FROM my_table WHERE last_updated >= :need_last_updated.