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

   1 --TEST--
   2 async unbuffered exec
   3 --SKIPIF--
   4 <?php include "_skipif.inc"; ?>
   5 --FILE--
   6 <?php
   7 echo "Test\n";
   8
   9 include "_setup.inc";
  10
  11 $c = new pq\Connection(PQ_DSN);
  12 $c->unbuffered = true;
  13 $c->execAsync("SELECT a FROM generate_series(1,3) a", function ($res) {
  14         var_dump($res);
  15 });
  16 do {
  17         while ($c->busy) {
  18                 $r = array($c->socket);
  19                 $w = $e = null;
  20                 if (stream_select($r, $w, $e, null)) {
  21                         $c->poll();
  22                 }
  23         }
  24 } while ($c->getResult());
  25
  26 ?>
  27 DONE
  28 --EXPECTF--
  29 Test
  30 object(pq\Result)#%d (6) {
  31   ["status"]=>
  32   int(9)
  33   ["errorMessage"]=>
  34   string(0) ""
  35   ["numRows"]=>
  36   int(1)
  37   ["numCols"]=>
  38   int(1)
  39   ["affectedRows"]=>
  40   int(0)
  41   ["fetchType"]=>
  42   int(0)
  43 }
  44 object(pq\Result)#%d (6) {
  45   ["status"]=>
  46   int(9)
  47   ["errorMessage"]=>
  48   string(0) ""
  49   ["numRows"]=>
  50   int(1)
  51   ["numCols"]=>
  52   int(1)
  53   ["affectedRows"]=>
  54   int(0)
  55   ["fetchType"]=>
  56   int(0)
  57 }
  58 object(pq\Result)#%d (6) {
  59   ["status"]=>
  60   int(9)
  61   ["errorMessage"]=>
  62   string(0) ""
  63   ["numRows"]=>
  64   int(1)
  65   ["numCols"]=>
  66   int(1)
  67   ["affectedRows"]=>
  68   int(0)
  69   ["fetchType"]=>
  70   int(0)
  71 }
  72 object(pq\Result)#%d (6) {
  73   ["status"]=>
  74   int(2)
  75   ["errorMessage"]=>
  76   string(0) ""
  77   ["numRows"]=>
  78   int(0)
  79   ["numCols"]=>
  80   int(1)
  81   ["affectedRows"]=>
  82   int(3)
  83   ["fetchType"]=>
  84   int(0)
  85 }
  86 DONE