Annotation of embedaddon/php/ext/mysqli/tests/mysqli_poll_mixing_insert_select.phpt, revision 1.1
1.1 ! misho 1: --TEST--
! 2: mysqli_poll() & INSERT SELECT
! 3: --SKIPIF--
! 4: <?php
! 5: require_once('skipif.inc');
! 6: require_once('skipifemb.inc');
! 7: require_once('connect.inc');
! 8: require_once('skipifconnectfailure.inc');
! 9:
! 10: if (!$IS_MYSQLND)
! 11: die("skip mysqlnd only feature, compile PHP using --with-mysqli=mysqlnd");
! 12: ?>
! 13: --FILE--
! 14: <?php
! 15: require_once('table.inc');
! 16:
! 17: function get_connection() {
! 18: global $host, $user, $passwd, $db, $port, $socket;
! 19:
! 20: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
! 21: printf("[001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
! 22: return $link;
! 23: }
! 24:
! 25:
! 26: // Note: some queries will fail! They are supposed to fail.
! 27: $queries = array(
! 28: 'CREATE TABLE IF NOT EXISTS bogus(id INT)',
! 29: 'SET @a = 1',
! 30: 'SELECT * FROM test ORDER BY id ASC LIMIT 2',
! 31: "INSERT INTO test(id, label) VALUES (100, 'z')",
! 32: 'SELECT * FROM test ORDER BY id ASC LIMIT 2',
! 33: 'SELECT',
! 34: 'UPDATE test SET id = 101 WHERE id > 3',
! 35: 'UPDATE_FIX test SET id = 101 WHERE id > 3',
! 36: 'DROP TABLE IF EXISTS bogus',
! 37: 'DELETE FROM test WHERE id = @a',
! 38: 'DELETE FROM test WHERE id = 1',
! 39: );
! 40:
! 41: $link = get_connection();
! 42: $have_proc = false;
! 43: mysqli_real_query($link, "DROP PROCEDURE IF EXISTS p");
! 44: 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;')) {
! 45: $have_proc = true;
! 46: $queries[] = "CALL p('myversion', @version)";
! 47: }
! 48: mysqli_close($link);
! 49:
! 50: $links = array();
! 51: for ($i = 0; $i < count($queries); $i++) {
! 52:
! 53: $link = get_connection();
! 54:
! 55: if (true !== ($tmp = mysqli_query($link, $queries[$i], MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
! 56: printf("[002] Expecting true got %s/%s\n", gettype($tmp), var_export($tmp, true));
! 57:
! 58: // WARNING KLUDGE NOTE
! 59: // Add a tiny delay to ensure that queries get executed in a certain order
! 60: // If your MySQL server is very slow the test may randomly fail!
! 61: usleep(20000);
! 62:
! 63: $links[mysqli_thread_id($link)] = array(
! 64: 'query' => $queries[$i],
! 65: 'link' => $link,
! 66: 'processed' => false,
! 67: );
! 68: }
! 69:
! 70: $saved_errors = array();
! 71: do {
! 72: $poll_links = $poll_errors = $poll_reject = array();
! 73: foreach ($links as $thread_id => $link) {
! 74: if (!$link['processed']) {
! 75: $poll_links[] = $link['link'];
! 76: $poll_errors[] = $link['link'];
! 77: $poll_reject[] = $link['link'];
! 78: }
! 79: }
! 80: if (0 == count($poll_links))
! 81: break;
! 82:
! 83: if (0 == ($num_ready = mysqli_poll($poll_links, $poll_errors, $poll_reject, 0, 200000)))
! 84: continue;
! 85:
! 86: if (!empty($poll_errors)) {
! 87: die(var_dump($poll_errors));
! 88: }
! 89:
! 90: foreach ($poll_links as $link) {
! 91: $thread_id = mysqli_thread_id($link);
! 92: $links[$thread_id]['processed'] = true;
! 93:
! 94: if (is_object($res = mysqli_reap_async_query($link))) {
! 95: // result set object
! 96: while ($row = mysqli_fetch_assoc($res)) {
! 97: // eat up all results
! 98: ;
! 99: }
! 100: mysqli_free_result($res);
! 101: } else {
! 102: // either there is no result (no SELECT) or there is an error
! 103: if (mysqli_errno($link) > 0) {
! 104: $saved_errors[$thread_id] = mysqli_errno($link);
! 105: printf("[003] '%s' caused %d\n", $links[$thread_id]['query'], mysqli_errno($link));
! 106: }
! 107: }
! 108: }
! 109:
! 110: } while (true);
! 111:
! 112: // Checking if all lines are still usable
! 113: foreach ($links as $thread_id => $link) {
! 114: if (isset($saved_errors[$thread_id]) &&
! 115: $saved_errors[$thread_id] != mysqli_errno($link['link'])) {
! 116: printf("[004] Error state not saved for query '%s', %d != %d\n", $link['query'],
! 117: $saved_errors[$thread_id], mysqli_errno($link['link']));
! 118: }
! 119:
! 120: if (!$res = mysqli_query($link['link'], 'SELECT * FROM test WHERE id = 100'))
! 121: printf("[005] Expecting true got %s/%s\n", gettype($tmp), var_export($tmp, true));
! 122: if (!$row = mysqli_fetch_row($res))
! 123: printf("[006] Expecting true got %s/%s\n", gettype($tmp), var_export($tmp, true));
! 124:
! 125: mysqli_free_result($res);
! 126: }
! 127:
! 128: if ($res = mysqli_query($link['link'], "SELECT * FROM test WHERE id = 100")) {
! 129: $row = mysqli_fetch_assoc($res);
! 130: var_dump($row);
! 131: mysqli_free_result($res);
! 132: }
! 133:
! 134: if ($have_proc && ($res = mysqli_query($link['link'], "SELECT @version as _version"))) {
! 135: $row = mysqli_fetch_assoc($res);
! 136: if ($row['_version'] != 'myversion') {
! 137: printf("[007] Check procedures\n");
! 138: }
! 139: mysqli_free_result($res);
! 140: }
! 141:
! 142: foreach ($links as $link)
! 143: mysqli_close($link['link']);
! 144:
! 145: $link = get_connection();
! 146: if (!mysqli_query($link, 'SELECT 1', MYSQLI_ASYNC))
! 147: printf("[008] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
! 148:
! 149: if (!mysqli_query($link, 'SELECT 1', MYSQLI_ASYNC))
! 150: printf("[009] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
! 151:
! 152: mysqli_close($link);
! 153:
! 154: print "done!";
! 155: ?>
! 156: --CLEAN--
! 157: <?php
! 158: require_once("connect.inc");
! 159: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
! 160: printf("[c001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
! 161:
! 162: if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
! 163: printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
! 164:
! 165: if (!mysqli_query($link, "DROP TABLE IF EXISTS bogus"))
! 166: printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
! 167:
! 168: mysqli_query($link, "DROP PROCEDURE IF EXISTS p");
! 169:
! 170: mysqli_close($link);
! 171: ?>
! 172:
! 173: --EXPECTF--
! 174: [003] 'SELECT' caused 1064
! 175: [003] 'UPDATE test SET id = 101 WHERE id > 3' caused 1062
! 176: [003] 'UPDATE_FIX test SET id = 101 WHERE id > 3' caused 1064
! 177: array(2) {
! 178: [%u|b%"id"]=>
! 179: %unicode|string%(3) "100"
! 180: [%u|b%"label"]=>
! 181: %unicode|string%(1) "z"
! 182: }
! 183: [009] [2014] %s
! 184: done!
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mysqli_poll_mixing_insert_select.phpt CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / mysqli / tests