postgresql 利用fdw来实现不同数据库之间数据互通(推荐)_PostgreSQL

来源:脚本之家  责任编辑:小易  

前言
最近在工作的时候 需要用数据库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插件

Create extension "postgres_fdw";

 

在这里插入图片描述

1.2 创建外部连接

无论你实在A数据库中创建B数据库的连接 ,还是在B数据库中创建A数据库的连接 从本质上是一样的,都是为了打通2个数据库,实现数据互通
1.2.1 在A数据库创建b数据库的连接

 --创建外部服务器
-- 括号里的三个参数,分别是数据库b的ip、端口和数据库名称
CREATE SERVER lianjiebb FOREIGN DATA WRAPPER postgres_fdw OPTIONS (host '100.20.0.120', port '6688', dbname 'BB');
--创建用户映射·
-- 括号里的两个参数,分别是数据库b数据库的用户名、密码
create user mapping for postgres server lianjiebb options(user 'postgres', password '数据库密码');

1.2.2 在b数据库创建a数据库的连接

--创建外部服务器
-- 括号里的三个参数,分别是数据库a的ip、端口和数据库名称
CREATE SERVER lianjieAA FOREIGN DATA WRAPPER postgres_fdw OPTIONS (host '10.10.2.100', port '5432', dbname 'AA');
--创建用户映射·
-- 括号里的两个参数,分别是数据库a数据库的用户名、密码
create user mapping for postgres server lianjieAA options(user 'postgres', password '数据库密码');

1.2.3 查询 外部链接

select * from pg_foreign_server;

1.3 创建外部表

在A数据库创建b1表的外部链接

CREATE FOREIGN TABLE tb_fdw_b1
 (
 collect_time timestamp(6),
 id varchar(36) ,
 列名1 numeric(12,2) ,
 列名2 int4 ,
列名3 timestamp(6)
 ) --跟b1 一模一样的表结构就行
 server lianjiebb --你创建的外部链接名字
 options (table_name '时序库的表名');

查看外部表是否有数,有数就表示ok了

select * from tb_fdw_b1;

在数据库b上创建a1表的外部链接也是一样的

二 插入数据

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

因为 俩个表都是一样的表结构,可以直接插入

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 直接上语句实现定时同步

DO $$
DECLARE
 jid integer;
 scid integer;
BEGIN
-- Creating a new job
INSERT INTO pgagent.pga_job(
 jobjclid, jobname, jobdesc, jobhostagent, jobenabled
) VALUES (
 1::integer, '更新表b1'::text, ''::text, ''::text, true
) RETURNING jobid INTO jid;

-- Steps
-- Inserting a step (jobid: NULL)
INSERT INTO pgagent.pga_jobstep (
 jstjobid, jstname, jstenabled, jstkind,
 jstconnstr, jstdbname, jstonerror,
 jstcode, jstdesc
) VALUES (
 jid, '更新表b1'::text, true, 's'::character(1),
 ''::text, '数据库A'::name, 'f'::character(1),
 ' INSERT into tb_fdw_b1 SELECT * from a1;'::text, ''::text
) ;

-- Schedules
-- Inserting a schedule
INSERT INTO pgagent.pga_schedule(
 jscjobid, jscname, jscdesc, jscenabled,
 jscstart, jscend, jscminutes, jschours, jscweekdays, jscmonthdays, jscmonths
) VALUES (
 jid, '更新表b1'::text, ''::text, true,
 '2021-02-07 10:24:50 +08:00'::timestamp with time zone, '2100-02-07 10:24:52 +08:00'::timestamp with time zone,
 -- Minutes
 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[],
 -- Hours
 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[],
 -- Week days
 ARRAY[false,false,false,false,false,false,false]::boolean[],
 -- Month days
 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[],
 -- Months
 ARRAY[false,false,false,false,false,false,false,false,false,false,false,false]::boolean[]
) RETURNING jscid INTO scid;
END
$$;

到此这篇关于postgresql 利用fdw来实现不同数据库之间数据互通的文章就介绍到这了,更多相关postgresql实现数据互通内容请搜索真格学网以前的文章或继续浏览下面的相关文章希望大家以后多多支持真格学网!

您可能感兴趣的文章:python连接PostgreSQL数据库的过程详解PHP连接及操作PostgreSQL数据库的方法详解C# 操作PostgreSQL 数据库的示例代码在Ubuntu中安装Postgresql数据库的步骤详解Linux下创建Postgresql数据库的方法步骤

  • 本文相关:
  • postgresql关于like%xxx%的优化操作
  • postgresql 自定义自动类型转换操作(cast)
  • postgres 创建role并赋予权限的操作
  • postgresql 字符串处理与日期处理操作
  • 使用pg_basebackup对postgre进行备份与恢复的实现
  • postgresql 性能参数配置方式
  • springboot连接使用postgresql数据库的方法
  • pgsql 实现分页查询方式
  • postgresql中slony-i同步复制部署教程
  • postgresql 中的参数查看和修改方式
  • PostgreSQL 怎么做数据的增量同步到其他PostgreSQL...
  • PostgreSQL两个数据库同步
  • postgresql从一个数据库转到另一个数据库有没有方...
  • 怎么实现MySQL和PostgreSQL之间不同编码方式实现数...
  • 讨论PostgreSQL 和其他数据库的差异在哪里
  • 【求助】postgresql数据库服务器同步
  • PostgreSQL数据库,想在脚本里面指定连接的数据库...
  • 两台物理主机,每台机器上装了postgresql数据库软件...
  • postgreSQL 数据库的客户端交互工具那个最好用啊?
  • postgreSQL数据库中使用PgAdmin如何新建服务器连接
  • 网站首页网页制作脚本下载服务器操作系统网站运营平面设计媒体动画电脑基础硬件教程网络安全mssqlmysqlmariadboracledb2mssql2008mssql2005sqlitepostgresqlmongodbredisaccess数据库文摘数据库其它首页python连接postgresql数据库的过程详解php连接及操作postgresql数据库的方法详解c# 操作postgresql 数据库的示例代码在ubuntu中安装postgresql数据库的步骤详解linux下创建postgresql数据库的方法步骤postgresql关于like%xxx%的优化操作postgresql 自定义自动类型转换操作(cast)postgres 创建role并赋予权限的操作postgresql 字符串处理与日期处理操作使用pg_basebackup对postgre进行备份与恢复的实现postgresql 性能参数配置方式springboot连接使用postgresql数据库的方法pgsql 实现分页查询方式postgresql中slony-i同步复制部署教程postgresql 中的参数查看和修改方式postgresql 角色与用户管理介绍windows下postgresql数据库的下载windows下postgresql安装图解postgresql中的oid和xid 说明15个postgresql数据库实用命令分postgresql alter语句常用操作小windows postgresql 安装图文教程postgresql 安装和简单使用postgresql 创建表分区postgresql新手入门教程postgresql 使用raise函数打印字符串postgresql 允许远程访问设置的操作浅谈postgresql默认端口5432你所不知道的mac系统重置postgresql密码的方法示例代码postgresql 将逗号分隔的字符串转为多行的postgresql psql文件执行与批处理多个sql基于postgresql数据库锁表问题的解决使用postgresql为表或视图创建备注的操作在postgresql数据库中创建只读用户的操作postgresql 实现字符串分割字段转列表查询
    免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved