Last updated: Fri, 18 Jul 2008

pg_send_query

(PHP 4 >= 4.2.0, PHP 5)

pg_send_query — Invia una query in modo asincrono

Descrizione

bool pg_send_query ( resource $connessione , string $query )

bool pg_send_query ( string $query )

pg_send_query() manda in modo asincrono una query sulla connessione . Diversamente da pg_query(), può inviare più query a PostgreSQL e recuperare i risultati uno ad uno utilizzando pg_get_result(). L'esecuzione dello script non viene interrotta mentre le query sono in esecuzione. Utilizzare pg_connection_busy() per controllare se la connessione è occupata (es. una query è in esecuzione). Le query possono essere cancellate mediante pg_cancel_query().

Anche se è possibile inviare query multiple in un sol colpo, non è possibile inviare query multiple su una connessione occupata. Se la query è inviata mentre la connessione è occupata, la funzione aspetta la fine del processamento di tutti le query in coda, quindi scarta tutti i risultati.

Vedere anche pg_query(), pg_cancel_query(), pg_get_result() e pg_connection_busy()

pg_set_client_encoding

pg_send_query_params

Last updated: Fri, 18 Jul 2008

add a note User Contributed Notes
pg_send_query

vincentdephily
29-Nov-2005 05:25


Note that if you send a query without calling pg_get_result() for the previous one (supposing it has finished and the connection is not busy), the previous query will get discarded.



See for yourself (tested on php4.4.0, postgres8.0.4, Linux/FreeBSD) :

<?

$conn = pg_connect("dbname=template1 host=localhost user=pgsql");

if ($conn === FALSE)

  exit("Can't connect to db");



$q = array();

// send some queries

foreach (range(0, 500) as $i)

  stack_query($q, $conn, "SELECT 'query $i' AS str;");

// receive them

while (true)

  {

    $left = stack_query($q, $conn);

    echo "$left left... ";

    $result = pg_get_result($conn);

    if ($left == 0 && $result === FALSE)

      break;

    $row = pg_fetch_assoc($result);

    // depending on race conditions, you wont get all your original queries here.

    echo "got $row[str]\n";

  }



function stack_query(&$queries, $conn, $sql = FALSE)

{

  if ($sql !== FALSE)

    $queries[] = $sql;

  while (count($queries) && !pg_connection_busy($conn))

    pg_send_query($conn, array_shift($queries));

  return count($queries) + (pg_connection_busy($conn) ? 1 : 0);

}

?>



You will have to write a higher level of abstraction if you want a "send all queries now, receive them later" behaviour.

Likeyouover others at hotmail dot com
02-Sep-2003 02:29


<?php

// --------- OPEN CONN ---



   $conn = pg_connect("host='127.0.0.1' dbname='test' user='usertest' password='passtest'");



// --------- OPEN FILE ---



   $fp = fopen('logo.gif', "r");

   $buffer = fread($fp, filesize('logo.gif'));

   fclose($fp);



// --------- CREATE - INSERT OID ---



   pg_exec($conn, "begin");



   $oid = pg_locreate($conn);



   $rs = pg_exec($conn,"INSERT INTO test(tipo, images) VALUES('A1', $oid);");

   $handle = pg_loopen ($conn, $oid, "w");



   pg_lowrite ($handle, $buffer);

   pg_loclose ($handle);



   pg_exec($conn, "commit");



// --------- OPEN - INSERT OID ---



   $rs = pg_exec($conn, "SELECT images FROM test WHERE tipo = 'A1';");

   $row = pg_fetch_row($rs, 0);



   pg_exec($conn, "begin");

   $loid = pg_loopen($conn, $row[0], "r");



   header("Content-type: image/gif");



   pg_loreadall($loid);

   pg_loclose($loid);



   pg_exec ($conn, "commit");



// --------- UNLINK OID ---



   pg_exec($conn, "begin");



   $loid = $row[0];

   pg_lounlink($conn, $loid);



   pg_exec ($conn, "commit");



// --------- DELETE OID ---



   pg_exec($conn, "DELETE FROM test WHERE tipo = 'A1';");



// --------- CLOSE CONN ---



   pg_close();

?>

Mikewithme at yahoo dot com
02-Sep-2003 02:28


Due to a bug, OLD API does not available with PHP 4.2.0 and 4.2.1.



PHP 4.2.2 will support OLD API again and will be kept long enough.



New API will be available PHP 4.2.0 to later versions. 

yohgaki at php dot net

19-Jun-2002 04:00 

Due to a bug, PHP 4.2.0 and 4.2.1 does not support pg_lo_import() old API. It's fixed in PHP 4.2.2.



BTW, new API will be always available from PHP 4.2.0 to later versions. Older API will be kept long enough, also. 

ceco at noxis dot net

15-May-2002 09:08 

it works for me (php-4.2.1)



not like this



int pg_lo_import ( string pathname [, resource connection])



but 

int pg_lo_import ( resource connection, string pathname )



don't know the reason

Ron Howard
04-Jan-2003 07:20


If there is an error in one of your queries, the queries following it will not get executed, and there will *not* be an error message displayed. The only way I can think of to determine if an SQL error happened is to use pg_trace.



Example:



pg_send_query($connection,

    "SELECT id FROM users;

    SELECT * FROM customers;

     [INVALID-SQL-STATEMENT];

    SELECT name FROM countries;");



while ($result = pg_get_result($connection))

    $results[] = $result;



The $results array will only have two items in it.

add a note

pg_set_client_encoding

pg_send_query_params

Last updated: Fri, 18 Jul 2008