pg_retry

pig build pkg pg_retry         # 构建 RPM / DEB 包

pig repo add pgsql -u          # 添加仓库并更新缓存

CREATE EXTENSION pg_retry;

retry.retry(
  sql TEXT,                          -- 要执行的 SQL 语句（仅限一条）
  max_tries INT DEFAULT 3,           -- 总尝试次数（1 + 重试次数），>= 1
  base_delay_ms INT DEFAULT 50,      -- 初始退避延迟（毫秒）
  max_delay_ms INT DEFAULT 1000,     -- 指数退避延迟上限
  retry_sqlstates TEXT[] DEFAULT ARRAY['40001','40P01','55P03','57014']
) RETURNS INT                       -- 处理的行数

SELECT retry.retry('UPDATE accounts SET balance = balance - 100 WHERE id = 1');

SELECT retry.retry(
    'INSERT INTO audit_log (event) VALUES (''test'')',
    5,      -- max_tries
    100,    -- base_delay_ms
    5000    -- max_delay_ms
);

ALTER SYSTEM SET pg_retry.default_max_tries = 5;
ALTER SYSTEM SET pg_retry.default_base_delay_ms = 100;
ALTER SYSTEM SET pg_retry.default_max_delay_ms = 5000;
ALTER SYSTEM SET pg_retry.default_sqlstates = '40001,40P01,55P03,57014';
SELECT pg_reload_conf();