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 $res->fetchCol($val, "a");
22 case pq\Result::TUPLES_OK:
23 printf("-> fetching done\n");
26 printf("!! %s\n", $res->errorMessage);
33 $r = array($c->socket);
35 if (stream_select($r, $w, $e, null)) {
39 } while ($c->getResult());