Для приготовления cURL в PostgreSQL нам понадобится сам postgres и его расширение pg_curl. (Я дал ссылки на свой форк postgres, т.к. делал некоторые изменения, которые пока не удалось пропихнуть в оригинальный репозиторий. Можно также воспользоваться готовым образом.)

Для начала устанавливаем расширение командой

CREATE EXTENSION pg_curl

Для get запроса создадим функцию

CREATE OR REPLACE FUNCTION get(url TEXT) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_init(), -- инициализируем
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения запроса
        pg_curl_easy_perform(), -- выполняем запрос
        pg_curl_easy_getinfo_char('CURLINFO_RESPONSE'), -- получаем результат выполнения запроса
        pg_curl_easy_cleanup() -- очищаем
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат выполнения запроса
$BODY$;

Для urlencoded post запроса создадим функцию

CREATE OR REPLACE FUNCTION post(url TEXT, request JSON) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_init(), -- инициализируем
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения запроса
        pg_curl_easy_setopt('CURLOPT_COPYPOSTFIELDS', ( -- задаём тело запроса
            WITH s AS (
                SELECT (json_each_text(request)).* -- пробегаемся по всему json-у
            ) SELECT array_to_string(array_agg(concat_ws('=', -- превращая его в urlencoded
                pg_curl_easy_escape(key),
                pg_curl_easy_escape(value)
            )), '&') FROM s
        )),
        pg_curl_easy_perform(), -- выполняем запрос
        pg_curl_easy_getinfo_char('CURLINFO_RESPONSE'), -- получаем результат выполнения запроса
        pg_curl_easy_cleanup() -- очищаем
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат выполнения запроса
$BODY$;

Для json post запроса создадим функцию

CREATE OR REPLACE FUNCTION post(url TEXT, request JSON) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_init(), -- инициализируем
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_header_append('Content-Type', 'application/json; charset=utf-8'), --задаём тип тела запроса
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения запроса
        pg_curl_easy_setopt('CURLOPT_COPYPOSTFIELDS', request::TEXT), -- задаём тело запроса
        pg_curl_easy_perform(), -- выполняем запрос
        pg_curl_easy_getinfo_char('CURLINFO_RESPONSE'), -- получаем результат выполнения запроса
        pg_curl_easy_cleanup() -- очищаем
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат выполнения запроса
$BODY$;

Для отправки почты создадим функцию

CREATE OR REPLACE FUNCTION email(url TEXT, username TEXT, password TEXT, subject TEXT, "from" TEXT, "to" TEXT[], data TEXT, type TEXT) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_init(), -- инициализируем
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_easy_setopt('CURLOPT_USERNAME', username), -- задаём логин
        pg_curl_easy_setopt('CURLOPT_PASSWORD', password), -- задаём пароль
        pg_curl_recipient_append("to"), -- задаём получателей
        pg_curl_header_append('Subject', subject), -- задаём тему
        pg_curl_header_append('From', "from"), -- задаём отправителя
        pg_curl_header_append('To', "to"), -- задаём получателей
        pg_curl_mime_data(data, type:=type), -- задаём тело
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения
        pg_curl_easy_perform(), -- выполняем
        pg_curl_easy_getinfo_char('CURLINFO_HEADERS'), -- получаем результат
        pg_curl_easy_cleanup() -- очищаем
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат
$BODY$;

И всё это можно выполнять асинхронно в фоне с помощью планировщика.

Комментарии (9)


  1. SDKiller
    19.06.2019 18:21

    Зачем?


    1. RekGRpth Автор
      19.06.2019 18:24

      Например, я у себя сделал отправку СМС прямо из PostgreSQL с помощью REST интерфейса оператора, а также регистрацию чеков в ОФД тоже с помощью REST интерфейса провайдера


      1. mariner
        20.06.2019 17:59

        но зачем?


  1. oxidmod
    19.06.2019 19:29

    Наблюдаю за вашими статьями и не могу понять, зачем эти извраты? почему не использовать язык общего назначения для подобных штук?


    1. RekGRpth Автор
      20.06.2019 05:51

      Ну, изначально я и писал на web2py. Но зачем использовать python, если можно его и не использовать?


  1. TyVik
    19.06.2019 23:01

    А почему бы не включить какой-нибудь PL/python и через него такие вещи делать?


    1. RekGRpth Автор
      20.06.2019 05:52

      Зачем использовать python, если можно его и не использовать?


  1. Merifri
    20.06.2019 08:31
    +1

    Как представлю танцы новой команды аутсорсеров над проектом без документации, в котором используется такое решение…
    (спустя… часов дебага)
    Кто, говорите, письма отправляет? PostgreSQL???


    1. RekGRpth Автор
      20.06.2019 15:23

      Это ещё что! Я у себя в форке curl добавил поддержку выполнения команд по ssh, и теперь у меня postgres может зайти по ssh на сервак, циску, микротик и выполнять там команды. И всё это асинхронно благодаря планировщику!