4 <?php include "_skipif.inc"; ?>
10 function complete($c) {
13 $r = array($c->socket);
15 if (stream_select($r, $w, $e, null)) {
19 } while ($c->getResult());
22 $c = new pq\Connection(PQ_DSN);
23 $t = new pq\Types($c);
24 $s = new pq\Statement($c, "test1", "SELECT NOW() - \$1", null, true);
25 complete($s->connection);
27 $s->execAsync(array("2012-12-12 12:12:12"));
28 complete($s->connection);
30 $s->descAsync(function($r) use ($t) {
31 list($typeOid) = $r->desc();
32 printf("%s\n", $t[$typeOid]->typname);
34 complete($s->connection);