Сохранение истории во внешней базе данных

Иногда необходимо сохранить историю переменных во внешей базе данных. Вот несколько шагов, позволяющих осуществить это: установите желаемую базу данных с таблицей для хранения значений, подключите эту базу данных к AggreGate Server и создайте Модель, которая будет слушать изменения переменных и хранить их в этой таблице.

Мы не будем описывать аспекты управления базой данных, предполагая, что вы с этим знакомы.

Сначала нужно получить базу данных. Можно создать новую базу данных или использовать существующую. Предположим, что имя базы данных - historyDB. Затем необходимо создать таблицу, которая будет сохранять историю переменных. Пусть у таблицы будет имя variable_history и следующие поля:

Предлагаются все типы полей, нужно определить соответствующий тип базы данных для каждого поля в соответствии с его целью.

Теперь давайте подключим базу данных к AggreGate Server. Для этого нужно создать для нее учетную запись устройства. Откройте всплывающее меню для узла Устройства в Системном дереве и кликните по пункту Добавить устройство.

В диалоге Добавить устройство выберите База данных в качестве Драйвера Устройства.

Назовите устройство historyDatabase и укажите URL соединения базы данных, имя пользователя базы данных и пароль базы данных. Мы используем пользователя root, потому что это удобно в тестовой среде, но, пожалуйста, убедитесь, что вы используете надлежащие протоколы безопасности в реальных средах.

Обратите внимание на правильное заполнение URL-адреса базы данных: строка подключения зависит от вашей DBMS. Можно начать редактирование строки, используя один из шаблонов в выпадающем списке поля. Для большинства современных баз данных можно пропустить поле Класс драйвера

Если параметры верны и соединение установлено, в системе появится учетная запись устройства History Database и отобразится ее диалог Настройки устройства. Теперь перейдите во вкладку Запросы (1)и добавьте новую запись путем нажатия кнопки Добавить строку (2). На шаге (3) мы добавили пример запроса SELECT * FROM variable_history, чтобы проиллюстрировать получение всех изменений для данной переменной.

После создания и установки устройства можно взаимодействовать с базой данных, выполняя запросы для учетной записи устройства History Database.

Мы будем использовать модель для прослушивания изменений переменных и записывать данные о событиях в базу данных. Поэтому нужно создать Модель. Откройте всплывающее меню для узла Моделии выберите пункт Создать, подобный созданию Устройства. Введите Имяи Описание в диалоге Properties, как показано ниже, и нажмите OK:

Откроется диалог конфигурации модели. Перейдите на вкладку " Привязки" (1) и добавьте строку (2). Новая привязка будет добавлена в таблицу привязок. Мы подробно рассмотрим, как заполнять каждое поле. Пока же просто отметьте поле При запуске (3).

Значения для остальных полей, Цель, Выражение, Активатор и Условие, описаны ниже.

Цель
Оставьте это поле пустым. Мы не хотим помещать данные о событиях в цель. Вместо этого мы просто выполним запрос на обновление базы данных в поле Выражение.

Активатор
Давайте заставим нашу привязку слушать событие изменения переменной. Щелкните на кнопке [...] в поле Активатор, чтобы открыть диалог выбора активатора.

Откройте вкладку Событие (1), затем найдите нужное устройство для прослушивания и выберите событие Context variable changed (2). Ссылка на это событие отображается внизу, в нашем случае users.admin.devices.defaultAdminDevice:updated@

После этого наша привязка будет выполняться каждый раз при изменении любой переменной на устройстве администратора по умолчанию. Чтобы привязка выполнялась при определённых изменениях, мы зададим условие.

Условие
Условие будет проверять каждое событие изменения переменной. Если условие ложно, событие будет проигнорировано. Поэтому мы установили выражение условия на cell({env/value}, 'variable') == 'random'. Это означает, что выражение привязки будет вычисляться только в том случае, если событие изменения переменной принадлежит переменной с именем random в выбранном контексте активатора. Обратите внимание, что выбранные нами устройства общего типа имеют ряд общих типов переменных, одной из которых является генератор случайных чисел, полезный для тестирования.

Выражение
Выражение вычисляется каждый раз, когда вызывается привязка и выполняется условие. Откройте редактор выражений для этого поля, нажав на кнопку [...]. В диалоговом окне редактора выражений задайте выражение для выполнения запроса на обновление базы данных. Он выполняется путем вызова функции executeQuery нашего устройства History Database. Запрос добавит новую запись в таблицу variable_history и будет подробно описан ниже.

Мы будем использовать функцию языка выражений callFunction(String context, String function, Object parameter1, Object parameter2, ...) для вызова функции executeQuery устройства (1) History Database. Можно найти шаблон этой функции в диалоге, который открывается кнопкой (2) Функции. Параметры следующие:

• context - строка, путь к контексту, откуда вызывается функция. Можно локализовать устройство History Database в дереве (3) Server Data, затем открыть всплывающее меню в соответствующем узле и выбрать действие Copy. После этого можно вставить путь устройства в текст выражения. Поэтому путь к устойству History Database должен быть users.admin.devices.historyDatabase (4)

• function - имя вызывающей функции. Оно должно быть executeQuery (5). Эта функция принадлежит базе данных SQL History Database context.

• parameter1 (query) - первый параметр вызывающей функции. Для вызывающей функции executeQuery это строка запроса. Поэтому наш запрос должен быть следующий: insert into variable_history(id, name, time, value) values(..., ..., ..., ...). Реальные значения должны быть введены вместо '...'. Мы получаем реальные значения из среды выражения. В нашем случае он будет хранить параметры события измененной переменной, потому что мы настраиваем эту привязку для расчета при событии. {env/id} ссылается на идентификатор события. cell({env/value}, "variable") получает имя переменной из данных событий. formatDate({env/time}, "YYYY-MM-dd HH:MM:s.SS") берет форматы и время событий в приемлемую временную строку базы данных . cell(cell({env/value}, "value"), "value") получает измененное значение из данных событий, берет таблицу, которая является измененной переменной value и получает поле value значения переменной (6).

• parameter2 (update) - второй параметр executeQuery указывает, является ли этот запрос запросом обновления. В нашем случае это true, т.е. запрос должен возвращать любое значение (7).

Примените выражение путем нажатия кнопки OK и нажмите кнопку OK в предыдущем диалоге Конфигурация модели для сохранения наших изменений привязок в модели.

Теперь, если все сделано правильно, изменения переменной random в Default Admin Device начнут сохраняться в таблице value_history базы данных history_db.

Можно проверить, если ли ошибки выполнения привязки, просматривая относящиеся к модели события External Event Storage. Просто выберите Просмотр событий из всплывающего меню модели в Системном дереве. Открывшийся Журнал событий можно использовать для отладки в режиме реального времени.

Наконец, вы можете изучить свои результаты, открывая настройки History Database. Щелкните на узле History Database в Системном дереве левой кнопкой мыши, или выберите Конфигурировать устройство в контекстном меню.

Мы видим историю переменной, которая была сохранена в нашей внешней базе данных: