调用我的函数时需要列定义列表错误

Question

我试图从这样的查询中构建一个现有的函数：

        Select * from dblink(
                            'host=db01
                            user=admin
                            password=xxxx
                            dbname=rm',
                            'select name,scopes from services es') as x(name varchar,scopes varchar)
    union all
        Select * from dblink(
                            'host=db02
                            user=admin
                            password=xxxx
                            dbname=rm',
                            'select name,scopes from services es') as x(name varchar,scopes varchar);

此查询有效，现在我想创建一个可重用的函数来跨此连接进行其他查询。 因此，我想在一个参数中传递选择，并在第二个参数中传递具有数据类型的别名。

这就是我的函数看起来像 atm 的样子。

CREATE OR REPLACE FUNCTION custom.dblink_function(qr varchar, alias varchar)
 RETURNS TABLE(name character varying, scopes character varying)
 LANGUAGE plpgsql
AS $$

begin 
    

    
        return query 
        Select * from dblink(
                            'host=db01
                            user=admin
                            password=xxxx
                            dbname=rm',
                            qr) as x(alias)
    union all
        Select * from dblink(
                            'host=db02
                            user=admin
                            password=xxxx
                            dbname=rm',
                            qr) as x(alias);
                
            
end;
$$  

当我这样调用它时，出现以下错误。

select * from custom.dblink_function('''select name,scopes from services es''','name varchar,scopes varchar')  

**

SQL Error [42601]: ERROR: a column definition list is required for functions returning "record"
  Where: PL/pgSQL function custom.dblink_function(character varying,character varying) line 10 at RETURN QUERY

**

我做错了什么？

Answer 1

“alias”是一个varchar，而不是一个列定义列表（据我所知没有类型）。它可能包含可以解释为列列表的文本，但要使其正常工作，您需要将查询文本组合成一个字符串，然后使用 return queryexecute 来执行该字符串。

你需要类似的东西

CREATE OR REPLACE FUNCTION dblink_function(qr varchar, alias varchar)
 RETURNS TABLE(name character varying, scopes character varying)
 LANGUAGE plpgsql
AS $
begin 
        return query execute
        format ($R$Select * from dblink(
                            'host=db01
                            user=admin
                            password=xxxx
                            dbname=rm',
                            %L) as x(%s)
    union all
        Select * from dblink(
                            'host=db02
                            user=admin
                            password=xxxx
                            dbname=rm',
                            %L) as x(%s)$R$,qr,alias,qr,alias);end;
$;