Django后端调用PostgreSQL存储过程需按序同步执行的问题

问题核心 #

需要按顺序同步执行5个PostgreSQL存储过程，要求前一个执行完成后才能启动下一个。尝试整合到main存储过程时存在语法错误，使用PERFORM调用存储过程报错，Django后端手动循环等待的方案也无效。

正确解决方案 #

方案1：修正main存储过程语法，利用PostgreSQL原生同步特性 #

PostgreSQL中，在存储过程内按顺序使用CALL调用其他存储过程时，默认就是同步执行——前一个存储过程执行完毕后，才会执行下一个。你的main存储过程存在语法错误，修正后即可正常工作：

CREATE PROCEDURE main(input_file_path varchar)
LANGUAGE plpgsql
AS $$
BEGIN
    CALL get_input_file(input_file_path);
    CALL gla_first_step();
    CALL glab_first_step();
    CALL jet_first_step();
    CALL completeness();
END;
$$;

语法错误说明：

• 原代码中begin as $$是错误写法，正确结构为AS $$ BEGIN ... END; $$
• LANGUAGE 'plpgsql'可去掉单引号，PostgreSQL允许直接写LANGUAGE plpgsql

方案2：在Django后端直接按顺序调用，无需额外等待 #

Django的cursor.execute()执行CALL语句时，本身就是阻塞同步的——只有当前存储过程执行完成后，execute()才会返回，后续代码才会执行。你之前写的循环等待完全多余，直接按顺序调用即可：

# 正确的Django调用方式
from django.db import connection

with connection.cursor() as cur:
    cur.execute('CALL get_input_file(%s)', [path])
    cur.execute('CALL gla_first_step()')
    cur.execute('CALL glab_first_step()')
    cur.execute('CALL jet_first_step()')
    cur.execute('CALL completeness()')

为什么之前的尝试失败？ #

• 使用PERFORM报错：PERFORM是PL/pgSQL中调用函数（有返回值）的语法，存储过程必须用CALL调用，因此触发错误。
• Django循环等待无效：SELECT 1会立即返回结果，循环逻辑没有意义，且execute()本身已是同步阻塞的，不需要额外等待。

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