Как в PostgeSQL вызвать функцию из другой схемы?

Question

[kondratev-ad]

Всем привет. Подскажите, как можно в триггер функции SQL вызвать функцию из другой схемы?
Имеем PosgreSQL, основная схема public и схема amqp, которая образовалась когда подключил pg_amqp.
В схеме public есть триггер функция по отслеживанию INSERT/UPDATE/DELETE в таблице:

Код функции

BEGIN
   if (TG_OP = 'INSERT') then
       INSERT INTO table_1_audit_log (
           table_1_id,
           old_row_data,
           new_row_data,
           dml_type,
           dml_timestamp
       )
       VALUES(
           NEW.id,
           null,
           to_jsonb(NEW),
           'INSERT',
           CURRENT_TIMESTAMP
       );
      
          
       RETURN NEW;
       
   elsif (TG_OP = 'UPDATE') then
       INSERT INTO table_1_audit_log (
           table_1_id,
           old_row_data,
           new_row_data,
           dml_type,
           dml_timestamp
       )
       VALUES(
           NEW.id,
           to_jsonb(OLD),
           to_jsonb(NEW),
           'UPDATE',
           CURRENT_TIMESTAMP
       );
            
       RETURN NEW;
   elsif (TG_OP = 'DELETE') then
       INSERT INTO table_1_audit_log (
           table_1_id,
           old_row_data,
           new_row_data,
           dml_type,
           dml_timestamp
       )
       VALUES(
           OLD.id,
           to_jsonb(OLD),
           null,
           'DELETE',
           CURRENT_TIMESTAMP
       );
       
       RETURN OLD;
   end if;
    
END;

Хочу в этой функции вызвать функцию amqp.publish из схемы amqp:
SELECT amqp.publish(1, '', 'queu', 'messange')

Но мне выдает ошибку:

ERROR: function amqp.publish(integer, unknown, unknown, unknown) does not exist

Comments

[Melkij]

покажите \dn+ и \df amqp.publish

[kondratev-ad]

Melkij,

[Melkij]

странно что нет permission denied for schema. Или вы от суперюзера работаете? Хотя, может я не помню и сообщение об ошибке где-то в минорках правили, попробуйте
grant USAGE on SCHEMA amqp to <username> ;
Если не повлияет, попробуйте задать типы принудительно

SELECT amqp.publish(1, ''::varchar, 'queu'::varchar, 'messange'::varchar)

[Melkij]

а, всё, догадался когда будет такое сообщение.

grant execute on amqp.publish(перепишите_список_параметров) to <username>;

[kondratev-ad]

Melkij, спасибо, помогло задать типы

Answer 1

[kondratev-ad]

Помогло решение Melkij задать типы принудительно

SELECT amqp.publish(1, ''::varchar, 'queu'::varchar, 'messange'::varchar)