4 <?php include "_skipif.inc"; ?>
11 $c = new pq\Connection(PQ_DSN);
12 var_dump($c->unbuffered ? true : false);
14 var_dump($c->unbuffered);
16 $c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
17 switch ($res->status) {
18 case pq\Result::SINGLE_TUPLE:
19 printf("%s\n", $res->fetchCol());
21 case pq\Result::TUPLES_OK:
22 printf("-> fetching done\n");
25 printf("!! %s\n", $res->errorMessage);
32 case pq\Connection::POLLING_READING:
35 stream:select($r,$w,$e,1);
37 case pq\Connection::POLLING_WRITING:
40 stream_select($r,$w,$e,1);
44 } while ($c->getResult());