--TEST--
unbuffered result
--SKIPIF--
-<?php include "_skipif.inc"; ?>
+<?php
+include "_skipif.inc";
+defined("pq\\Result::SINGLE_TUPLE") or die("skip need pq\\Result::SINGLE_TUPLE");
+
+?>
--FILE--
<?php
echo "Test\n";
$c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
switch ($res->status) {
case pq\Result::SINGLE_TUPLE:
- printf("%s\n", $res->fetchCol());
+ $res->fetchCol($val, "a");
+ printf("%s\n", $val);
break;
case pq\Result::TUPLES_OK:
printf("-> fetching done\n");
break;
}
});
+
do {
while ($c->busy) {
- switch ($c->poll()) {
- case pq\Connection::POLLING_READING:
- $w=$e=array();
- $r=array($c->socket);
- stream:select($r,$w,$e,1);
- break;
- case pq\Connection::POLLING_WRITING:
- $r=$e=array();
- $w=array($c->socket);
- stream_select($r,$w,$e,1);
- break;
+ $r = array($c->socket);
+ $w = $e = null;
+ if (stream_select($r, $w, $e, null)) {
+ $c->poll();
}
}
} while ($c->getResult());
+
?>
DONE
--EXPECTF--