git.m6w6.name Git - m6w6/ext-pq/blob - tests/async007.phpt

   1 --TEST--
   2 async statement
   3 --SKIPIF--
   4 <?php include "_skipif.inc"; ?>
   5 --FILE--
   6 <?php
   7 echo "Test\n";
   8 include "_setup.inc";
   9
  10 function complete($c) {
  11         do {
  12                 while ($c->busy) {
  13                         $r = array($c->socket);
  14                         $w = $e = null;
  15                         if (stream_select($r, $w, $e, null)) {
  16                                 $c->poll();
  17                         }
  18                 }
  19         } while ($c->getResult());
  20 }
  21
  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);
  26
  27 $s->execAsync(array("2012-12-12 12:12:12"));
  28 complete($s->connection);
  29
  30 $s->descAsync(function($r) use ($t) {
  31         list($typeOid) = $r->desc();
  32         printf("%s\n", $t[$typeOid]->typname);
  33 });
  34 complete($s->connection);
  35
  36 ?>
  37 DONE
  38 --EXPECT--
  39 Test
  40 timestamptz
  41 DONE