как сохранить порядок сообщений, преобразованных из потребителя jms в файл в пентахо - PullRequest
0 голосов
/ 12 мая 2019

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

1 Ответ

0 голосов
/ 13 мая 2019

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

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

Я думаю, что это больше вопрос DATABASE, чем вопрос PDI.

...