如何使用 postgres_fdw 将插入查询公式化到另一个数据库中？

Question

这是我要运行的查询 - 假设我在其中运行此查询的当前数据库是 db1，我要在其中插入记录的数据库是 db2。

  insert into db2.employee(id, name, group) values(id, <db1.employee.name>, <db1.employee.group>) where id in (select id from archived limit 2);

如您所见，这些值必须从 db1（当前数据库）的员工表中选择，然后插入到 db2 的员工表中。

我知道查询是错误的 - 但我刚刚写信是为了解释我想要做什么。

如何使用 postgres_fdw 制定查询？

我尝试过使用这个查询做一些相反的事情

INSERT INTO  employee select * from 
dblink('host=10.1.1.1
 user=user
 password=password
 dbname=mydb', 'select * from employee') tt(
       id int,
  name character varying,
 );

编辑：请注意，我想做一个远程插入和一个本地选择。 当我在 db2 中作为本地数据库而不是 db1 运行查询时，似乎可以使用上面的查询来实现这一点

Answer 1

您不能像在 MySQL 中那样直接访问不同数据库中的表（一个 MySQL database 对应一个 PostgreSQL schema）。

因此，也许您可​​以通过在单个数据库中使用不同的模式来实现您想要的。

如果您确实需要更新不同数据库中的表，则必须使用 postgres_fdw 外部数据包装器来访问外部表。

您必须在数据库db1 中定义一个外部表——我们称之为foreign_employee，它指向db2 中的一个表。

那么你可以这样做：

INSERT INTO foreign_employee
SELECT e.*
FROM employee e
     JOIN archived a USING id
LIMIT 2;

请注意，LIMIT 在这里有点奇怪，因为查询结果中没有隐含的顺序，除非您强制使用 ORDER BY。