Pdo\Pgsql::getNotify

    (PHP 8 >= 8.4.0)

    Pdo\Pgsql::getNotify — Recebe notificação assíncrona

    Descrição

    public function Pdo\Pgsql::getNotify(int $fetchMode = PDO::FETCH_DEFAULT, int $timeoutMilliseconds = 0): array|false

    Retorna um conjunto de resultados que representa uma notificação assíncrona pendente.

    Parâmetros

    fetchMode

    O formato como o conjunto de resultados deve ser retornado, uma das seguintes constantes:

    timeoutMilliseconds
    O tempo de espera por uma resposta, em milissegundos.

    Valor Retornado

    Se uma notificação estiver pendente, retorna uma única linha, caso contrário retorna false. Alinha tem um campo message (o nome do canal) e um campo pid (o ID do processo do backend que envia a notificação). Se a notificação traz uma carga não vazia, a linha também tem um campo payload. Com PDO::FETCH_NUM, estes campos estão nos índices 0, 1 e 2.

    Erros/Exceções

    Uma exceção ValueError será lançada se fetchMode não for uma das constantes PDO::FETCH_* válidas.

    Uma exceção ValueError será lançada se timeoutMilliseconds for menor que 0.

    Um E_WARNING é gerado quando timeoutMilliseconds é maior que o valor que pode estar contido em um inteiro com sinal de 32 bits; nesse caso, será o valor máximo de um inteiro com sinal de 32 bits.

    Exemplos

    Exemplo #1 Exemplo de Pdo\Pgsql::getNotify()

    Inscreva em um canal com LISTEN e então leia a próxima notificação pendente com um tempo limite de um segundo. 

    <?php
$db = new Pdo\Pgsql('pgsql:dbname=test host=localhost', $user, $pass);
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$db->exec('LISTEN messages');
$db->exec("NOTIFY messages, 'hello'");

$notification = $db->getNotify(PDO::FETCH_ASSOC, 1000);
var_export($notification);
?>

    O exemplo acima produzirá algo semelhante a:

    array (
  'message' => 'messages',
  'pid' => 1928,
  'payload' => 'hello',
)

    Veja Também

    Melhore Esta Página

    Aprenda Como Melhorar Esta Página • Envie uma Solicitação de Modificação • Reporte um Problema
    ＋adicionar nota

    Notas de Usuários 1 note

    up
    0
    sage at sage dot sk
    5 months ago
    This page needs an example to understand that you **need** to explicitly call LISTEN before using getNotify, like shown in https://www.php.net/manual/en/function.pg-get-notify.php

<?php

$db = new PDO($dsn, $user, $password, $options);
$db->query('LISTEN test');
$notification = $db->pgsqlGetNotify(PDO::FETCH_ASSOC, 10000);

// or

$db = new Pdo\Pgsql($dsn, $user, $password, $options);
$db->query('LISTEN test');
$notification = $db->getNotify(PDO::FETCH_ASSOC, 10000);

// now you can call NOTIFY elsewhere
// PG> NOTIFY test, 'payload string';
var_dump($notification);

?>

array(3) {
  ["message"]=>
  string(4) "test"
  ["pid"]=>
  int(123565)
  ["payload"]=>
  string(14) "payload string"
}

If you called NOTIFY before calling LISTEN, nothing will be returned!

You receive the first notification only, and you have to call getNotify again. And call LISTEN again if DB connection drops.
    ＋adicionar nota
    To Top