postgresql 数据库与TimescaleDB 时序库 join 在一起_PostgreSQL

postgresql 数据库与TimescaleDB 时序库 join 在一起

2021-02-27 18:27yang_z_1 PostgreSQL

这篇文章主要介绍了postgresql 数据库与TimescaleDB 时序库 join 在一起,需要的朋友可以参考下

之前在CSDN阅读资料时，发现有人问怎么把 postgresql数据库的表跟TimescaleDB 时序库的表 join在一起，正好我在查询数据的时候遇到过这个问题，我说一下我的解决方案
我选择的是postgresql数据库的fdw功能（postgres_fdw插件）

一安装postgres_fdw插件

1.1安装postgres_fdw插件
**

									su – postgres

									-bash-4.2$ psql

									postgres=# \c hrmwv2 #（数据库名字）

									Create extension "postgres_fdw";

也可以在连接数据库的工具中执行

postgresql 数据库与TimescaleDB 时序库 join 在一起

1.2 查看已安装插件命令

1	`select` `*` `from` `pg_available_extensions;`

二创建外部连接（TimescaleDB数据库）

**
需要连接TimescaleDB数据库信息：（虚构）
ip ：170.0.0.32 端口：5432
数据库名: hrmw 用户名：postgres

2.1创建于TimescaleDB的外部链接

									--创建外部服务器

									-- 括号里的三个参数，分别是timescaledb的ip、端口和数据库名称

									CREATE SERVER timescale_db FOREIGN DATA WRAPPER postgres_fdw OPTIONS (host '170.0.0.32', port '5432', dbname 'hrmw');

									--创建用户映射

									-- 括号里的两个参数，分别是timescaledb数据库的用户名、密码

									create user mapping for postgres server timescale_db options(user 'postgres', password '数据库密码');

2.2 查看外部链接命令

1	`select` `*` `from` `pg_foreign_server;`

结果：

postgresql 数据库与TimescaleDB 时序库 join 在一起

									#一般fwd出问题就看看这里 是否配置正确

									srvname：--你建的链接名

									srvoptions：--你要链接的timescaledb时序库的信息

2.3 删除fdw外部链接
这里删除要一步步的删或者直接使用级联删除的方法

1	`drop` `server timescale_db` `CASCADE;`

如果不用级联，直接drop timescale_db ，是删不掉的，报错如下：

> ERROR: cannot drop server timescale_db because other objects depend on it
DETAIL: user mapping for postgres on server timescale_db depends on server timescale_db
HINT: Use DROP ... CASCADE to drop the dependent objects too.

三创建外部表

**
3.1 创建外部表（你需要join TimescaleDB的那张表：一模一样的，可以是超表）

									CREATE FOREIGN TABLE tb_fdw_timescale_target 

									 (

									 collect_time timestamp(6),

									 id varchar(36) ,

									 value numeric(12,2) ,

									 file_no int4 ,

									 create_time timestamp(6)

									 )

									 server timescale_db --你创建的外部链接名字

									 options (table_name '时序库的表名');