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

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