Em Postgres
, você pode escrever uma stored procedure usando a linguagem PL/Python
capaz de se conectar em um banco Oracle
, possibilitando o intercâmbio de dados, veja só:
CREATE FUNCTION oracle_foobar()
RETURNS SETOF tb_foobar AS
$BODY$
import cx_Oracle
conn = cx_Oracle.connect('usuario/senha@servidor_oracle/database')
cur = conn.cursor()
cur.execute('select * from tb_foobar')
ret = cur[:]
cur.close()
conn.close()
return ret;
$BODY$
LANGUAGE plpythonu;
Uma vez com a função oracle_foobar()
criada, você pode usa-lá para extrair os dados de um banco de dados Oracle
(tb_foobar
) e inserí-las em um banco de dados Postgres
(tb_xpto
), por exemplo:
INSERT INTO tb_xpto ( a, b, c )
(SELECT a, b, c FROM oracle_foobar() WHERE c = 3);
No Postgres
você pode usar o pg_cron
para executar a função de forma agendada.
Todos os dias, às 10:00am
, por exemplo:
SELECT cron.schedule('0 10 * * *', $$INSERT INTO tb_xpto ( a, b, c )(SELECT a, b, c FROM oracle_foobar() WHERE c = 3);$$ );