pg_curl

封装CURL,执行各种用URL传输数据的操作

概览

扩展包名版本分类许可证语言
pg_curl2.4.5UTILMITC
ID扩展名BinLibLoadCreateTrustReloc模式
4090pg_curl-
相关扩展http pg_net pgjwt gzip bzip zstd pgjq pg_smtp_client

版本

类型仓库版本PG 大版本包名依赖
EXTPIGSTY2.4.51817161514pg_curl-
RPMPIGSTY2.4.51817161514pg_curl_$v-
DEBPIGSTY2.4.51817161514postgresql-$v-pg-curl-
OS / PGPG18PG17PG16PG15PG14
el8.x86_64
el8.aarch64
el9.x86_64
el9.aarch64
el10.x86_64
el10.aarch64
d12.x86_64
d12.aarch64
d13.x86_64
d13.aarch64
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
u22.x86_64
u22.aarch64
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
u24.x86_64
u24.aarch64
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5
PIGSTY 2.4.5

构建

您可以使用 pig build 命令构建 pg_curl 扩展的 RPM / DEB 包:

pig build pkg pg_curl         # 构建 RPM / DEB 包

安装

您可以直接安装 pg_curl 扩展包的预置二进制包,首先确保 PGDGPIGSTY 仓库已经添加并启用:

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

使用 pig 或者是 apt/yum/dnf 安装扩展:

pig install pg_curl;          # 当前活跃 PG 版本安装
pig ext install -y pg_curl -v 18  # PG 18
pig ext install -y pg_curl -v 17  # PG 17
pig ext install -y pg_curl -v 16  # PG 16
pig ext install -y pg_curl -v 15  # PG 15
pig ext install -y pg_curl -v 14  # PG 14
dnf install -y pg_curl_18       # PG 18
dnf install -y pg_curl_17       # PG 17
dnf install -y pg_curl_16       # PG 16
dnf install -y pg_curl_15       # PG 15
dnf install -y pg_curl_14       # PG 14
apt install -y postgresql-18-pg-curl   # PG 18
apt install -y postgresql-17-pg-curl   # PG 17
apt install -y postgresql-16-pg-curl   # PG 16
apt install -y postgresql-15-pg-curl   # PG 15
apt install -y postgresql-14-pg-curl   # PG 14

创建扩展

CREATE EXTENSION pg_curl;

用法

CREATE EXTENSION pg_curl;

执行 HTTP Get 请求:

-- 封装 curl http get 请求
CREATE OR REPLACE FUNCTION get(url TEXT) RETURNS TEXT LANGUAGE SQL AS $BODY$
WITH s AS (SELECT
               curl_easy_reset(),
               curl_easy_setopt_url(url),
               curl_easy_perform(),
               curl_easy_getinfo_data_in()
) SELECT convert_from(curl_easy_getinfo_data_in, 'utf-8') FROM s;
$BODY$;


SELECT get('https://www.postgresql.org/');

通过 SMTP 发送邮件:

CREATE OR REPLACE FUNCTION email(url TEXT, username TEXT, password TEXT, subject TEXT, sender TEXT, recipient TEXT, body TEXT, type TEXT) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        curl_easy_reset(),
        curl_easy_setopt_mail_from(sender),
        curl_easy_setopt_password(password),
        curl_easy_setopt_url(url),
        curl_easy_setopt_username(username),
        curl_header_append('From', sender),
        curl_header_append('Subject', subject),
        curl_header_append('To', recipient),
        curl_mime_data(body, type:=type),
        curl_recipient_append(recipient),
        curl_easy_perform(),
        curl_easy_getinfo_header_in()
    ) SELECT curl_easy_getinfo_header_in FROM s;
$BODY$;

通过 FTP 下载文件:

CREATE OR REPLACE FUNCTION download(url TEXT, username TEXT, password TEXT) RETURNS BYTEA LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        curl_easy_reset(),
        curl_easy_setopt_password(password),
        curl_easy_setopt_url(url),
        curl_easy_setopt_username(username),
        curl_easy_perform(),
        curl_easy_getinfo_data_in()
    ) SELECT curl_easy_getinfo_data_in FROM s;
$BODY$;

最后修改 2026-03-08: add extension catalog (baacba6)