6 defined("pq\\Result::SINGLE_TUPLE") or die("skip need pq\\Result::SINGLE_TUPLE");
15 $c = new pq\Connection(PQ_DSN);
16 var_dump($c->unbuffered ? true : false);
18 var_dump($c->unbuffered);
20 $c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
21 switch ($res->status) {
22 case pq\Result::SINGLE_TUPLE:
23 $res->fetchCol($val, "a");
26 case pq\Result::TUPLES_OK:
27 printf("-> fetching done\n");
30 printf("!! %s\n", $res->errorMessage);
37 $r = array($c->socket);
39 if (stream_select($r, $w, $e, null)) {
43 } while ($c->getResult());