Skip to main content
adicionou 45 caracteres ao conteúdo
Fonte Link
Lacobus
  • 13,9mil
  • 13
  • 34

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);$$ );

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:

SELECT cron.schedule('0 10 * * *', $$INSERT INTO tb_xpto ( a, b, c )(SELECT a, b, c FROM oracle_foobar() WHERE c = 3);$$ );

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);$$ );
Fonte Link
Lacobus
  • 13,9mil
  • 13
  • 34

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:

SELECT cron.schedule('0 10 * * *', $$INSERT INTO tb_xpto ( a, b, c )(SELECT a, b, c FROM oracle_foobar() WHERE c = 3);$$ );