| Server IP : 79.136.114.73 / Your IP : 3.136.11.217 Web Server : Apache/2.4.7 (Ubuntu) PHP/5.5.9-1ubuntu4.29 OpenSSL/1.0.1f System : Linux b8009 3.13.0-170-generic #220-Ubuntu SMP Thu May 9 12:40:49 UTC 2019 x86_64 User : www-data ( 33) PHP Version : 5.5.9-1ubuntu4.29 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /proc/self/root/home/b8009/php-5.6.22/ext/mysqli/tests/ |
Upload File : |
--TEST--
mysqli_poll() & INSERT SELECT
--SKIPIF--
<?php
require_once('skipif.inc');
require_once('skipifemb.inc');
require_once('connect.inc');
require_once('skipifconnectfailure.inc');
if (!$IS_MYSQLND)
die("skip mysqlnd only feature, compile PHP using --with-mysqli=mysqlnd");
?>
--FILE--
<?php
require_once('table.inc');
function get_connection() {
global $host, $user, $passwd, $db, $port, $socket;
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
printf("[001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
return $link;
}
// Note: some queries will fail! They are supposed to fail.
$queries = array(
'CREATE TABLE IF NOT EXISTS bogus(id INT)',
'SET @a = 1',
'SELECT * FROM test ORDER BY id ASC LIMIT 2',
"INSERT INTO test(id, label) VALUES (100, 'z')",
'SELECT * FROM test ORDER BY id ASC LIMIT 2',
'SELECT',
'UPDATE test SET id = 101 WHERE id > 3',
'UPDATE_FIX test SET id = 101 WHERE id > 3',
'DROP TABLE IF EXISTS bogus',
'DELETE FROM test WHERE id = @a',
'DELETE FROM test WHERE id = 1',
);
$link = get_connection();
$have_proc = false;
mysqli_real_query($link, "DROP PROCEDURE IF EXISTS p");
if (mysqli_real_query($link, 'CREATE PROCEDURE p(IN ver_in VARCHAR(25), OUT ver_out VARCHAR(25)) BEGIN SELECT ver_in INTO ver_out; END;')) {
$have_proc = true;
$queries[] = "CALL p('myversion', @version)";
}
mysqli_close($link);
$links = array();
for ($i = 0; $i < count($queries); $i++) {
$link = get_connection();
if (true !== ($tmp = mysqli_query($link, $queries[$i], MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
printf("[002] Expecting true got %s/%s\n", gettype($tmp), var_export($tmp, true));
// WARNING KLUDGE NOTE
// Add a tiny delay to ensure that queries get executed in a certain order
// If your MySQL server is very slow the test may randomly fail!
usleep(20000);
$links[mysqli_thread_id($link)] = array(
'query' => $queries[$i],
'link' => $link,
'processed' => false,
);
}
$saved_errors = array();
do {
$poll_links = $poll_errors = $poll_reject = array();
foreach ($links as $thread_id => $link) {
if (!$link['processed']) {
$poll_links[] = $link['link'];
$poll_errors[] = $link['link'];
$poll_reject[] = $link['link'];
}
}
if (0 == count($poll_links))
break;
if (0 === ($num_ready = mysqli_poll($poll_links, $poll_errors, $poll_reject, 0, 200000)))
continue;
if (!empty($poll_errors)) {
die(var_dump($poll_errors));
}
if (FALSE === $num_ready) {
die("Some mysqli indicated error");
}
foreach ($poll_links as $link) {
$thread_id = mysqli_thread_id($link);
$links[$thread_id]['processed'] = true;
if (is_object($res = mysqli_reap_async_query($link))) {
// result set object
while ($row = mysqli_fetch_assoc($res)) {
// eat up all results
;
}
mysqli_free_result($res);
} else {
// either there is no result (no SELECT) or there is an error
if (mysqli_errno($link) > 0) {
$saved_errors[$thread_id] = mysqli_errno($link);
printf("[003] '%s' caused %d\n", $links[$thread_id]['query'], mysqli_errno($link));
}
}
}
} while (true);
// Checking if all lines are still usable
foreach ($links as $thread_id => $link) {
if (isset($saved_errors[$thread_id]) &&
$saved_errors[$thread_id] != mysqli_errno($link['link'])) {
printf("[004] Error state not saved for query '%s', %d != %d\n", $link['query'],
$saved_errors[$thread_id], mysqli_errno($link['link']));
}
if (!$res = mysqli_query($link['link'], 'SELECT * FROM test WHERE id = 100'))
printf("[005] Expecting true got %s/%s\n", gettype($tmp), var_export($tmp, true));
if (!$row = mysqli_fetch_row($res))
printf("[006] Expecting true got %s/%s\n", gettype($tmp), var_export($tmp, true));
mysqli_free_result($res);
}
if ($res = mysqli_query($link['link'], "SELECT * FROM test WHERE id = 100")) {
$row = mysqli_fetch_assoc($res);
var_dump($row);
mysqli_free_result($res);
}
if ($have_proc && ($res = mysqli_query($link['link'], "SELECT @version as _version"))) {
$row = mysqli_fetch_assoc($res);
if ($row['_version'] != 'myversion') {
printf("[007] Check procedures\n");
}
mysqli_free_result($res);
}
foreach ($links as $link)
mysqli_close($link['link']);
$link = get_connection();
if (!mysqli_query($link, 'SELECT 1', MYSQLI_ASYNC))
printf("[008] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
if (!mysqli_query($link, 'SELECT 1', MYSQLI_ASYNC))
printf("[009] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
mysqli_close($link);
print "done!";
?>
--CLEAN--
<?php
require_once("connect.inc");
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
printf("[c001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
if (!mysqli_query($link, "DROP TABLE IF EXISTS bogus"))
printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
mysqli_query($link, "DROP PROCEDURE IF EXISTS p");
mysqli_close($link);
?>
--EXPECTF--
[003] 'SELECT' caused 1064
[003] 'UPDATE test SET id = 101 WHERE id > 3' caused 1062
[003] 'UPDATE_FIX test SET id = 101 WHERE id > 3' caused 1064
array(2) {
[%u|b%"id"]=>
%unicode|string%(3) "100"
[%u|b%"label"]=>
%unicode|string%(1) "z"
}
[009] [2014] %s
done!