CREATE TABLE AS400_VPRA_ABONO 
   ("ABON_NUM_CCTE" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_FEC_COMPR_PAG" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_CORR_COMPR" NUMBER(3,0) NOT NULL ENABLE,  
	"ABON_CORRELATIVO" NUMBER(3,0) NOT NULL ENABLE,  
	"ABON_FEC_CPBTE_ING_EGR" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_TIPO_REND" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_NUM_CPBTE_ING_EGR" NUMBER(8,0) NOT NULL ENABLE,  
	"ABON_TIPO_COMPR" NUMBER(1,0) NOT NULL ENABLE,  
	"ABON_TIPO_AVISO" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_NUM_AVISO" NUMBER(8,0) NOT NULL ENABLE,  
	"ABON_LINEA" NUMBER(5,0) NOT NULL ENABLE,  
	"ABON_TIPO_ABONO" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_TIPO_VIA" NUMBER(1,0) NOT NULL ENABLE,  
	"ABON_RECAUDADOR" NUMBER(5,0) NOT NULL ENABLE,  
	"ABON_MTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MTO_PAG_PESOS" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_FEC_PAGO" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_MEDIO_PAGO" NUMBER(1,0) NOT NULL ENABLE,  
	"ABON_AREA" CHAR(16 BYTE) NOT NULL ENABLE,  
	"ABON_BCO_ADM" CHAR(10 BYTE) NOT NULL ENABLE,  
	"ABON_MTO_DEV_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MTO_PAG_MON_AJ" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MTO_PAG_PESOS_AJ" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MOTIVO" NUMBER(3,0) NOT NULL ENABLE,  
	"ABON_SALDO" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_STATUS" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_STA_FACTUR" CHAR(1 BYTE) NOT NULL ENABLE,  
	"ABON_EXENTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_AFECTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_DEREMI_PAG_MON" NUMBER(9,2) NOT NULL ENABLE,  
	"ABON_IMPTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_TIPDOC" CHAR(2 BYTE) NOT NULL ENABLE,  
	"ABON_NUMDOC" CHAR(8 BYTE) NOT NULL ENABLE,  
	"ABON_FILLER" CHAR(14 BYTE) NOT NULL ENABLE 
   )

CREATE TABLE AS400_VPRA_ABONO_ORIGIN 
   ("ABON_NUM_CCTE" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_FEC_COMPR_PAG" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_CORR_COMPR" NUMBER(3,0) NOT NULL ENABLE,  
	"ABON_CORRELATIVO" NUMBER(3,0) NOT NULL ENABLE,  
	"ABON_FEC_CPBTE_ING_EGR" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_TIPO_REND" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_NUM_CPBTE_ING_EGR" NUMBER(8,0) NOT NULL ENABLE,  
	"ABON_TIPO_COMPR" NUMBER(1,0) NOT NULL ENABLE,  
	"ABON_TIPO_AVISO" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_NUM_AVISO" NUMBER(8,0) NOT NULL ENABLE,  
	"ABON_LINEA" NUMBER(5,0) NOT NULL ENABLE,  
	"ABON_TIPO_ABONO" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_TIPO_VIA" NUMBER(1,0) NOT NULL ENABLE,  
	"ABON_RECAUDADOR" NUMBER(5,0) NOT NULL ENABLE,  
	"ABON_MTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MTO_PAG_PESOS" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_FEC_PAGO" NUMBER(9,0) NOT NULL ENABLE,  
	"ABON_MEDIO_PAGO" NUMBER(1,0) NOT NULL ENABLE,  
	"ABON_AREA" CHAR(16 BYTE) NOT NULL ENABLE,  
	"ABON_BCO_ADM" CHAR(10 BYTE) NOT NULL ENABLE,  
	"ABON_MTO_DEV_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MTO_PAG_MON_AJ" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MTO_PAG_PESOS_AJ" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_MOTIVO" NUMBER(3,0) NOT NULL ENABLE,  
	"ABON_SALDO" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_STATUS" NUMBER(2,0) NOT NULL ENABLE,  
	"ABON_STA_FACTUR" CHAR(1 BYTE) NOT NULL ENABLE,  
	"ABON_EXENTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_AFECTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_DEREMI_PAG_MON" NUMBER(9,2) NOT NULL ENABLE,  
	"ABON_IMPTO_PAG_MON" NUMBER(13,2) NOT NULL ENABLE,  
	"ABON_TIPDOC" CHAR(2 BYTE) NOT NULL ENABLE,  
	"ABON_NUMDOC" CHAR(8 BYTE) NOT NULL ENABLE,  
	"ABON_FILLER" CHAR(14 BYTE) NOT NULL ENABLE 
   )

declare 
   type array_object is table of as400_VPRA_ABONO%rowtype index by binary_integer; 
  
   cursor c is select * from AS400_VPRA_ABONO_ORIGIN -- VPRA.ABONO@DBLINK_AS400 --> this is the original source of data  
                 Where abon_fec_pago between 20030000 and 20040000; 
   lr_datos array_object; 
begin 
   open c; 
   loop 
	 fetch c bulk collect into lr_datos limit 100; 
	 begin 
		forall i in 1..lr_datos.count save exceptions 
			insert /*+APPEND NOLOGING*/ into as400_VPRA_ABONO values lr_datos (i); 
		commit; 
	 exception 
		 when others then 
			dbms_output.put_line (sqlerrm); 
	 end; 
	 exit when c%notfound; 
 	 commit; 
	end loop; 
	close c; 
 exception 
	when others then 
		dbms_output.put_line (sqlerrm); 
 end;