Получение уведомлений MS SQL сервера в С++ Builder

В клиент-серверных задачах порою требуется получить по некоемому событию на SQL сервере уведомление на клиенте, при этом не опрашивая о случившихся изменениях. Реализовать данную функциональность возможно с использованием расширенной хранимой процедуры (extended stored procedure), представляющей из себя динамически подключаемую библиотеку, которая через сокеты по протоколу UDP будет рассылать бродкаст (broadcast) пакеты по сети. Создание расширенной хранимой процедуры производилось мною в среде С++ Builder 6 c использованием ODS (Open Data Service) API для СУБД MS SQL Server 2000. Необходимо обратить внимание, что по умолчанию в поставку данной среды разработки от Borland входит статическая библиотека Opends60.lib, реализующая весь сервис предоставляемой ODS API, но данная библиотека имеет устаревшую версию и поддерживает только MS SQL 7. Взять файл импорта библиотеки можно отсюда или сформировать его самостоятельно с использованием утилиты Implib. Также следует отметить, что протокол UDP не гарантирует доставку сообщения, но и не требует установления соединения, как скажем TCP, что является решающим при выборе способа доставки.

Простейшим примером использования механизма уведомления, является генерация события отсылки оповещения из триггера таблицы аудита пользователей при добавлении новой записи. Таблица, именуемая EVENTS, имеет структуру, состоящую из уникального идентификатора записи, логина пользователя и информационного сообщения, о котором надо уведомить всех заинтересованных подписчиков. Расширенная процедура "xp_event" может иметь следующие входные параметры: <имя хоста>, <номер порта>, <текст сообщения>, <имя пользователя>, <идентификатор записи>. В качестве имени хоста можно задать широковещательный адрес. К примеру, 223.1.2.255 (net-directed broadcast - вещание в пределах сети 223.1.2.XXX), 255.255.255.255 (limited broadcast address), когда хост может не знать собственной маски подсети и своего IP адреса, а можно и просто сетевое имя машины локальной сети. Обратите внимание, что если ваша сеть разделена на подсети, то маршрутизатор не пропустит широковещательные пакеты без дополнительной настройки. Номер порта UDP произволен, но следует избегать при настройке системных портов используемых операционной системой. По умолчанию на клиенте для прослушивания используется порт 3338.

Компонент TSQLAlerter имеет два метода: Start и Stop, которые соответственно создают новый процесс для прослушивания порта и останавливают его, т.е. клиент выступает в роли UDP сервера. Событие OnGetMessage наступает в момент получения оповещения, а указатель на визуальный компонент TLabel позволяет визуализировать полученное сообщение на форме. Структура, используемая для пересылки данных имеет следующий вид:

typedef struct TDATASEND      // Структура для пересылки
{
  char message[1024]; 
  char login[1024];
  long id;
}  TDATASEND;

Поток получает уведомление и в методе AddMessage() синхронизирует свойства Message, RecordId и Login объекта класса TSQLAlerter. Свойство Language отвечает за язык, используемый при визуализации основных сообщений об ошибках в работе компонента. Пример регистрации процедуры и реализации отсылки уведомления можно посмотреть в скрипте TSQLAlerter.sql:

--TSQLAlerter.sql

USE master

IF EXISTS (SELECT name FROM sysobjects
      WHERE name = 'xp_event' AND type = 'X')
   EXEC sp_dropextendedproc 'xp_event'
GO
EXEC sp_addextendedproc xp_event, 'dll_event.dll'

--Create table events

IF EXISTS (SELECT name FROM sysobjects
      WHERE name = 'EVENTS' AND type = 'U')
   DROP TABLE EVENTS
GO

CREATE TABLE dbo.EVENTS ( 
 [ID] INT IDENTITY(1,1)   NOT NULL,
 [LOGIN] CHAR(255)   NULL,
 [MESSAGE] TEXT   NULL
)
GO

--Create trigger

IF EXISTS (SELECT name FROM sysobjects
      WHERE name = 'events_trg' AND type = 'TR')
   DROP TRIGGER events_trg
GO

CREATE TRIGGER events_trg
ON EVENTS
FOR INSERT
AS
declare @login varchar(20)
declare @message varchar(2000)
declare @id int
select @login=rtrim(LOGIN),@id = ID from inserted
select @message = EVENTS.MESSAGE from inserted join EVENTS on EVENTS.ID=inserted.ID
EXEC master..xp_event '255.255.255.255',3338,@message,@login,@id