ext-pq/tests/async005.phpt

--TEST--
async prepared statement
--SKIPIF--
<?php include "_skipif.inc"; ?>
--FILE--
<?php
echo "Test\n";

include "_setup.inc";

function complete($s) {
	do {
		while ($s->connection->busy) {
			$r = array($s->connection->socket);
			$w = $e = null;
			if (stream_select($r, $w, $e, null)) {
				$s->connection->poll();
			}
		}
	} while ($s->connection->getResult());
}

$c = new pq\Connection(PQ_DSN);
$t = new pq\Types($c);
$s = $c->prepareAsync("test", "SELECT \$1,\$2::int4", array($t["int4"]->oid));

complete($s);

$s->execAsync(array(1,2), function ($res) {
	var_dump($res);
});

complete($s);

?>
DONE
--EXPECTF--
Test
object(pq\Result)#%d (8) {
  ["status"]=>
  int(2)
  ["statusMessage"]=>
  string(9) "TUPLES_OK"
  ["errorMessage"]=>
  string(0) ""
  ["numRows"]=>
  int(1)
  ["numCols"]=>
  int(2)
  ["affectedRows"]=>
  int(%d)
  ["fetchType"]=>
  int(0)
  ["autoConvert"]=>
  int(65535)
}
DONE