transaction ltr_source
transaction ltr_target
string ls_inifile = "convert.ini"
string ls_pipeline[]
pipeline lpipe_pipe
integer li_item
integer li_pipes
integer li_error


hpb_progress.Visible = false
SetPointer(HourGlass!)

lpipe_pipe = CREATE pipeline

ls_pipeline[1] = "act_type"
ls_pipeline[2] = "adress"
// список сокращен
ls_pipeline[41] = "workers"

f_show_log( mle_log, 'Создаю объекты транзакций' )

ltr_source = create transaction
ltr_target = create transaction


//[Source]
ltr_source.DBMS = ProfileString ( ls_inifile, "Source", "DBMS", "") //"ODBC"
ltr_source.DbParm = ProfileString ( ls_inifile, "Source", "DBParm", "") //"ConnectString='DSN=prg;UID=sa'"

//[Target]
ltr_target.DBMS = ProfileString ( ls_inifile, "Target", "DBMS", "")
ltr_target.LogId = ProfileString ( ls_inifile, "Target", "LogID", "")
ltr_target.LogPass = ProfileString ( ls_inifile, "Target", "LogPassword", "")
ltr_target.ServerName = ProfileString ( ls_inifile, "Target", "Servername", "")

f_show_log( mle_log, 'Соединяюсь с базами' )
CONNECT USING ltr_source;
CONNECT USING ltr_target;

li_pipes = UpperBound( ls_pipeline )
for li_item = 1 to li_pipes
f_show_log( mle_log, 'Импортируется таблица - ' + ls_pipeline[ li_item ] )
lpipe_pipe.DataObject = ls_pipeline[ li_item ]
li_error = lpipe_pipe.Start(ltr_source, ltr_target, dw_1)
if li_error = 1 then
f_show_log( mle_log, 'Таблица ' + Upper( ls_pipeline[ li_item ] ) + ' импортирована.' )
else
f_show_log( mle_log, 'При импорте таблицы ' + Upper( ls_pipeline[ li_item ] ) + ' возникли ошибки.~n~nКод ошибки - ' + string(li_error) )
end if
next


hpb_progress.OffsetPos ( 100 )

f_show_log( mle_log, 'Разъединяюсь с базами' )

DISCONNECT USING ltr_source;
DISCONNECT USING ltr_target;

destroy ltr_source
destroy ltr_target

destroy lpipe_pipe


MessageBox("Внимание!","Процесс импорта закончен")

hpb_progress.Visible = false
f_show_log( mle_log, 'Процесс импорта закончен' )