如何在Postgres中为表中的虚拟列创建数据库链接？

Posted 2021-04-04

我有一个使用dblink的Oracle Query，

SELECT * FROM  SSP2_PCAT.PRODUCT_TYPES WHERE ( PRODUCT_TYPE) IN 
(SELECT PRODUCT_TYPE FROM SSP2_PCAT.PRODUCT_TYPES
MINUS
SELECT PRODUCT_TYPE FROM SSP2_PCAT.PRODUCT_TYPES@FPORDDEV);

现在我使用dblink将其转换为Postgres，如下所示，

SELECT * FROM  SSP2_PCAT.PRODUCT_TYPES WHERE (PRODUCT_TYPE) IN 
(SELECT PRODUCT_TYPE FROM SSP2_PCAT.PRODUCT_TYPES
EXCEPT 
SELECT * from dblink 
('dbname=NTE5OFF port=5432 host=xxxxx 
  user=yyyyy password=zzzzz','SELECT PRODUCT_TYPE FROM 
  SSP2_PCAT.PRODUCT_TYPES')
as t (PRODUCT_TYPE character varying(60)) );

现在这个工作绝对精细！

现在，我如何将以下相同的Oracle sql转换为虚拟列，如下所示，

SELECT 'ITO' FRM, SALES_CD, SALES_CODE_DESC, ACTIVE_IND
FROM SSP2_PCAT.ACCT_LVL_SALES_CDS
EXCEPT 
SELECT 'ITO' FRM, SALES_CD, SALES_CODE_DESC, ACTIVE_IND
FROM SSP2_PCAT.ACCT_LVL_SALES_CDS@FPORDDEV;

我在Postgres中尝试了如下代码，但显然它给出了虚拟列的错误，

SELECT 'ITO' FRM, SALES_CD, SALES_CODE_DESC, ACTIVE_IND FROM 
SSP2_PCAT.ACCT_LVL_SALES_CDS
EXCEPT 
SELECT * FROM dblink 
('dbname=NTE5OFF port=5432 host=xxxxx 
user=yyyyy password=zzzzz', 
'SELECT FRM, SALES_CD, SALES_CODE_DESC, ACTIVE_IND FROM 
SSP2_PCAT.ACCT_LVL_SALES_CDS')
as t ( FRM varchar,
   sales_cd character varying(15),
       sales_code_desc character varying(150),
       active_ind character varying(3) ) );

如果我在这里遗漏任何东西，有人可以告诉我吗？

答案

你必须这样做

SELECT 'ITO' FRM ...

在dblink查询中，但由于它是在一个字符串中，你必须加倍单引号来转义它们：

'SELECT ''ITO'' FRM ...'

但是使用postgres_fdw的外表会更简单。