PL/pgSQL：触发函数返回不正确的数据

Question

我有一个带有参数“select_date”和“sponsor”的函数，它应该根据作为参数传递的值返回一些数据表：

SET search_path to Olympic;

CREATE OR REPLACE FUNCTION fn_get_info_by_sponsor
       (register_date tb_register.register_ts%type, sponsor_name tb_finance.sponsor_name%type)
RETURNS SETOF sponsor_data LANGUAGE plpgsql AS $$
DECLARE
      sp_data sponsor_data ;
BEGIN
      SELECT 
                 tb_sponsor.email,
                 tb_finance.sponsor_name,
                 tb_athlete.name,
                 tb_discipline.name,
                 tb_register.round_number,  
                 tb_register.register_measure, 
                 tb_register.register_position,
                 DATE(tb_register.register_ts)
                
       INTO sp_data
       FROM olympic.tb_sponsor
      INNER JOIN olympic.tb_finance
           ON (tb_finance.sponsor_name = tb_sponsor.name)
      INNER JOIN olympic.tb_athlete
           ON tb_athlete.athlete_id = tb_finance.athlete_id
      INNER JOIN olympic.tb_register
           ON tb_register.athlete_id = tb_athlete.athlete_id
      INNER JOIN olympic.tb_discipline
           ON tb_discipline.discipline_id = tb_register.discipline_id
      ORDER BY tb_sponsor.email ;

      RETURN NEXT sp_data ;
END ;  
$$;

该函数部分工作，但它返回不正确的值。当我使用参数 '2021-06-02 00:00:00', 'Adidas' 其中 'Adidas' 是赞助商时，它会将赞助商名称返回为 VISA：

SELECT * FROM fn_get_info_by_sponsor('2021-06-02 00:00:00', 'Adidas')

sponsor email, sponsor_name, athlete_name, discipline_name, round_number, register_measure, register_position, register_ts,
  NULL  "VISA"  "JACOBY Lydia"  "Swimming"  1   NULL    3   "2021-06-07"

谁能看出我做错了什么？

谢谢！

CREATE TYPE sponsor_data AS (
email email_type,
sponsor_name CHARACTER VARYING(100),
athletes_name CHARACTER VARYING(50),
discilpine_name CHARACTER VARYING(50),
round_number  INT ,
mark CHARACTER(12),
register_position INT,
register_ts  DATE
);

Answer 1

对于返回 setof 的 PL/pgSQL 函数，您必须使用 RETURN QUERY 子句，请参阅 manual ：

CREATE OR REPLACE FUNCTION fn_get_info_by_sponsor
       (register_date tb_register.register_ts%type, sponsor_name tb_finance.sponsor_name%type)
RETURNS SETOF sponsor_data LANGUAGE plpgsql AS $$
BEGIN
      RETURN QUERY
      SELECT row(
                 tb_sponsor.email,
                 tb_finance.sponsor_name,
                 tb_athlete.name,
                 tb_discipline.name,
                 tb_register.round_number,  
                 tb_register.register_measure, 
                 tb_register.register_position,
                 DATE(tb_register.register_ts)
                ) :: sponsor_data 
       FROM olympic.tb_sponsor
      INNER JOIN olympic.tb_finance
           ON (tb_finance.sponsor_name = tb_sponsor.name)
      INNER JOIN olympic.tb_athlete
           ON tb_athlete.athlete_id = tb_finance.athlete_id
      INNER JOIN olympic.tb_register
           ON tb_register.athlete_id = tb_athlete.athlete_id
      INNER JOIN olympic.tb_discipline
           ON tb_discipline.discipline_id = tb_register.discipline_id
      ORDER BY tb_sponsor.email ;
END ;  
$$;

或者您可以简单地编写一个 SQL 用户定义函数：

CREATE OR REPLACE FUNCTION fn_get_info_by_sponsor
       (register_date tb_register.register_ts%type, sponsor_name tb_finance.sponsor_name%type)
RETURNS SETOF sponsor_data LANGUAGE sql AS $$
      SELECT row(
                 tb_sponsor.email,
                 tb_finance.sponsor_name,
                 tb_athlete.name,
                 tb_discipline.name,
                 tb_register.round_number,  
                 tb_register.register_measure, 
                 tb_register.register_position,
                 DATE(tb_register.register_ts)
                ) :: sponsor_data 
       FROM olympic.tb_sponsor
      INNER JOIN olympic.tb_finance
           ON (tb_finance.sponsor_name = tb_sponsor.name)
      INNER JOIN olympic.tb_athlete
           ON tb_athlete.athlete_id = tb_finance.athlete_id
      INNER JOIN olympic.tb_register
           ON tb_register.athlete_id = tb_athlete.athlete_id
      INNER JOIN olympic.tb_discipline
           ON tb_discipline.discipline_id = tb_register.discipline_id
      ORDER BY tb_sponsor.email ;
$$;