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

   1 --TEST--
   2 unbuffered result
   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 var_dump($c->unbuffered ? true : false);
  13 $c->unbuffered = 1;
  14 var_dump($c->unbuffered);
  15
  16 $c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
  17         switch ($res->status) {
  18         case pq\Result::SINGLE_TUPLE:
  19                 $res->fetchCol("a", $val);
  20                 printf("%s\n", $val);
  21                 break;
  22         case pq\Result::TUPLES_OK:
  23                 printf("-> fetching done\n");
  24                 break;
  25         default:
  26                 printf("!! %s\n", $res->errorMessage);
  27                 break;
  28         }
  29 });
  30
  31 do {
  32         while ($c->busy) {
  33                 $r = array($c->socket);
  34                 $w = $e = null;
  35                 if (stream_select($r, $w, $e, null)) {
  36                         $c->poll();
  37                 }
  38         }
  39 } while ($c->getResult());
  40
  41 ?>
  42 DONE
  43 --EXPECTF--
  44 Test
  45 bool(false)
  46 bool(true)
  47 1
  48 2
  49 3
  50 4
  51 5
  52 6
  53 7
  54 8
  55 9
  56 10
  57 -> fetching done
  58 DONE