/*
     IBE блок который загружает в тестовую таблицу TEST_BLOB_TABLE
     все файлы из каталога указанного в переменной DIR

     при возникновении ошибки в ходе загрузки
     выводится сообщение с соответствующим текстом
*/

/*
-- DDL-скрипт создания тестовой таблицы:
CREATE TABLE TEST_BLOB_TABLE (
    ID         INTEGER DEFAULT 0 NOT NULL,
    FILE_BODY  BLOB SUB_TYPE 0 SEGMENT SIZE 8192,
    FILE_NAME  VARCHAR(255) CHARACTER SET WIN1251
);

ALTER TABLE TEST_BLOB_TABLE ADD CONSTRAINT PK_TEST_BLOB_TABLE PRIMARY KEY (ID);
*/

execute ibeblock
as
 declare variable NEW_ID integer;
begin

    -- создаем блок для отработки сообщений при выполнении скрипта (можно и без него)
    CBB = 'execute ibeblock (BlockData variant)
             as
             begin
               sMessage = BlockData;
               if (sMessage is not null) then
                begin
                    ibec_Progress('  || ibec_Chr(39) || 'SQL Script: ' || ibec_Chr(39) || ' + sMessage );
                end;
             end';

    -- каталог с файлами для загрузки
    DIR = 'C:\pdf_test\';

    -- создаем массив с файлами из заданного каталога
    ibec_GetFiles(FILE_LIST, DIR, '*.*', __faReadOnly + __gfFullName );

    cnt      = ibec_High( FILE_LIST );

    -- получаем значение последнего ключа
    select first 1 t.id from test_blob_table t order by t.id desc into :NEW_ID;

    for indx = 0 to cnt do
    begin

        FILE_NAME = FILE_LIST[indx];

        FSIZE     = ibec_FileSize(FILE_NAME);
        -- создаем HEX-маску для загрузчика тела файла h[начальная позиция для чтения]_[длина загружаемого набора байт или просто размер файла]
        LOAD_HEX = ibec_Format('h0_%s', ibec_IntToHex(FSIZE, 0));
    
        -- увеличиваем значени для первичного ключа таблицы (так как в тестовой таблице у нас для этого нет генератора и тригера)
        NEW_ID = coalesce(NEW_ID,0) + 1;

        NEW_FILE_NAME = ibec_ExtractFileName(FILE_NAME);

        -- сам скрипт который будет грузить тело бинарного файла в блоб
        IBE_SCRIPT=     ibec_Format(
            '    SET BLOBFILE %s%s%s; '                                                             ||ibec_chr(13) ||
            '     insert into test_blob_table (ID, FILE_BODY, FILE_NAME) values (%d, :%s, %s%s%s);' ||ibec_chr(13) ||
            '     commit work;   ',
                        ibec_Chr(39), FILE_NAME,     ibec_Chr(39),
                        NEW_ID,
                        LOAD_HEX,
                        ibec_Chr(39), NEW_FILE_NAME, ibec_Chr(39)
                   );

            -- выполняем его и сохраням результат в переменную. если CBB не создавали - указываем вместо последнего параметра null
            EXECUTE_RESULT = ibec_ExecSQLScript( ibec_GetDefaultConnection, IBE_SCRIPT, 'ServerVersion=FB21; StopOnError=True', CBB);

            -- если в ходе выполнения скрипта возникла ошибка - выводим сообщение с текстом
            if (ibec_Pos('Error',EXECUTE_RESULT) > 0)
                then ibec_MessageDlg(EXECUTE_RESULT, __mtError, __mbOK);
    end;
end

/*
     IBE блок который загружает в тестовую таблицу TEST_BLOB_TABLE
     все файлы из каталога указанного в переменной DIR

     при возникновении ошибки в ходе загрузки
     выводится сообщение с соответствующим текстом
*/

/*
-- DDL-скрипт создания тестовой таблицы:
CREATE TABLE TEST_BLOB_TABLE (
    ID         INTEGER DEFAULT 0 NOT NULL,
    FILE_BODY  BLOB SUB_TYPE 0 SEGMENT SIZE 8192,
    FILE_NAME  VARCHAR(255) CHARACTER SET WIN1251
);

ALTER TABLE TEST_BLOB_TABLE ADD CONSTRAINT PK_TEST_BLOB_TABLE PRIMARY KEY (ID);
*/

execute ibeblock
as
 declare variable NEW_ID integer;
begin

    -- создаем блок для отработки сообщений при выполнении скрипта (можно и без него)
    CBB = 'execute ibeblock (BlockData variant)
             as
             begin
               sMessage = BlockData;
               if (sMessage is not null) then
                begin
                    ibec_Progress(''SQL Script: '' + sMessage );
                end;
             end';

    -- каталог с файлами для загрузки
    DIR = 'C:\pdf_test\';

    -- создаем массив с файлами из заданного каталога
    ibec_GetFiles(FILE_LIST, DIR, '*.*', __faReadOnly + __gfFullName );

    cnt      = ibec_High( FILE_LIST );

    -- получаем значение последнего ключа
    select first 1 t.id from test_blob_table t order by t.id desc into :NEW_ID;

    for indx = 0 to cnt do
    begin

        FILE_NAME = FILE_LIST[indx];

        FSIZE     = ibec_FileSize(FILE_NAME);
        -- создаем HEX-маску для загрузчика тела файла h[начальная позиция для чтения]_[длина загружаемого набора байт или просто размер файла]
        LOAD_HEX = ibec_Format('h0_%s', ibec_IntToHex(FSIZE, 0));
    
        -- увеличиваем значение для первичного ключа таблицы (так как в тестовой таблице у нас для этого нет генератора и триггера)
        NEW_ID = coalesce(NEW_ID,0) + 1;

        NEW_FILE_NAME = ibec_ExtractFileName(FILE_NAME);

        -- сам скрипт который будет грузить тело бинарного файла в блоб
        IBE_SCRIPT=     ibec_Format(
            '    SET BLOBFILE ''%s''; '                                                             ||ibec_crlf ||
            '     insert into test_blob_table (ID, FILE_BODY, FILE_NAME) values (%d, :%s, ''%s'');' ||ibec_crlf ||
            '     commit work;   ',
                        FILE_NAME,
                        NEW_ID,
                        LOAD_HEX,
                        NEW_FILE_NAME
                   );

            -- выполняем его и сохраняем результат в переменную. если CBB не создавали - указываем вместо последнего параметра null
            EXECUTE_RESULT = ibec_ExecSQLScript( ibec_GetDefaultConnection, IBE_SCRIPT, 'ServerVersion=FB21; StopOnError=True', CBB);

            -- если в ходе выполнения скрипта возникла ошибка - выводим сообщение с текстом
            if (ibec_Pos('Error',EXECUTE_RESULT) > 0)
                then ibec_MessageDlg(EXECUTE_RESULT, __mtError, __mbOK);
    end;
end