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