mirror of
https://github.com/danog/ext-pq.git
synced 2024-11-30 04:19:49 +01:00
63 lines
906 B
PHP
63 lines
906 B
PHP
--TEST--
|
|
unbuffered result
|
|
--SKIPIF--
|
|
<?php
|
|
include "_skipif.inc";
|
|
defined("pq\\Result::SINGLE_TUPLE") or die("skip need pq\\Result::SINGLE_TUPLE");
|
|
|
|
?>
|
|
--FILE--
|
|
<?php
|
|
echo "Test\n";
|
|
|
|
include "_setup.inc";
|
|
|
|
$c = new pq\Connection(PQ_DSN);
|
|
var_dump($c->unbuffered ? true : false);
|
|
$c->unbuffered = 1;
|
|
var_dump($c->unbuffered);
|
|
|
|
$c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
|
|
switch ($res->status) {
|
|
case pq\Result::SINGLE_TUPLE:
|
|
$res->fetchCol($val, "a");
|
|
printf("%s\n", $val);
|
|
break;
|
|
case pq\Result::TUPLES_OK:
|
|
printf("-> fetching done\n");
|
|
break;
|
|
default:
|
|
printf("!! %s\n", $res->errorMessage);
|
|
break;
|
|
}
|
|
});
|
|
|
|
do {
|
|
while ($c->busy) {
|
|
$r = array($c->socket);
|
|
$w = $e = null;
|
|
if (stream_select($r, $w, $e, null)) {
|
|
$c->poll();
|
|
}
|
|
}
|
|
} while ($c->getResult());
|
|
|
|
?>
|
|
DONE
|
|
--EXPECTF--
|
|
Test
|
|
bool(false)
|
|
bool(true)
|
|
1
|
|
2
|
|
3
|
|
4
|
|
5
|
|
6
|
|
7
|
|
8
|
|
9
|
|
10
|
|
-> fetching done
|
|
DONE
|