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 (8) {
  31   ["status"]=>
  32   int(9)
  33   ["statusMessage"]=>
  34   string(12) "SINGLE_TUPLE"
  35   ["errorMessage"]=>
  36   string(0) ""
  37   ["numRows"]=>
  38   int(1)
  39   ["numCols"]=>
  40   int(1)
  41   ["affectedRows"]=>
  42   int(0)
  43   ["fetchType"]=>
  44   int(0)
  45   ["autoConvert"]=>
  46   int(65535)
  47 }
  48 object(pq\Result)#%d (8) {
  49   ["status"]=>
  50   int(9)
  51   ["statusMessage"]=>
  52   string(12) "SINGLE_TUPLE"
  53   ["errorMessage"]=>
  54   string(0) ""
  55   ["numRows"]=>
  56   int(1)
  57   ["numCols"]=>
  58   int(1)
  59   ["affectedRows"]=>
  60   int(0)
  61   ["fetchType"]=>
  62   int(0)
  63   ["autoConvert"]=>
  64   int(65535)
  65 }
  66 object(pq\Result)#%d (8) {
  67   ["status"]=>
  68   int(9)
  69   ["statusMessage"]=>
  70   string(12) "SINGLE_TUPLE"
  71   ["errorMessage"]=>
  72   string(0) ""
  73   ["numRows"]=>
  74   int(1)
  75   ["numCols"]=>
  76   int(1)
  77   ["affectedRows"]=>
  78   int(0)
  79   ["fetchType"]=>
  80   int(0)
  81   ["autoConvert"]=>
  82   int(65535)
  83 }
  84 object(pq\Result)#%d (8) {
  85   ["status"]=>
  86   int(2)
  87   ["statusMessage"]=>
  88   string(9) "TUPLES_OK"
  89   ["errorMessage"]=>
  90   string(0) ""
  91   ["numRows"]=>
  92   int(0)
  93   ["numCols"]=>
  94   int(1)
  95   ["affectedRows"]=>
  96   int(3)
  97   ["fetchType"]=>
  98   int(0)
  99   ["autoConvert"]=>
 100   int(65535)
 101 }
 102 DONE