• 售前

  • 售后

热门帖子
入门百科

postgresql 利用fdw来实现不同数据库之间数据互通(保举)

[复制链接]
音乐之家1 显示全部楼层 发表于 2021-8-14 15:13:37 |阅读模式 打印 上一主题 下一主题
前言
近来在工作的时候 需要用数据库A中的表a1来更新插入数据库B中的b2表 由于数据库都是postgres数据库
我想到了 postgres_fdw插件
预备工作
首先需要保证这两个数据库之间网 是通的
数据库A 名字 AA ip 10.10.2.100(虚构)端口 5432 用户名 postgres
数据库B 名字 BB ip 100.20.0.120(虚构)端口 6688 用户名 postgres
一 利用fdw创建2个数据库之间的毗连

1.1 安装 postgres_fdw插件
  1. Create extension "postgres_fdw";
复制代码


1.2 创建外部毗连

无论你实在A数据库中创建B数据库的毗连 ,还是在B数据库中创建A数据库的毗连 从本质上是一样的,都是为了买通2个数据库,实现数据互通
1.2.1 在A数据库创建b数据库的毗连
  1. --创建外部服务器
  2. -- 括号里的三个参数,分别是数据库b的ip、端口和数据库名称
  3. CREATE SERVER lianjiebb FOREIGN DATA WRAPPER postgres_fdw OPTIONS (host '100.20.0.120', port '6688', dbname 'BB');
  4. --创建用户映射·
  5. -- 括号里的两个参数,分别是数据库b数据库的用户名、密码
  6. create user mapping for postgres server lianjiebb options(user 'postgres', password '数据库密码');
复制代码
1.2.2 在b数据库创建a数据库的毗连
  1. --创建外部服务器
  2. -- 括号里的三个参数,分别是数据库a的ip、端口和数据库名称
  3. CREATE SERVER lianjieAA FOREIGN DATA WRAPPER postgres_fdw OPTIONS (host '10.10.2.100', port '5432', dbname 'AA');
  4. --创建用户映射·
  5. -- 括号里的两个参数,分别是数据库a数据库的用户名、密码
  6. create user mapping for postgres server lianjieAA options(user 'postgres', password '数据库密码');
复制代码
1.2.3 查询 外部链接
  1. select * from pg_foreign_server;
复制代码
1.3 创建外部表

在A数据库创建b1表的外部链接
  1. CREATE FOREIGN TABLE tb_fdw_b1
  2. (
  3. collect_time timestamp(6),
  4. id varchar(36) ,
  5. 列名1 numeric(12,2) ,
  6. 列名2 int4 ,
  7. 列名3 timestamp(6)
  8. ) --跟b1 一模一样的表结构就行
  9. server lianjiebb --你创建的外部链接名字
  10. options (table_name '时序库的表名');
复制代码
查看外部表是否有数,有数就表示ok了
  1. select * from tb_fdw_b1;
复制代码
在数据库b上创建a1表的外部链接也是一样的
二 插入数据

2.1 往外部表tb_fdw_b1 插入表a1的数据

因为 俩个表都是一样的表结构,可以直接插入
  1. INSERT into tb_fdw_b1 SELECT * from a1;
复制代码
因为外部表是及时的 在数据库a中更改了 外部表tb_fdw_b1 的数据 ,数据库B中的b1表中的数据也随之改变 告竣了我们一开始的目的
更新 UPDATE 删除DELETE 也是一样的 在这里就不说了
三 利用定时任务来告竣自动同步

每天都需要实验显然不符合我们的“懒人”形象 ,所以用定时任务来实现明天自动同步是必不可少的 我让他每天早上8点自动实验
3.1 利用 pgadmin实现定时同步(截图)

3.1.1

3.1.2

3.1.3

3.1.4

3.2 直接上语句实现定时同步
  1. DO $$
  2. DECLARE
  3. jid integer;
  4. scid integer;
  5. BEGIN
  6. -- Creating a new job
  7. INSERT INTO pgagent.pga_job(
  8. jobjclid, jobname, jobdesc, jobhostagent, jobenabled
  9. ) VALUES (
  10. 1::integer, '更新表b1'::text, ''::text, ''::text, true
  11. ) RETURNING jobid INTO jid;
  12. -- Steps
  13. -- Inserting a step (jobid: NULL)
  14. INSERT INTO pgagent.pga_jobstep (
  15. jstjobid, jstname, jstenabled, jstkind,
  16. jstconnstr, jstdbname, jstonerror,
  17. jstcode, jstdesc
  18. ) VALUES (
  19. jid, '更新表b1'::text, true, 's'::character(1),
  20. ''::text, '数据库A'::name, 'f'::character(1),
  21. ' INSERT into tb_fdw_b1 SELECT * from a1;'::text, ''::text
  22. ) ;
  23. -- Schedules
  24. -- Inserting a schedule
  25. INSERT INTO pgagent.pga_schedule(
  26. jscjobid, jscname, jscdesc, jscenabled,
  27. jscstart, jscend, jscminutes, jschours, jscweekdays, jscmonthdays, jscmonths
  28. ) VALUES (
  29. jid, '更新表b1'::text, ''::text, true,
  30. '2021-02-07 10:24:50 +08:00'::timestamp with time zone, '2100-02-07 10:24:52 +08:00'::timestamp with time zone,
  31. -- Minutes
  32. ARRAY[true,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false]::boolean[],
  33. -- Hours
  34. ARRAY[false,false,false,false,false,false,false,false,true,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false]::boolean[],
  35. -- Week days
  36. ARRAY[false,false,false,false,false,false,false]::boolean[],
  37. -- Month days
  38. ARRAY[false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false,false]::boolean[],
  39. -- Months
  40. ARRAY[false,false,false,false,false,false,false,false,false,false,false,false]::boolean[]
  41. ) RETURNING jscid INTO scid;
  42. END
  43. $$;
复制代码
到此这篇关于postgresql 利用fdw来实现差别数据库之间数据互通的文章就介绍到这了,更多相关postgresql实现数据互通内容请搜刮脚本之家以前的文章或继承浏览下面的相关文章希望各人以后多多支持脚本之家!

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有帐号?立即注册

x

帖子地址: 

回复

使用道具 举报

分享
推广
火星云矿 | 预约S19Pro,享500抵1000!
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

草根技术分享(草根吧)是全球知名中文IT技术交流平台,创建于2021年,包含原创博客、精品问答、职业培训、技术社区、资源下载等产品服务,提供原创、优质、完整内容的专业IT技术开发社区。
  • 官方手机版

  • 微信公众号

  • 商务合作