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

   1 --TEST--
   2 unbuffered result
   3 --SKIPIF--
   4 <?php
   5 include "_skipif.inc";
   6 defined("pq\\Result::SINGLE_TUPLE") or die("skip need pq\\Result::SINGLE_TUPLE");
   7
   8 ?>
   9 --FILE--
  10 <?php
  11 echo "Test\n";
  12
  13 include "_setup.inc";
  14
  15 $c = new pq\Connection(PQ_DSN);
  16 var_dump($c->unbuffered ? true : false);
  17 $c->unbuffered = 1;
  18 var_dump($c->unbuffered);
  19
  20 $c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
  21         switch ($res->status) {
  22         case pq\Result::SINGLE_TUPLE:
  23                 $res->fetchCol($val, "a");
  24                 printf("%s\n", $val);
  25                 break;
  26         case pq\Result::TUPLES_OK:
  27                 printf("-> fetching done\n");
  28                 break;
  29         default:
  30                 printf("!! %s\n", $res->errorMessage);
  31                 break;
  32         }
  33 });
  34
  35 do {
  36         while ($c->busy) {
  37                 $r = array($c->socket);
  38                 $w = $e = null;
  39                 if (stream_select($r, $w, $e, null)) {
  40                         $c->poll();
  41                 }
  42         }
  43 } while ($c->getResult());
  44
  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