我已经在PL/代理中设置了一个存储过程以进行查询,并收到一些记录。
在PL/代理中:
CREATE OR REPLACE FUNCTION query_autocomplete(q text, i_id bigint)
RETURNS SETOF RECORD AS $$
CLUSTER 'autocompletecluster';
RUN ON i_id;
$$ LANGUAGE plproxy;
在每个分区中:
CREATE OR REPLACE FUNCTION query_autocomplete(q text, i_id bigint)
RETURNS SETOF RECORD AS $$
DECLARE
rec RECORD;
BEGIN
FOR rec IN EXECUTE q
LOOP
RETURN NEXT rec;
END LOOP;
RETURN;
END;
$$ LANGUAGE plpgsql;
正如您可能猜到的那样,这是在PGSQL中击中已定义的服务器,称为" AutoCompleteCluster"。我发送的查询字符串如下:
$sql = "SELECT * FROM autocomplete WHERE member_id = :memberId";
$query = $this->db->prepare("SELECT query_autocomplete('{$sql}',1234");
它正在返回以下内容:
SQLSTATE[XX000]: Internal error: 7 ERROR: PL/Proxy function public.query_autocomplete(0): unsupported type
查询正在命中的表被定义为:
CREATE TABLE autocomplete (
id character varying(100) NOT NULL,
extra_data hstore,
username character varying(254),
member_id bigint
);
我在做什么错?
错误强烈建议PL/代理不支持SETOF RECORD
。尝试将您的函数定义为返回autocomplete%rowtype
,或者以匹配列集为单位的RETURNS TABLE (...)
。