Есть две подсистемы, живущие на разных схемах БД. Из одной подсистемы необходимо периодически переливать часть данных в другую подсистему. Переливка осуществляется без непосредственной связи: через формирование промежуточного пакета из БД-источника и загрузку его в БД-приемник из клиентского приложения. Данные вроде таких: основные таблицы (вроде карточки товара) и справочная информация (вроде справочников видов товара, единиц измерения и т.п.) Все принимаемые данные уже могут частично находится на приемнике. При переливке справочной информации основной алгоритм таков: если идентификатор сущности уже есть, то ничего не делать, если есть сущность с таким же уникальным полем (названием например), то изменить все коды в принимаемой схеме на код найденной сущности. Если и совпадение по уникальному полю не найдено, то вставить новую сущность. Однако для некоторых справочных таблиц логика перегонки иная.
Как это сделано сейчас:
мастер, на первом шаге мастера данные полностью выливаются во временные таблицы приемника. Затем пользователь отмечает в списке какие основные данные он хочет перегнать. После чего на следующих шагах ему показывается, какие справочные данные будут добавлены, а какие заменены. Наконец, на завершающем этапе выполняется переливка из временных таблиц в основные.
Недостатки при таком подходе: логика переливки жестко забита в код, при малейшем изменении схемы базы-приемника или логики в заливке таблиц необходимо переделывать логику импорта, после чего его долго и мучительно ее тестировать, для переливки из разных версий подсистем нужно писать свою обработку, пользователь не может влиять на замену справочных сведений.
Хотелось бы сделать функционал более гибким, не завязанным на конкретную логику и схему, расширить возможности пользователя (выбирать какие поля необходимо перегонять, какие данные заменять)
Посоветуйте, какие подходы здесь можно использовать?