🔥 Словарик по FireBird
Главная / Справочник / SQL-рецепты

transfer table

Версии сервера

2.53.0
--

Доступно в

DSQL, ESQL, ISQL, PSQL

Формат

Передача части таблицы от одного сервера другому.

Суть проблемы.

Есть центральная база данных и большое количество филиалов. Необходимо создать репликацию одной или нескольких таблиц с центральной БД. Эта проблема может быть решена применением EXECUTE STATEMENT. Однако за период накопления, в филиалах набирается большой объем данных. Передача их открытым трафиком приводит к серьезной загрузке канала, да и непрогнозируемым нагрузкам на центральный сервер БД. Более разумно сжимать передаваемый трафик архиватором, а обрабатывать посылки данных по расписанию. Для реализации такого обмена, данные из таблицы-источника сохраняются во внешней (EXTERNAL) таблице, которая находится в отдельном файле, который после формирования архивируется и передается в сжатом виде. Собственно, настоящая статья описывает процедуру формирования пакета для передачи.

Описание

Процедура принимает следующие входные данные

  1. имя передаваемой таблицы

  2. условия отбора (секция WHERE запроса). В случае пустого значения этого параметра вся таблица передается полностью

  3. путь и имя/расширение создаваемого файла

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

ВНИМАНИЕ! Для работы этой процедуры использована функция создания внешних (EXTERNAL) таблиц. По умолчанию эта возможность отключена в фале настроек firebird.conf Для работы этой процедуры параметру ExternalFileAccessнеобходимо установить значениеFull

ВНИМАНИЕ! для передачи данных создается внешняя (EXTERNAL) таблица на которую накладываются ограничения связанные с таким объектом. В частности невозможна передача объектов типа BLOB. Подробности см. в соответствующей статье CREATE TABLE

Часть кода взята из статьи RDB$FIELDS

Пример

CREATE OR ALTER PROCEDURE TRANSFER (
    table_name varchar(1000),
    where_str varchar(1000),
    path_file varchar(1000) = 'c:\transfer.db')
as
declare variable temp_s1 varchar(10000);
declare variable i integer;
declare variable res varchar(10000);
begin
res = 'CREATE TABLE ' || table_name ||'_REP EXTERNAL ' || ASCII_CHAR(39) || PATH_FILE || ASCII_CHAR(39) || ' (';
SELECT count(*) FROM RDB$RELATIONS WHERE RDB$RELATION_NAME = :TABLE_NAME || '_REP' INTO i;

if (i > 0 ) then begin
            EXECUTE STATEMENT 'DROP TABLE ' || TABLE_NAME || '_REP'
            WITH AUTONOMOUS TRANSACTION;
            end
i = 0;
FOR
SELECT TRIM(RDB$RELATION_FIELDS.RDB$FIELD_NAME) ||' '||
TRIM( ( SELECT
cast(
       case T2.RDB$FIELD_TYPE
        when 7 then 'SMALLINT'
        when 8 then 'INTEGER'
        when 12 then 'DATE'
        when 13 then 'TIME'
        when 14 then 'CHAR('||T2.rdb$field_length||')'
        when 16 then
          iif(T2.rdb$field_sub_type = 0,'BIGINT', 'NUMERIC('||T2.RDB$FIELD_PRECISION||','||(-1*T2.rdb$field_scale)||')')
        when 35 then 'TIMESTAMP'
        when 37 then 'VARCHAR('||T2.rdb$field_length||')'
        when 261 then 'BLOB SUB_TYPE '||T2.rdb$field_sub_type||' SEGMENT SIZE '||T2.rdb$segment_length
        else cast(T2.RDB$FIELD_TYPE AS varchar(10))
    end
    ||iif(T2.RDB$NULL_FLAG = 1,' NOT NULL ',' ')
    ||coalesce(' '||RDB$DEFAULT_SOURCE,'')
    ||coalesce(' '||rdb$validation_SOURCE,'')
AS varchar(1000)) 
FROM RDB$FIELDS  T2 
WHERE T2.RDB$FIELD_NAME = RDB$RELATION_FIELDS.RDB$FIELD_SOURCE
) )  AS SPECIFICATION
FROM RDB$RELATION_FIELDS INNER JOIN RDB$FIELDS ON (RDB$FIELDS.RDB$FIELD_NAME = RDB$RELATION_FIELDS.RDB$FIELD_SOURCE), RDB$TYPES
WHERE RDB$TYPES.RDB$TYPE = RDB$FIELDS.RDB$FIELD_TYPE AND RDB$TYPES.RDB$FIELD_NAME = 'RDB$FIELD_TYPE'
AND RDB$RELATION_NAME = :TABLE_NAME
ORDER BY RDB$FIELD_POSITION
INTO TEMP_S1
do
BEGIN
res = res || case when i > 0 then ', ' else '' end || TEMP_S1; i = i + 1;
end
            res = res || ');';
            EXECUTE STATEMENT res
            WITH AUTONOMOUS TRANSACTION;

            temp_s1 = 'INSERT INTO ' || TABLE_NAME || '_REP SELECT ' || TABLE_NAME || '.* FROM ' || TABLE_NAME ||
            case when CHAR_LENGTH(WHERE_STR) < 2 then ' ;' else ' where ' || WHERE_STR || ' ;' END;

            EXECUTE STATEMENT temp_s1
            WITH  AUTONOMOUS TRANSACTION;

            EXECUTE STATEMENT 'DROP TABLE ' || TABLE_NAME || '_REP'
            WITH AUTONOMOUS TRANSACTION;

end

См. также

EXECUTE STATEMENT CREATE TABLE EXTERNAL RDB$FIELDS

Источник

%Firebird%\doc\565

✏️ Править эту статью на GitHub

Обсуждение