1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139
|
--TEST--
async exec
--SKIPIF--
<?php include "_skipif.inc"; ?>
--FILE--
<?php
echo "Test\n";
include "_setup.inc";
$c = new pq\Connection(PQ_DSN);
$c->execAsync("SELECT 1+2+3; SELECT 2,3,4", function ($res) {
var_dump($res);
});
do {
while ($c->busy) {
$r = array($c->socket);
$w = $e = null;
if (stream_select($r, $w, $e, 1, 1000)) {
$c->poll();
}
}
} while ($c->getResult());
?>
DONE
--EXPECTF--
Test
object(pq\Result)#%d (9) {
["status"]=>
int(2)
["statusMessage"]=>
string(9) "TUPLES_OK"
["errorMessage"]=>
string(0) ""
["diag"]=>
array(17) {
["severity"]=>
NULL
["sqlstate"]=>
NULL
["message_primary"]=>
NULL
["message_detail"]=>
NULL
["message_hint"]=>
NULL
["statement_position"]=>
NULL
["internal_position"]=>
NULL
["internal_query"]=>
NULL
["context"]=>
NULL
["schema_name"]=>
NULL
["table_name"]=>
NULL
["column_name"]=>
NULL
["datatype_name"]=>
NULL
["constraint_name"]=>
NULL
["source_file"]=>
NULL
["source_line"]=>
NULL
["source_function"]=>
NULL
}
["numRows"]=>
int(1)
["numCols"]=>
int(1)
["affectedRows"]=>
int(%d)
["fetchType"]=>
int(0)
["autoConvert"]=>
int(65535)
}
object(pq\Result)#%d (9) {
["status"]=>
int(2)
["statusMessage"]=>
string(9) "TUPLES_OK"
["errorMessage"]=>
string(0) ""
["diag"]=>
array(17) {
["severity"]=>
NULL
["sqlstate"]=>
NULL
["message_primary"]=>
NULL
["message_detail"]=>
NULL
["message_hint"]=>
NULL
["statement_position"]=>
NULL
["internal_position"]=>
NULL
["internal_query"]=>
NULL
["context"]=>
NULL
["schema_name"]=>
NULL
["table_name"]=>
NULL
["column_name"]=>
NULL
["datatype_name"]=>
NULL
["constraint_name"]=>
NULL
["source_file"]=>
NULL
["source_line"]=>
NULL
["source_function"]=>
NULL
}
["numRows"]=>
int(1)
["numCols"]=>
int(3)
["affectedRows"]=>
int(%d)
["fetchType"]=>
int(0)
["autoConvert"]=>
int(65535)
}
DONE
|