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

   1 --TEST--
   2 async 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->execAsync("SELECT 1+2+3; SELECT 2,3,4", function ($res) {
  13         var_dump($res);
  14 });
  15 do {
  16         while ($c->busy) {
  17                 $r = array($c->socket);
  18                 $w = $e = null;
  19                 if (stream_select($r, $w, $e, null)) {
  20                         $c->poll();
  21                 }
  22         }
  23 } while ($c->getResult());
  24
  25 ?>
  26 DONE
  27 --EXPECTF--
  28 Test
  29 object(pq\Result)#%d (8) {
  30   ["status"]=>
  31   int(2)
  32   ["statusMessage"]=>
  33   string(9) "TUPLES_OK"
  34   ["errorMessage"]=>
  35   string(0) ""
  36   ["numRows"]=>
  37   int(1)
  38   ["numCols"]=>
  39   int(1)
  40   ["affectedRows"]=>
  41   int(1)
  42   ["fetchType"]=>
  43   int(0)
  44   ["autoConvert"]=>
  45   int(255)
  46 }
  47 object(pq\Result)#%d (8) {
  48   ["status"]=>
  49   int(2)
  50   ["statusMessage"]=>
  51   string(9) "TUPLES_OK"
  52   ["errorMessage"]=>
  53   string(0) ""
  54   ["numRows"]=>
  55   int(1)
  56   ["numCols"]=>
  57   int(3)
  58   ["affectedRows"]=>
  59   int(1)
  60   ["fetchType"]=>
  61   int(0)
  62   ["autoConvert"]=>
  63   int(255)
  64 }
  65 DONE