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 do {
  30         while ($c->busy) {
  31                 switch ($c->poll()) {
  32                         case pq\Connection::POLLING_READING:
  33                                 $w=$e=array();
  34                                 $r=array($c->socket);
  35                                 stream:select($r,$w,$e,1);
  36                                 break;
  37                         case pq\Connection::POLLING_WRITING:
  38                                 $r=$e=array();
  39                                 $w=array($c->socket);
  40                                 stream_select($r,$w,$e,1);
  41                                 break;
  42                 }
  43         }
  44 } while ($c->getResult());
  45 ?>
  46 DONE
  47 --EXPECTF--
  48 Test
  49 bool(false)
  50 bool(true)
  51 1
  52 2
  53 3
  54 4
  55 5
  56 6
  57 7
  58 8
  59 9
  60 10
  61 -> fetching done
  62 DONE