在PostgreSQL中拼接字符串并追加到WHERE子句时出现语法错误，如何修复？

错误原因 #

1. CASE语句语法不完整：原代码中的CASE结构缺少END CASE;结尾，PostgreSQL无法正确解析后续WHEN子句，直接触发语法错误。
2. 动态SQL写法非法：直接将字符串拼接在SELECT语句中的方式不被PostgreSQL支持，必须通过动态SQL执行机制处理。
3. 筛选逻辑有缺陷：原CASE是顺序匹配逻辑，一旦某个星级条件满足就停止后续判断，无法处理stars数组包含多个星级的筛选需求。

修正后的函数代码 #

CREATE OR REPLACE FUNCTION public.reviewsbystartotal(
    cid integer, stars integer[])
    RETURNS integer
    LANGUAGE 'plpgsql'
    COST 100
    VOLATILE PARALLEL UNSAFE
AS $BODY$
declare 
    appendtext text := '';
    result_count integer;
BEGIN       
    -- 遍历所有星级条件，追加匹配的筛选规则
    IF 5 = ANY(stars) THEN
        appendtext := appendtext || ' AND cr.generalrating >= 4.25';
    END IF;
    IF 4 = ANY(stars) THEN
        appendtext := appendtext || ' AND cr.generalrating BETWEEN 3.25 AND 4.24';
    END IF;
    IF 3 = ANY(stars) THEN
        appendtext := appendtext || ' AND cr.generalrating BETWEEN 2.5 AND 3.24';
    END IF;
    IF 2 = ANY(stars) THEN
        appendtext := appendtext || ' AND cr.generalrating BETWEEN 1.75 AND 2.49';
    END IF;
    IF 1 = ANY(stars) THEN
        appendtext := appendtext || ' AND cr.generalrating BETWEEN 1 AND 1.74';
    END IF;

    -- 构建动态SQL并执行，通过参数绑定避免注入风险
    EXECUTE format(
        'SELECT count(1) FROM companyreviews cr 
         WHERE cr.company = $1 
           AND cr.internalapproval = true %s',
        appendtext
    ) INTO result_count USING cid;

    RETURN result_count;
END; 
$BODY$;

关键修正说明 #

• 替换CASE为独立IF判断，支持stars数组包含多个星级时，同时追加所有对应筛选条件。
• 使用EXECUTE + format()实现动态SQL拼接，通过USING传递参数，彻底避免SQL注入风险。
• 用BETWEEN ... AND ...简化区间判断逻辑，让代码更简洁易读。

内容的提问来源于stack exchange，提问作者Daisy