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 (7) {
  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 }
  46 object(pq\Result)#%d (7) {
  47   ["status"]=>
  48   int(9)
  49   ["statusMessage"]=>
  50   string(12) "SINGLE_TUPLE"
  51   ["errorMessage"]=>
  52   string(0) ""
  53   ["numRows"]=>
  54   int(1)
  55   ["numCols"]=>
  56   int(1)
  57   ["affectedRows"]=>
  58   int(0)
  59   ["fetchType"]=>
  60   int(0)
  61 }
  62 object(pq\Result)#%d (7) {
  63   ["status"]=>
  64   int(9)
  65   ["statusMessage"]=>
  66   string(12) "SINGLE_TUPLE"
  67   ["errorMessage"]=>
  68   string(0) ""
  69   ["numRows"]=>
  70   int(1)
  71   ["numCols"]=>
  72   int(1)
  73   ["affectedRows"]=>
  74   int(0)
  75   ["fetchType"]=>
  76   int(0)
  77 }
  78 object(pq\Result)#%d (7) {
  79   ["status"]=>
  80   int(2)
  81   ["statusMessage"]=>
  82   string(9) "TUPLES_OK"
  83   ["errorMessage"]=>
  84   string(0) ""
  85   ["numRows"]=>
  86   int(0)
  87   ["numCols"]=>
  88   int(1)
  89   ["affectedRows"]=>
  90   int(3)
  91   ["fetchType"]=>
  92   int(0)
  93 }
  94 DONE