1--TEST-- 2mysqli_get_client_stats() 3--SKIPIF-- 4<?PHP 5require_once('skipif.inc'); 6require_once('skipifemb.inc'); 7require_once('skipifconnectfailure.inc'); 8if (!function_exists('mysqli_get_client_stats')) { 9 die("skip only available with mysqlnd"); 10} 11?> 12--INI-- 13mysqlnd.collect_statistics=1 14mysqlnd.collect_memory_statistics=1 15--FILE-- 16<?php 17 /* 18 TODO 19 no_index_used - difficult to simulate because server/engine dependent 20 bad_index_used - difficult to simulate because server/engine dependent 21 flushed_normal_sets 22 flushed_ps_sets 23 explicit_close 24 implicit_close 25 disconnect_close 26 in_middle_of_command_close 27 explicit_free_result 28 implicit_free_result 29 explicit_stmt_close 30 implicit_stmt_close 31 */ 32 33 function mysqli_get_client_stats_assert_eq($field, $current, $expected, &$test_counter, $desc = "") { 34 35 $test_counter++; 36 if (is_array($current) && is_array($expected)) { 37 if ($current[$field] !== $expected[$field]) { 38 printf("[%03d] %s Expecting %s = %s/%s, got %s/%s\n", 39 $test_counter, $desc, 40 $field, $expected[$field], gettype($expected[$field]), 41 $current[$field], gettype($current[$field])); 42 } 43 } else if (is_array($current)) { 44 if ($current[$field] !== $expected) { 45 printf("[%03d] %s Expecting %s = %s/%s, got %s/%s\n", 46 $test_counter, $desc, 47 $field, $expected, gettype($expected), 48 $current[$field], gettype($current[$field])); 49 } 50 } else { 51 if ($current !== $expected) { 52 printf("[%03d] %s Expecting %s = %s/%s, got %s/%s\n", 53 $test_counter, $desc, 54 $field, $expected, gettype($expected), 55 $current, gettype($current)); 56 } 57 } 58 59 } 60 61 function mysqli_get_client_stats_assert_gt($field, $current, $expected, &$test_counter, $desc = "") { 62 63 $test_counter++; 64 if (is_array($current) && is_array($expected)) { 65 if ($current[$field] <= $expected[$field]) { 66 printf("[%03d] %s Expecting %s > %s/%s, got %s/%s\n", 67 $test_counter, $desc, 68 $field, $expected[$field], gettype($expected[$field]), 69 $current[$field], gettype($current[$field])); 70 } 71 } else { 72 if ($current <= $expected) { 73 printf("[%03d] %s Expecting %s > %s/%s, got %s/%s\n", 74 $test_counter, $desc, $field, 75 $expected, gettype($expected), 76 $current, gettype($current)); 77 } 78 } 79 80 } 81 82 83 $tmp = $link = null; 84 if (!is_null($tmp = @mysqli_get_client_stats($link))) 85 printf("[001] Expecting NULL, got %s/%s\n", gettype($tmp), $tmp); 86 87 require_once("connect.inc"); 88 89 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 90 printf("[002] Expecting array/any_non_empty, got %s/%s\n", gettype($info), $info); 91 92 var_dump($info); 93 94 if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket)) { 95 printf("[003] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n", 96 $host, $user, $db, $port, $socket); 97 exit(1); 98 } 99 100 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 101 printf("[004] Expecting array/any_non_empty, got %s/%s\n", gettype($new_info), $new_info); 102 103 if (count($info) != count($new_info)) { 104 printf("[005] Expecting the same number of entries in the arrays\n"); 105 var_dump($info); 106 var_dump($new_info); 107 } 108 109 $test_counter = 6; 110 111 mysqli_get_client_stats_assert_gt('bytes_sent', $new_info, $info, $test_counter); 112 mysqli_get_client_stats_assert_gt('bytes_received', $new_info, $info, $test_counter); 113 mysqli_get_client_stats_assert_gt('packets_sent', $new_info, $info, $test_counter); 114 mysqli_get_client_stats_assert_gt('packets_received', $new_info, $info, $test_counter); 115 mysqli_get_client_stats_assert_gt('protocol_overhead_in', $new_info, $info, $test_counter); 116 mysqli_get_client_stats_assert_gt('protocol_overhead_out', $new_info, $info, $test_counter); 117 118 // we assume the above as tested and in the following we check only those 119 mysqli_get_client_stats_assert_eq('result_set_queries', $new_info, $info, $test_counter); 120 121 /* we need to skip this test in unicode - we send set names utf8 during mysql_connect */ 122 if (!(version_compare(PHP_VERSION, '6.0', '==') == 1)) 123 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, $info, $test_counter); 124 mysqli_get_client_stats_assert_eq('buffered_sets', $new_info, $info, $test_counter); 125 mysqli_get_client_stats_assert_eq('unbuffered_sets', $new_info, $info, $test_counter); 126 mysqli_get_client_stats_assert_eq('ps_buffered_sets', $new_info, $info, $test_counter); 127 mysqli_get_client_stats_assert_eq('ps_unbuffered_sets', $new_info, $info, $test_counter); 128 129 mysqli_get_client_stats_assert_eq('rows_skipped_ps', $new_info, $info, $test_counter); 130 mysqli_get_client_stats_assert_eq('copy_on_write_saved', $new_info, $info, $test_counter); 131 mysqli_get_client_stats_assert_eq('copy_on_write_performed', $new_info, $info, $test_counter); 132 mysqli_get_client_stats_assert_eq('command_buffer_too_small', $new_info, $info, $test_counter); 133 // This is not a mistake that I use %unicode|string%(1) "1" here! Andrey did not go for int to avoid any 134 // issues for very large numbers and 32 vs. 64bit systems 135 mysqli_get_client_stats_assert_eq('connect_success', $new_info, "1", $test_counter); 136 mysqli_get_client_stats_assert_eq('connect_failure', $new_info, $info, $test_counter); 137 mysqli_get_client_stats_assert_eq('connection_reused', $new_info, $info, $test_counter); 138 139 // No data fetched so far 140 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $new_info, "0", $test_counter); 141 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $new_info, "0", $test_counter); 142 143 require('table.inc'); 144 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 145 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 146 ++$test_counter, gettype($info), $info); 147 148 // fetch stats 149 $expected = $info; 150 151 // buffered normal 152 print "Testing buffered normal...\n"; 153 if (!$res = mysqli_query($link, 'SELECT COUNT(*) AS _num FROM test', MYSQLI_STORE_RESULT)) 154 printf("[%03d] SELECT COUNT() FROM test failed, [%d] %s\n", 155 ++$test_counter, mysqli_errno($link), mysqli_error($link)); 156 157 $expected['rows_fetched_from_server_normal'] = (string)($expected['rows_fetched_from_server_normal'] + 1); 158 $expected['buffered_sets'] = (string)($expected['buffered_sets'] + 1); 159 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 160 $expected['rows_buffered_from_client_normal'] = (string)($expected['rows_buffered_from_client_normal'] + 1); 161 162 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 163 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 164 ++$test_counter, gettype($info), $info); 165 166 mysqli_get_client_stats_assert_gt('bytes_sent', $info, $expected, $test_counter); 167 mysqli_get_client_stats_assert_gt('bytes_received', $info, $expected, $test_counter); 168 169 // real_data_* get incremented after mysqli_*fetch*() 170 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, "0", $test_counter); 171 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, "0", $test_counter); 172 173 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 174 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_buffered', $info, $expected, $test_counter); 175 mysqli_get_client_stats_assert_eq('buffered_sets', $info, $expected, $test_counter); 176 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 177 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_normal', $info, $expected, $test_counter); 178 179 /* no change to rows_fetched_from_client_normal_buffered! */ 180 if (!$row = mysqli_fetch_assoc($res)) 181 printf("[%03d] fetch_assoc - SELECT COUNT() FROM test failed, [%d] %s\n", 182 ++$test_counter, mysqli_errno($link), mysqli_error($link)); 183 184 $expected['rows_fetched_from_client_normal_buffered'] = (string)($expected['rows_fetched_from_client_normal_buffered'] + 1); 185 186 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 187 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 188 ++$test_counter, gettype($info), $info); 189 190 // fetch will increment 191 mysqli_get_client_stats_assert_gt('bytes_received_real_data_normal', $info, $expected, $test_counter); 192 $expected['bytes_received_real_data_normal'] = $info['bytes_received_real_data_normal']; 193 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, "0", $test_counter); 194 195 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 196 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_buffered', $info, $expected, $test_counter); 197 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_normal', $info, $expected, $test_counter); 198 199 $num_rows = $row['_num']; 200 mysqli_free_result($res); 201 202 print "Testing buffered normal... - SELECT id, label FROM test\n"; 203 if (!$res = mysqli_query($link, 'SELECT id, label FROM test', MYSQLI_STORE_RESULT)) 204 printf("[%03d] SELECT id, label FROM test failed, [%d] %s\n", 205 ++$test_counter, mysqli_errno($link), mysqli_error($link)); 206 207 208 assert(mysqli_num_rows($res) == $num_rows); 209 210 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 211 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 212 ++$test_counter, gettype($info), $info); 213 214 215 $expected['rows_fetched_from_server_normal'] = (string)($expected['rows_fetched_from_server_normal'] + $num_rows); 216 $expected['rows_buffered_from_client_normal'] = (string)($expected['rows_buffered_from_client_normal'] + $num_rows); 217 $expected['buffered_sets'] = (string)($expected['buffered_sets'] + 1); 218 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 219 220 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 221 222 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 223 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_buffered', $info, $expected, $test_counter); 224 mysqli_get_client_stats_assert_eq('buffered_sets', $info, $expected, $test_counter); 225 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 226 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_normal', $info, $expected, $test_counter); 227 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_normal', $info, $expected, $test_counter); 228 229 /* fetching none, but stats should not be affected - current implementation */ 230 mysqli_free_result($res); 231 232 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 233 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 234 ++$test_counter, gettype($info), $info); 235 236 237 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 238 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 239 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_buffered', $info, $expected, $test_counter); 240 241 print "Testing unbuffered normal...\n"; 242 if (!$res = mysqli_query($link, 'SELECT id, label FROM test', MYSQLI_USE_RESULT)) 243 printf("[%03d] SELECT id, label FROM test failed, [%d] %s\n", 244 ++$test_counter, mysqli_errno($link), mysqli_error($link)); 245 246 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 247 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 248 ++$test_counter, gettype($info), $info); 249 250 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 251 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_unbuffered', $info, $expected, $test_counter); 252 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 253 254 while ($row = mysqli_fetch_assoc($res)) 255 ; 256 mysqli_free_result($res); 257 258 $expected['rows_fetched_from_server_normal'] = (string)($expected['rows_fetched_from_server_normal'] + $num_rows); 259 $expected['rows_fetched_from_client_normal_unbuffered'] = (string)($expected['rows_fetched_from_client_normal_unbuffered'] + $num_rows); 260 $expected['unbuffered_sets'] = (string)($expected['unbuffered_sets'] + 1); 261 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 262 263 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 264 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 265 ++$test_counter, gettype($info), $info); 266 267 mysqli_get_client_stats_assert_gt('bytes_received_real_data_normal', $info, $expected, $test_counter); 268 $expected['bytes_received_real_data_normal'] = $info['bytes_received_real_data_normal']; 269 270 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 271 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_unbuffered', $info, $expected, $test_counter); 272 mysqli_get_client_stats_assert_eq('unbuffered_sets', $info, $expected, $test_counter); 273 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 274 275 print "Testing unbuffered normal... - SELECT id, label FROM test, not all fetched\n"; 276 if (!$res = mysqli_query($link, 'SELECT id, label FROM test', MYSQLI_USE_RESULT)) 277 printf("[%03d] SELECT id, label FROM test failed, [%d] %s\n", 278 ++$test_counter, mysqli_errno($link), mysqli_error($link)); 279 280 for ($i = 0; $i < $num_rows - 1; $i++) 281 $row = mysqli_fetch_assoc($res); 282 283 $expected['rows_fetched_from_server_normal'] = (string)($expected['rows_fetched_from_server_normal'] + $num_rows - 1); 284 $expected['rows_fetched_from_client_normal_unbuffered'] = (string)($expected['rows_fetched_from_client_normal_unbuffered'] + $num_rows - 1); 285 $expected['unbuffered_sets'] = (string)($expected['unbuffered_sets'] + 1); 286 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 287 288 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 289 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 290 ++$test_counter, gettype($info), $info); 291 292 mysqli_get_client_stats_assert_gt('bytes_received_real_data_normal', $info, $expected, $test_counter); 293 $expected['bytes_received_real_data_normal'] = $info['bytes_received_real_data_normal']; 294 295 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 296 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_unbuffered', $info, $expected, $test_counter); 297 mysqli_get_client_stats_assert_eq('unbuffered_sets', $info, $expected, $test_counter); 298 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 299 300 print "Testing if implicit fetching and cleaning happens...\n"; 301 mysqli_free_result($res); 302 303 /* last row has been implicitly cleaned from the wire by freeing the result set */ 304 $expected['rows_fetched_from_server_normal'] = (string)($expected['rows_fetched_from_server_normal'] + 1); 305 $expected['rows_fetched_from_client_normal_unbuffered'] = (string)($expected['rows_fetched_from_client_normal_unbuffered'] + 1); 306 $expected['rows_skipped_normal'] = (string)($info['rows_skipped_normal'] + 1); 307 $expected['flushed_normal_sets'] = (string)($expected['flushed_normal_sets'] + 1); 308 309 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 310 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 311 ++$test_counter, gettype($info), $info); 312 313 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 314 315 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_normal', $info, $expected, $test_counter); 316 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_normal_unbuffered', $info, $expected, $test_counter); 317 mysqli_get_client_stats_assert_eq('rows_skipped_normal', $info, $expected, $test_counter); 318 mysqli_get_client_stats_assert_eq('flushed_normal_sets', $info, $expected, $test_counter); 319 320 print "Testing buffered Prepared Statements...\n"; 321 if (!$stmt = mysqli_stmt_init($link)) 322 printf("[%03d] stmt_init() failed, [%d] %s\n", 323 ++$test_counter, mysqli_errno($link), mysqli_error($link)); 324 325 if (!mysqli_stmt_prepare($stmt, 'SELECT id, label FROM test') || 326 !mysqli_stmt_execute($stmt)) 327 printf("[%03d] prepare/execute failed, [%d] %s\n", 328 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 329 330 /* by default PS is unbuffered - no change */ 331 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 332 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_ps_buffered', $info, $expected, $test_counter); 333 334 if (!mysqli_stmt_store_result($stmt)) 335 printf("[%03d] store_result failed, [%d] %s\n", 336 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 337 mysqli_stmt_free_result($stmt); 338 339 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, "0", $test_counter); 340 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 341 342 $expected['rows_fetched_from_server_ps'] = (string)($expected['rows_fetched_from_server_ps'] + $num_rows); 343 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 344 $expected['ps_buffered_sets'] = (string)($expected['ps_buffered_sets'] + 1); 345 $expected['rows_buffered_from_client_ps'] = (string)($expected['rows_buffered_from_client_ps'] + $num_rows); 346 347 348 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 349 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 350 ++$test_counter, gettype($info), $info); 351 352 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 353 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_ps_buffered', $info, $expected, $test_counter); 354 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 355 mysqli_get_client_stats_assert_eq('ps_buffered_sets', $info, $expected, $test_counter); 356 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_ps', $info, $expected, $test_counter); 357 358 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, "0", $test_counter); 359 360 print "Testing buffered Prepared Statements... - fetching all\n"; 361 362 if (!mysqli_stmt_prepare($stmt, 'SELECT id, label FROM test') || 363 !mysqli_stmt_execute($stmt)) 364 printf("[%03d] prepare/execute failed, [%d] %s\n", 365 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 366 367 $id = $label = null; 368 if (!mysqli_stmt_bind_result($stmt, $id, $label)) 369 printf("[%03d] bind_result failed, [%d] %s\n", 370 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 371 372 if (!mysqli_stmt_store_result($stmt)) 373 printf("[%03d] store_result failed, [%d] %s\n", 374 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 375 376 while (mysqli_stmt_fetch($stmt)) 377 ; 378 379 $expected['rows_fetched_from_server_ps'] = (string)($expected['rows_fetched_from_server_ps'] + $num_rows); 380 $expected['rows_fetched_from_client_ps_buffered'] = (string)($expected['rows_fetched_from_client_ps_buffered'] + $num_rows); 381 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 382 $expected['ps_buffered_sets'] = (string)($expected['ps_buffered_sets'] + 1); 383 $expected['rows_buffered_from_client_ps'] = (string)($expected['rows_buffered_from_client_ps'] + $num_rows); 384 385 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 386 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 387 ++$test_counter, gettype($info), $info); 388 389 390 mysqli_get_client_stats_assert_gt('bytes_received_real_data_ps', $info, $expected, $test_counter); 391 $expected['bytes_received_real_data_ps'] = $info['bytes_received_real_data_ps']; 392 393 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 394 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_ps_buffered', $info, $expected, $test_counter); 395 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 396 mysqli_get_client_stats_assert_eq('ps_buffered_sets', $info, $expected, $test_counter); 397 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_ps', $info, $expected, $test_counter); 398 399 mysqli_stmt_free_result($stmt); 400 401 print "Testing buffered Prepared Statements... - fetching all but one\n"; 402 403 if (!mysqli_stmt_prepare($stmt, 'SELECT id, label FROM test') || 404 !mysqli_stmt_execute($stmt)) 405 printf("[%03d] prepare/execute failed, [%d] %s\n", 406 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 407 408 $id = $label = null; 409 if (!mysqli_stmt_bind_result($stmt, $id, $label)) 410 printf("[%03d] bind_result failed, [%d] %s\n", 411 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 412 413 if (!mysqli_stmt_store_result($stmt)) 414 printf("[%03d] store_result failed, [%d] %s\n", 415 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 416 417 for ($i = 0; $i < $num_rows - 1; $i++) 418 mysqli_stmt_fetch($stmt); 419 420 $expected['rows_fetched_from_server_ps'] = (string)($expected['rows_fetched_from_server_ps'] + $num_rows); 421 $expected['rows_fetched_from_client_ps_buffered'] = (string)($expected['rows_fetched_from_client_ps_buffered'] + $num_rows - 1); 422 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 423 $expected['ps_buffered_sets'] = (string)($expected['ps_buffered_sets'] + 1); 424 $expected['rows_buffered_from_client_ps'] = (string)($expected['rows_buffered_from_client_ps'] + $num_rows); 425 426 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 427 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 428 ++$test_counter, gettype($info), $info); 429 430 mysqli_get_client_stats_assert_gt('bytes_received_real_data_ps', $info, $expected, $test_counter); 431 $expected['bytes_received_real_data_ps'] = $info['bytes_received_real_data_ps']; 432 433 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 434 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_ps_buffered', $info, $expected, $test_counter); 435 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 436 mysqli_get_client_stats_assert_eq('ps_buffered_sets', $info, $expected, $test_counter); 437 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_ps', $info, $expected, $test_counter); 438 439 $expected['rows_skipped_ps'] = $info['rows_skipped_ps']; 440 mysqli_stmt_free_result($stmt); 441 442 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 443 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 444 ++$test_counter, gettype($info), $info); 445 446 /* buffered result set - no skipping possible! */ 447 mysqli_get_client_stats_assert_eq('rows_skipped_ps', $info, $expected, $test_counter); 448 449 print "Testing unbuffered Prepared Statements... - fetching all\n"; 450 451 if (!mysqli_stmt_prepare($stmt, 'SELECT id, label FROM test') || 452 !mysqli_stmt_execute($stmt)) 453 printf("[%03d] prepare/execute failed, [%d] %s\n", 454 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 455 456 $id = $label = null; 457 if (!mysqli_stmt_bind_result($stmt, $id, $label)) 458 printf("[%03d] bind_result failed, [%d] %s\n", 459 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 460 461 $i = 0; 462 while (mysqli_stmt_fetch($stmt)) 463 $i++; 464 assert($num_rows = $i); 465 466 $expected['rows_fetched_from_server_ps'] = (string)($expected['rows_fetched_from_server_ps'] + $num_rows); 467 $expected['rows_fetched_from_client_ps_unbuffered'] = (string)($expected['rows_fetched_from_client_ps_unbuffered'] + $num_rows); 468 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 469 $expected['ps_unbuffered_sets'] = (string)($expected['ps_unbuffered_sets'] + 1); 470 471 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 472 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 473 ++$test_counter, gettype($info), $info); 474 475 mysqli_get_client_stats_assert_gt('bytes_received_real_data_ps', $info, $expected, $test_counter); 476 $expected['bytes_received_real_data_ps'] = $info['bytes_received_real_data_ps']; 477 478 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 479 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_ps_unbuffered', $info, $expected, $test_counter); 480 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 481 mysqli_get_client_stats_assert_eq('ps_unbuffered_sets', $info, $expected, $test_counter); 482 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_ps', $info, $expected, $test_counter); 483 484 mysqli_stmt_free_result($stmt); 485 486 print "Testing unbuffered Prepared Statements... - fetching all but one\n"; 487 488 if (!mysqli_stmt_prepare($stmt, 'SELECT id, label FROM test') || 489 !mysqli_stmt_execute($stmt)) 490 printf("[%03d] prepare/execute failed, [%d] %s\n", 491 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 492 493 $id = $label = null; 494 if (!mysqli_stmt_bind_result($stmt, $id, $label)) 495 printf("[%03d] bind_result failed, [%d] %s\n", 496 ++$test_counter, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt)); 497 498 for ($i = 0; $i < $num_rows - 1; $i++) 499 mysqli_stmt_fetch($stmt); 500 501 $expected['rows_fetched_from_server_ps'] = (string)($expected['rows_fetched_from_server_ps'] + $num_rows - 1); 502 $expected['rows_fetched_from_client_ps_unbuffered'] = (string)($expected['rows_fetched_from_client_ps_unbuffered'] + $num_rows - 1); 503 $expected['result_set_queries'] = (string)($expected['result_set_queries'] + 1); 504 $expected['ps_unbuffered_sets'] = (string)($expected['ps_unbuffered_sets'] + 1); 505 506 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 507 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 508 ++$test_counter, gettype($info), $info); 509 510 mysqli_get_client_stats_assert_gt('bytes_received_real_data_ps', $info, $expected, $test_counter); 511 $expected['bytes_received_real_data_ps'] = $info['bytes_received_real_data_ps']; 512 513 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 514 mysqli_get_client_stats_assert_eq('rows_fetched_from_client_ps_unbuffered', $info, $expected, $test_counter); 515 mysqli_get_client_stats_assert_eq('result_set_queries', $info, $expected, $test_counter); 516 mysqli_get_client_stats_assert_eq('ps_unbuffered_sets', $info, $expected, $test_counter); 517 mysqli_get_client_stats_assert_eq('rows_buffered_from_client_ps', $info, $expected, $test_counter); 518 519 mysqli_stmt_free_result($stmt); 520 $expected['rows_skipped_ps'] = (string)($expected['rows_skipped_ps'] + 1); 521 $expected['flushed_ps_sets'] = (string)($expected['flushed_ps_sets'] + 1); 522 $expected['rows_fetched_from_server_ps'] = (string)($expected['rows_fetched_from_server_ps'] + 1); 523 524 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 525 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 526 ++$test_counter, gettype($info), $info); 527 528 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, $expected, $test_counter); 529 530 mysqli_get_client_stats_assert_eq('rows_skipped_ps', $info, $expected, $test_counter); 531 mysqli_get_client_stats_assert_eq('flushed_ps_sets', $info, $expected, $test_counter); 532 mysqli_get_client_stats_assert_eq('rows_fetched_from_server_ps', $info, $expected, $test_counter); 533 534 /* 535 print "Checking for normal buffered side effects...\n"; 536 foreach ($info as $k => $v) 537 if ($info[$k] != $expected[$k]) 538 printf("$k - $v != %s\n", $expected[$k]); 539 */ 540 print "... done with fetch statistics\n"; 541 542 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 543 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 544 ++$test_counter, gettype($info), $info); 545 546 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 547 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, $expected, $test_counter); 548 549 // 550 // result_set_queries statistics 551 // 552 553 if (!is_array($info = mysqli_get_client_stats()) || empty($info)) 554 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 555 ++$test_counter, gettype($info), $info); 556 557 if (!$res = mysqli_query($link, "SELECT id, label FROM test")) 558 printf("[%03d] SELECT failed, [%d] %s\n", ++$test_counter, 559 mysqli_errno($link), mysqli_error($link)); 560 561 $rows = 0; 562 while ($row = mysqli_fetch_assoc($res)) 563 $rows++; 564 565 if (0 == $rows) 566 printf("[%03d] Expecting at least one result, [%d] %s\n", ++$test_counter, 567 mysqli_errno($link), mysqli_error($link)); 568 569 mysqli_free_result($res); 570 571 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 572 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 573 ++$test_counter, gettype($new_info), $new_info); 574 575 mysqli_get_client_stats_assert_eq('result_set_queries', $new_info, (string)($info['result_set_queries'] + 1), $test_counter); 576 $info = $new_info; 577 578 mysqli_get_client_stats_assert_gt('bytes_received_real_data_normal', $info, $expected, $test_counter); 579 $expected['bytes_received_real_data_normal'] = $info['bytes_received_real_data_normal']; 580 581 // 582 // non_result_set_queries - DDL 583 // 584 585 // CREATE TABLE, DROP TABLE 586 if (!mysqli_query($link, "DROP TABLE IF EXISTS non_result_set_queries_test")) 587 printf("[%03d] DROP TABLE failed, [%d] %s\n", ++$test_counter, 588 mysqli_errno($link), mysqli_error($link)); 589 590 if (!mysqli_query($link, "CREATE TABLE non_result_set_queries_test(id INT) ENGINE = " . $engine)) { 591 printf("[%03d] CREATE TABLE failed, [%d] %s\n", ++$test_counter, 592 mysqli_errno($link), mysqli_error($link)); 593 } else { 594 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 595 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 596 ++$test_counter, gettype($new_info), $new_info); 597 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 2), $test_counter, 'CREATE/DROP TABLE'); 598 } 599 $info = $new_info; 600 601 // ALERT TABLE 602 if (!mysqli_query($link, "ALTER TABLE non_result_set_queries_test ADD label CHAR(1)")) { 603 printf("[%03d] ALTER TABLE failed, [%d] %s\n", ++$test_counter, 604 mysqli_errno($link), mysqli_error($link)); 605 } else { 606 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 607 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 608 ++$test_counter, gettype($new_info), $new_info); 609 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'ALTER TABLE'); 610 } 611 $info = $new_info; 612 613 // CREATE INDEX, DROP INDEX 614 if (!mysqli_query($link, "CREATE INDEX idx_1 ON non_result_set_queries_test(id)")) { 615 printf("[%03d] CREATE INDEX failed, [%d] %s\n", ++$test_counter, 616 mysqli_errno($link), mysqli_error($link)); 617 } else { 618 619 if (!mysqli_query($link, "DROP INDEX idx_1 ON non_result_set_queries_test")) 620 printf("[%03d] DROP INDEX failed, [%d] %s\n", ++$test_counter, 621 mysqli_errno($link), mysqli_error($link)); 622 623 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 624 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 625 ++$test_counter, gettype($new_info), $new_info); 626 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 2), $test_counter, 'DROP INDEX'); 627 } 628 $info = $new_info; 629 630 // RENAME TABLE 631 if (!mysqli_query($link, "DROP TABLE IF EXISTS client_stats_test")) 632 printf("[%03d] Cleanup, DROP TABLE client_stats_test failed, [%d] %s\n", ++$test_counter, 633 mysqli_errno($link), mysqli_error($link)); 634 635 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 636 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 637 ++$test_counter, gettype($new_info), $new_info); 638 $info = $new_info; 639 640 if (!mysqli_query($link, "RENAME TABLE non_result_set_queries_test TO client_stats_test")) { 641 printf("[%03d] RENAME TABLE failed, [%d] %s\n", ++$test_counter, 642 mysqli_errno($link), mysqli_error($link)); 643 644 } else { 645 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 646 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 647 ++$test_counter, gettype($new_info), $new_info); 648 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'RENAME TABLE'); 649 650 } 651 $info = $new_info; 652 653 if (!mysqli_query($link, "DROP TABLE IF EXISTS non_result_set_queries_test")) 654 printf("[%03d] Cleanup, DROP TABLE failed, [%d] %s\n", ++$test_counter, 655 mysqli_errno($link), mysqli_error($link)); 656 657 if (!mysqli_query($link, "DROP TABLE IF EXISTS client_stats_test")) 658 printf("[%03d] Cleanup, DROP TABLE failed, [%d] %s\n", ++$test_counter, 659 mysqli_errno($link), mysqli_error($link)); 660 661 // Let's see if we have privileges for CREATE DATABASE 662 mysqli_query($link, "DROP DATABASE IF EXISTS mysqli_get_client_stats"); 663 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 664 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 665 ++$test_counter, gettype($new_info), $new_info); 666 $info = $new_info; 667 668 669 // CREATE, ALTER, RENAME, DROP DATABASE 670 if (mysqli_query($link, "CREATE DATABASE mysqli_get_client_stats")) { 671 672 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 673 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 674 ++$test_counter, gettype($new_info), $new_info); 675 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'CREATE DATABASE'); 676 $info = $new_info; 677 678 if (!mysqli_query($link, "ALTER DATABASE DEFAULT CHARACTER SET latin1")) 679 printf("[%03d] ALTER DATABASE failed, [%d] %s\n", ++$test_counter, 680 mysqli_errno($link), mysqli_error($link)); 681 682 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 683 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 684 ++$test_counter, gettype($new_info), $new_info); 685 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'CREATE DATABASE'); 686 $info = $new_info; 687 688 if (mysqli_get_server_version($link) > 51700) { 689 if (!mysqli_query($link, "RENAME DATABASE mysqli_get_client_stats TO mysqli_get_client_stats_")) 690 printf("[%03d] RENAME DATABASE failed, [%d] %s\n", ++$test_counter, 691 mysqli_errno($link), mysqli_error($link)); 692 693 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 694 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 695 ++$test_counter, gettype($new_info), $new_info); 696 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'CREATE DATABASE'); 697 $info = $new_info; 698 } else { 699 if (!mysqli_query($link, "CREATE DATABASE mysqli_get_client_stats_")) 700 printf("[%03d] CREATE DATABASE failed, [%d] %s\n", ++$test_counter, 701 mysqli_errno($link), mysqli_error($link)); 702 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 703 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 704 ++$test_counter, gettype($new_info), $new_info); 705 $info = $new_info; 706 } 707 708 if (!mysqli_query($link, "DROP DATABASE mysqli_get_client_stats_")) 709 printf("[%03d] DROP DATABASE failed, [%d] %s\n", ++$test_counter, 710 mysqli_errno($link), mysqli_error($link)); 711 712 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 713 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 714 ++$test_counter, gettype($new_info), $new_info); 715 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'DROP DATABASE'); 716 $info = $new_info; 717 } 718 719 // CREATE SERVER, ALTER SERVER, DROP SERVER 720 // We don't really try to use federated, we just want to see if the syntax works 721 mysqli_query($link, "DROP SERVER IF EXISTS myself"); 722 723 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 724 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 725 ++$test_counter, gettype($new_info), $new_info); 726 $info = $new_info; 727 728 $sql = sprintf("CREATE SERVER myself FOREIGN DATA WRAPPER mysql OPTIONS (user '%s', password '%s', database '%s')", 729 $user, $passwd, $db); 730 if (mysqli_query($link, $sql)) { 731 // server knows about it 732 733 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 734 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 735 ++$test_counter, gettype($new_info), $new_info); 736 737 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'CREATE SERVER'); 738 $info = $new_info; 739 740 if (!mysqli_query($link, sprintf("ALTER SERVER myself OPTIONS(user '%s_')", $user))) 741 printf("[%03d] ALTER SERVER failed, [%d] %s\n", ++$test_counter, 742 mysqli_errno($link), mysqli_error($link)); 743 744 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 745 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 746 ++$test_counter, gettype($new_info), $new_info); 747 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'ALTER SERVER'); 748 $info = $new_info; 749 750 if (!mysqli_query($link, "DROP SERVER myself")) 751 printf("[%03d] DROP SERVER failed, [%d] %s\n", ++$test_counter, 752 mysqli_errno($link), mysqli_error($link)); 753 754 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 755 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 756 ++$test_counter, gettype($new_info), $new_info); 757 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'DROP SERVER'); 758 $info = $new_info; 759 } 760 761 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 762 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, $expected, $test_counter); 763 764 /* 765 We don't test the NDB ones. 766 13.1. Data Definition Statements 767 13.1.3. ALTER LOGFILE GROUP Syntax 768 13.1.4. ALTER TABLESPACE Syntax 769 13.1.9. CREATE LOGFILE GROUP Syntax 770 13.1.10. CREATE TABLESPACE Syntax 771 13.1.15. DROP LOGFILE GROUP Syntax 772 13.1.16. DROP TABLESPACE Syntax 773 */ 774 775 // 776 // DML 777 // 778 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 779 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 780 ++$test_counter, gettype($new_info), $new_info); 781 $info = $new_info; 782 783 if (!mysqli_query($link, "INSERT INTO test(id) VALUES (100)")) 784 printf("[%03d] INSERT failed, [%d] %s\n", ++$test_counter, 785 mysqli_errno($link), mysqli_error($link)); 786 787 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 788 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 789 ++$test_counter, gettype($new_info), $new_info); 790 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'INSERT'); 791 $info = $new_info; 792 793 if (!mysqli_query($link, "UPDATE test SET label ='z' WHERE id = 100")) 794 printf("[%03d] UPDATE failed, [%d] %s\n", ++$test_counter, 795 mysqli_errno($link), mysqli_error($link)); 796 797 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 798 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 799 ++$test_counter, gettype($new_info), $new_info); 800 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'UPDATE'); 801 $info = $new_info; 802 803 if (!mysqli_query($link, "REPLACE INTO test(id, label) VALUES (100, 'b')")) 804 printf("[%03d] INSERT failed, [%d] %s\n", ++$test_counter, 805 mysqli_errno($link), mysqli_error($link)); 806 807 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 808 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 809 ++$test_counter, gettype($new_info), $new_info); 810 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'REPLACE'); 811 $info = $new_info; 812 813 // NOTE: this will NOT update dbl_ddls counter 814 if (!$res = mysqli_query($link, "SELECT id, label FROM test WHERE id = 100")) 815 printf("[%03d] SELECT@dml failed, [%d] %s\n", ++$test_counter, 816 mysqli_errno($link), mysqli_error($link)); 817 mysqli_free_result($res); 818 819 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 820 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 821 ++$test_counter, gettype($new_info), $new_info); 822 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, $info, $test_counter, 'SELECT@dml'); 823 $info = $new_info; 824 825 if (!mysqli_query($link, "DELETE FROM test WHERE id = 100")) 826 printf("[%03d] DELETE failed, [%d] %s\n", ++$test_counter, 827 mysqli_errno($link), mysqli_error($link)); 828 829 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 830 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 831 ++$test_counter, gettype($new_info), $new_info); 832 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'DELETE'); 833 $info = $new_info; 834 835 if (!$res = mysqli_query($link, "TRUNCATE TABLE test")) 836 printf("[%03d] TRUNCATE failed, [%d] %s\n", ++$test_counter, 837 mysqli_errno($link), mysqli_error($link)); 838 839 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 840 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 841 ++$test_counter, gettype($new_info), $new_info); 842 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'TRUNCATE'); 843 $info = $new_info; 844 845 846 $file = tempnam(sys_get_temp_dir(), 'mysqli_test'); 847 if ($fp = fopen($file, 'w')) { 848 @fwrite($fp, '1;"a"'); 849 fclose($fp); 850 chmod($file, 0644); 851 $sql = sprintf('LOAD DATA LOCAL INFILE "%s" INTO TABLE test', mysqli_real_escape_string($link, $file)); 852 if (mysqli_query($link, $sql)) { 853 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 854 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 855 ++$test_counter, gettype($new_info), $new_info); 856 mysqli_get_client_stats_assert_eq('non_result_set_queries', $new_info, (string)($info['non_result_set_queries'] + 1), $test_counter, 'LOAD DATA LOCAL'); 857 $info = $new_info; 858 } 859 unlink($file); 860 } 861 862 mysqli_get_client_stats_assert_eq('bytes_received_real_data_normal', $info, $expected, $test_counter); 863 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, $expected, $test_counter); 864 865 /* 866 We skip those: 867 13.2. Data Manipulation Statements 868 13.2.2. DO Syntax 869 13.2.3. HANDLER Syntax 870 13.2.5. LOAD DATA INFILE Syntax 871 */ 872 mysqli_query($link, "DELETE FROM test"); 873 if (!mysqli_query($link, "INSERT INTO test(id, label) VALUES (1, 'a'), (2, 'b')")) 874 printf("[%03d] Cannot insert new records, [%d] %s\n", ++$test_counter, 875 mysqli_errno($link), mysqli_error($link)); 876 877 if (!$res = mysqli_real_query($link, "SELECT id, label FROM test ORDER BY id")) 878 printf("[%03d] Cannot SELECT with mysqli_real_query(), [%d] %s\n", ++$test_counter, 879 mysqli_errno($link), mysqli_error($link)); 880 881 if (!is_object($res = mysqli_use_result($link))) 882 printf("[%03d] mysqli_use_result() failed, [%d] %s\n", ++$test_counter, 883 mysqli_errno($link), mysqli_error($link)); 884 885 while ($row = mysqli_fetch_assoc($res)) 886 ; 887 mysqli_free_result($res); 888 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 889 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 890 ++$test_counter, gettype($new_info), $new_info); 891 mysqli_get_client_stats_assert_eq('unbuffered_sets', $new_info, (string)($info['unbuffered_sets'] + 1), $test_counter, 'mysqli_use_result()'); 892 $info = $new_info; 893 894 if (!$res = mysqli_real_query($link, "SELECT id, label FROM test ORDER BY id")) 895 printf("[%03d] Cannot SELECT with mysqli_real_query() II, [%d] %s\n", ++$test_counter, 896 mysqli_errno($link), mysqli_error($link)); 897 898 if (!is_object($res = mysqli_store_result($link))) 899 printf("[%03d] mysqli_use_result() failed, [%d] %s\n", ++$test_counter, 900 mysqli_errno($link), mysqli_error($link)); 901 902 while ($row = mysqli_fetch_assoc($res)) 903 ; 904 mysqli_free_result($res); 905 if (!is_array($new_info = mysqli_get_client_stats()) || empty($new_info)) 906 printf("[%03d] Expecting array/any_non_empty, got %s/%s\n", 907 ++$test_counter, gettype($new_info), $new_info); 908 mysqli_get_client_stats_assert_eq('buffered_sets', $new_info, (string)($info['buffered_sets'] + 1), $test_counter, 'mysqli_use_result()'); 909 $info = $new_info; 910 911 mysqli_close($link); 912 913 mysqli_get_client_stats_assert_gt('bytes_received_real_data_normal', $info, $expected, $test_counter); 914 $expected['bytes_received_real_data_normal'] = $info['bytes_received_real_data_normal']; 915 mysqli_get_client_stats_assert_eq('bytes_received_real_data_ps', $info, $expected, $test_counter); 916 917 /* 918 no_index_used 919 bad_index_used 920 flushed_normal_sets 921 flushed_ps_sets 922 explicit_close 923 implicit_close 924 disconnect_close 925 in_middle_of_command_close 926 explicit_free_result 927 implicit_free_result 928 explicit_stmt_close 929 implicit_stmt_close 930 */ 931 932 print "done!"; 933?> 934--CLEAN-- 935<?php 936require_once("connect.inc"); 937if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket)) 938 printf("[c001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error()); 939 940if (!mysqli_query($link, "DROP TABLE IF EXISTS test")) 941 printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link)); 942 943if (!mysqli_query($link, "DROP TABLE IF EXISTS non_result_set_queries_test")) 944 printf("[c003] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link)); 945 946if (!mysqli_query($link, "DROP TABLE IF EXISTS client_stats_test")) 947 printf("[c004] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link)); 948 949if (!mysqli_query($link, "DROP DATABASE IF EXISTS mysqli_get_client_stats_")) 950 printf("[c005] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link)); 951 952if (!mysqli_query($link, "DROP DATABASE IF EXISTS mysqli_get_client_stats")) 953 printf("[c006] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link)); 954 955if (!mysqli_query($link, "DROP SERVER IF EXISTS myself")) 956 printf("[c007] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link)); 957 958mysqli_close($link); 959?> 960--EXPECTF-- 961array(161) { 962 [%u|b%"bytes_sent"]=> 963 %unicode|string%(1) "0" 964 [%u|b%"bytes_received"]=> 965 %unicode|string%(1) "0" 966 [%u|b%"packets_sent"]=> 967 %unicode|string%(1) "0" 968 [%u|b%"packets_received"]=> 969 %unicode|string%(1) "0" 970 [%u|b%"protocol_overhead_in"]=> 971 %unicode|string%(1) "0" 972 [%u|b%"protocol_overhead_out"]=> 973 %unicode|string%(1) "0" 974 [%u|b%"bytes_received_ok_packet"]=> 975 %unicode|string%(1) "0" 976 [%u|b%"bytes_received_eof_packet"]=> 977 %unicode|string%(1) "0" 978 [%u|b%"bytes_received_rset_header_packet"]=> 979 %unicode|string%(1) "0" 980 [%u|b%"bytes_received_rset_field_meta_packet"]=> 981 %unicode|string%(1) "0" 982 [%u|b%"bytes_received_rset_row_packet"]=> 983 %unicode|string%(1) "0" 984 [%u|b%"bytes_received_prepare_response_packet"]=> 985 %unicode|string%(1) "0" 986 [%u|b%"bytes_received_change_user_packet"]=> 987 %unicode|string%(1) "0" 988 [%u|b%"packets_sent_command"]=> 989 %unicode|string%(1) "0" 990 [%u|b%"packets_received_ok"]=> 991 %unicode|string%(1) "0" 992 [%u|b%"packets_received_eof"]=> 993 %unicode|string%(1) "0" 994 [%u|b%"packets_received_rset_header"]=> 995 %unicode|string%(1) "0" 996 [%u|b%"packets_received_rset_field_meta"]=> 997 %unicode|string%(1) "0" 998 [%u|b%"packets_received_rset_row"]=> 999 %unicode|string%(1) "0" 1000 [%u|b%"packets_received_prepare_response"]=> 1001 %unicode|string%(1) "0" 1002 [%u|b%"packets_received_change_user"]=> 1003 %unicode|string%(1) "0" 1004 [%u|b%"result_set_queries"]=> 1005 %unicode|string%(1) "0" 1006 [%u|b%"non_result_set_queries"]=> 1007 %unicode|string%(1) "0" 1008 [%u|b%"no_index_used"]=> 1009 %unicode|string%(1) "0" 1010 [%u|b%"bad_index_used"]=> 1011 %unicode|string%(1) "0" 1012 [%u|b%"slow_queries"]=> 1013 %unicode|string%(1) "0" 1014 [%u|b%"buffered_sets"]=> 1015 %unicode|string%(1) "0" 1016 [%u|b%"unbuffered_sets"]=> 1017 %unicode|string%(1) "0" 1018 [%u|b%"ps_buffered_sets"]=> 1019 %unicode|string%(1) "0" 1020 [%u|b%"ps_unbuffered_sets"]=> 1021 %unicode|string%(1) "0" 1022 [%u|b%"flushed_normal_sets"]=> 1023 %unicode|string%(1) "0" 1024 [%u|b%"flushed_ps_sets"]=> 1025 %unicode|string%(1) "0" 1026 [%u|b%"ps_prepared_never_executed"]=> 1027 %unicode|string%(1) "0" 1028 [%u|b%"ps_prepared_once_executed"]=> 1029 %unicode|string%(1) "0" 1030 [%u|b%"rows_fetched_from_server_normal"]=> 1031 %unicode|string%(1) "0" 1032 [%u|b%"rows_fetched_from_server_ps"]=> 1033 %unicode|string%(1) "0" 1034 [%u|b%"rows_buffered_from_client_normal"]=> 1035 %unicode|string%(1) "0" 1036 [%u|b%"rows_buffered_from_client_ps"]=> 1037 %unicode|string%(1) "0" 1038 [%u|b%"rows_fetched_from_client_normal_buffered"]=> 1039 %unicode|string%(1) "0" 1040 [%u|b%"rows_fetched_from_client_normal_unbuffered"]=> 1041 %unicode|string%(1) "0" 1042 [%u|b%"rows_fetched_from_client_ps_buffered"]=> 1043 %unicode|string%(1) "0" 1044 [%u|b%"rows_fetched_from_client_ps_unbuffered"]=> 1045 %unicode|string%(1) "0" 1046 [%u|b%"rows_fetched_from_client_ps_cursor"]=> 1047 %unicode|string%(1) "0" 1048 [%u|b%"rows_affected_normal"]=> 1049 %unicode|string%(1) "0" 1050 [%u|b%"rows_affected_ps"]=> 1051 %unicode|string%(1) "0" 1052 [%u|b%"rows_skipped_normal"]=> 1053 %unicode|string%(1) "0" 1054 [%u|b%"rows_skipped_ps"]=> 1055 %unicode|string%(1) "0" 1056 [%u|b%"copy_on_write_saved"]=> 1057 %unicode|string%(1) "0" 1058 [%u|b%"copy_on_write_performed"]=> 1059 %unicode|string%(1) "0" 1060 [%u|b%"command_buffer_too_small"]=> 1061 %unicode|string%(1) "0" 1062 [%u|b%"connect_success"]=> 1063 %unicode|string%(1) "0" 1064 [%u|b%"connect_failure"]=> 1065 %unicode|string%(1) "0" 1066 [%u|b%"connection_reused"]=> 1067 %unicode|string%(1) "0" 1068 [%u|b%"reconnect"]=> 1069 %unicode|string%(1) "0" 1070 [%u|b%"pconnect_success"]=> 1071 %unicode|string%(1) "0" 1072 [%u|b%"active_connections"]=> 1073 %unicode|string%(1) "0" 1074 [%u|b%"active_persistent_connections"]=> 1075 %unicode|string%(1) "0" 1076 [%u|b%"explicit_close"]=> 1077 %unicode|string%(1) "0" 1078 [%u|b%"implicit_close"]=> 1079 %unicode|string%(1) "0" 1080 [%u|b%"disconnect_close"]=> 1081 %unicode|string%(1) "0" 1082 [%u|b%"in_middle_of_command_close"]=> 1083 %unicode|string%(1) "0" 1084 [%u|b%"explicit_free_result"]=> 1085 %unicode|string%(1) "0" 1086 [%u|b%"implicit_free_result"]=> 1087 %unicode|string%(1) "0" 1088 [%u|b%"explicit_stmt_close"]=> 1089 %unicode|string%(1) "0" 1090 [%u|b%"implicit_stmt_close"]=> 1091 %unicode|string%(1) "0" 1092 [%u|b%"mem_emalloc_count"]=> 1093 %unicode|string%(1) "0" 1094 [%u|b%"mem_emalloc_amount"]=> 1095 %unicode|string%(1) "0" 1096 [%u|b%"mem_ecalloc_count"]=> 1097 %unicode|string%(1) "0" 1098 [%u|b%"mem_ecalloc_amount"]=> 1099 %unicode|string%(1) "0" 1100 [%u|b%"mem_erealloc_count"]=> 1101 %unicode|string%(1) "0" 1102 [%u|b%"mem_erealloc_amount"]=> 1103 %unicode|string%(1) "0" 1104 [%u|b%"mem_efree_count"]=> 1105 %unicode|string%(1) "0" 1106 [%u|b%"mem_efree_amount"]=> 1107 %unicode|string%(1) "0" 1108 [%u|b%"mem_malloc_count"]=> 1109 %unicode|string%(1) "0" 1110 [%u|b%"mem_malloc_amount"]=> 1111 %unicode|string%(1) "0" 1112 [%u|b%"mem_calloc_count"]=> 1113 %unicode|string%(%d) "%d" 1114 [%u|b%"mem_calloc_amount"]=> 1115 %unicode|string%(%d) "%d" 1116 [%u|b%"mem_realloc_count"]=> 1117 %unicode|string%(1) "0" 1118 [%u|b%"mem_realloc_amount"]=> 1119 %unicode|string%(1) "0" 1120 [%u|b%"mem_free_count"]=> 1121 %unicode|string%(1) "0" 1122 [%u|b%"mem_free_amount"]=> 1123 %unicode|string%(1) "0" 1124 [%u|b%"mem_estrndup_count"]=> 1125 %unicode|string%(1) "0" 1126 [%u|b%"mem_strndup_count"]=> 1127 %unicode|string%(1) "0" 1128 [%u|b%"mem_estndup_count"]=> 1129 %unicode|string%(1) "0" 1130 [%u|b%"mem_strdup_count"]=> 1131 %unicode|string%(1) "0" 1132 [%u|b%"proto_text_fetched_null"]=> 1133 %unicode|string%(1) "0" 1134 [%u|b%"proto_text_fetched_bit"]=> 1135 %unicode|string%(1) "0" 1136 [%u|b%"proto_text_fetched_tinyint"]=> 1137 %unicode|string%(1) "0" 1138 [%u|b%"proto_text_fetched_short"]=> 1139 %unicode|string%(1) "0" 1140 [%u|b%"proto_text_fetched_int24"]=> 1141 %unicode|string%(1) "0" 1142 [%u|b%"proto_text_fetched_int"]=> 1143 %unicode|string%(1) "0" 1144 [%u|b%"proto_text_fetched_bigint"]=> 1145 %unicode|string%(1) "0" 1146 [%u|b%"proto_text_fetched_decimal"]=> 1147 %unicode|string%(1) "0" 1148 [%u|b%"proto_text_fetched_float"]=> 1149 %unicode|string%(1) "0" 1150 [%u|b%"proto_text_fetched_double"]=> 1151 %unicode|string%(1) "0" 1152 [%u|b%"proto_text_fetched_date"]=> 1153 %unicode|string%(1) "0" 1154 [%u|b%"proto_text_fetched_year"]=> 1155 %unicode|string%(1) "0" 1156 [%u|b%"proto_text_fetched_time"]=> 1157 %unicode|string%(1) "0" 1158 [%u|b%"proto_text_fetched_datetime"]=> 1159 %unicode|string%(1) "0" 1160 [%u|b%"proto_text_fetched_timestamp"]=> 1161 %unicode|string%(1) "0" 1162 [%u|b%"proto_text_fetched_string"]=> 1163 %unicode|string%(1) "0" 1164 [%u|b%"proto_text_fetched_blob"]=> 1165 %unicode|string%(1) "0" 1166 [%u|b%"proto_text_fetched_enum"]=> 1167 %unicode|string%(1) "0" 1168 [%u|b%"proto_text_fetched_set"]=> 1169 %unicode|string%(1) "0" 1170 [%u|b%"proto_text_fetched_geometry"]=> 1171 %unicode|string%(1) "0" 1172 [%u|b%"proto_text_fetched_other"]=> 1173 %unicode|string%(1) "0" 1174 [%u|b%"proto_binary_fetched_null"]=> 1175 %unicode|string%(1) "0" 1176 [%u|b%"proto_binary_fetched_bit"]=> 1177 %unicode|string%(1) "0" 1178 [%u|b%"proto_binary_fetched_tinyint"]=> 1179 %unicode|string%(1) "0" 1180 [%u|b%"proto_binary_fetched_short"]=> 1181 %unicode|string%(1) "0" 1182 [%u|b%"proto_binary_fetched_int24"]=> 1183 %unicode|string%(1) "0" 1184 [%u|b%"proto_binary_fetched_int"]=> 1185 %unicode|string%(1) "0" 1186 [%u|b%"proto_binary_fetched_bigint"]=> 1187 %unicode|string%(1) "0" 1188 [%u|b%"proto_binary_fetched_decimal"]=> 1189 %unicode|string%(1) "0" 1190 [%u|b%"proto_binary_fetched_float"]=> 1191 %unicode|string%(1) "0" 1192 [%u|b%"proto_binary_fetched_double"]=> 1193 %unicode|string%(1) "0" 1194 [%u|b%"proto_binary_fetched_date"]=> 1195 %unicode|string%(1) "0" 1196 [%u|b%"proto_binary_fetched_year"]=> 1197 %unicode|string%(1) "0" 1198 [%u|b%"proto_binary_fetched_time"]=> 1199 %unicode|string%(1) "0" 1200 [%u|b%"proto_binary_fetched_datetime"]=> 1201 %unicode|string%(1) "0" 1202 [%u|b%"proto_binary_fetched_timestamp"]=> 1203 %unicode|string%(1) "0" 1204 [%u|b%"proto_binary_fetched_string"]=> 1205 %unicode|string%(1) "0" 1206 [%u|b%"proto_binary_fetched_json"]=> 1207 %unicode|string%(1) "0" 1208 [%u|b%"proto_binary_fetched_blob"]=> 1209 %unicode|string%(1) "0" 1210 [%u|b%"proto_binary_fetched_enum"]=> 1211 %unicode|string%(1) "0" 1212 [%u|b%"proto_binary_fetched_set"]=> 1213 %unicode|string%(1) "0" 1214 [%u|b%"proto_binary_fetched_geometry"]=> 1215 %unicode|string%(1) "0" 1216 [%u|b%"proto_binary_fetched_other"]=> 1217 %unicode|string%(1) "0" 1218 [%u|b%"init_command_executed_count"]=> 1219 %unicode|string%(1) "0" 1220 [%u|b%"init_command_failed_count"]=> 1221 %unicode|string%(1) "0" 1222 [%u|b%"com_quit"]=> 1223 %unicode|string%(1) "0" 1224 [%u|b%"com_init_db"]=> 1225 %unicode|string%(1) "0" 1226 [%u|b%"com_query"]=> 1227 %unicode|string%(1) "0" 1228 [%u|b%"com_field_list"]=> 1229 %unicode|string%(1) "0" 1230 [%u|b%"com_create_db"]=> 1231 %unicode|string%(1) "0" 1232 [%u|b%"com_drop_db"]=> 1233 %unicode|string%(1) "0" 1234 [%u|b%"com_refresh"]=> 1235 %unicode|string%(1) "0" 1236 [%u|b%"com_shutdown"]=> 1237 %unicode|string%(1) "0" 1238 [%u|b%"com_statistics"]=> 1239 %unicode|string%(1) "0" 1240 [%u|b%"com_process_info"]=> 1241 %unicode|string%(1) "0" 1242 [%u|b%"com_connect"]=> 1243 %unicode|string%(1) "0" 1244 [%u|b%"com_process_kill"]=> 1245 %unicode|string%(1) "0" 1246 [%u|b%"com_debug"]=> 1247 %unicode|string%(1) "0" 1248 [%u|b%"com_ping"]=> 1249 %unicode|string%(1) "0" 1250 [%u|b%"com_time"]=> 1251 %unicode|string%(1) "0" 1252 [%u|b%"com_delayed_insert"]=> 1253 %unicode|string%(1) "0" 1254 [%u|b%"com_change_user"]=> 1255 %unicode|string%(1) "0" 1256 [%u|b%"com_binlog_dump"]=> 1257 %unicode|string%(1) "0" 1258 [%u|b%"com_table_dump"]=> 1259 %unicode|string%(1) "0" 1260 [%u|b%"com_connect_out"]=> 1261 %unicode|string%(1) "0" 1262 [%u|b%"com_register_slave"]=> 1263 %unicode|string%(1) "0" 1264 [%u|b%"com_stmt_prepare"]=> 1265 %unicode|string%(1) "0" 1266 [%u|b%"com_stmt_execute"]=> 1267 %unicode|string%(1) "0" 1268 [%u|b%"com_stmt_send_long_data"]=> 1269 %unicode|string%(1) "0" 1270 [%u|b%"com_stmt_close"]=> 1271 %unicode|string%(1) "0" 1272 [%u|b%"com_stmt_reset"]=> 1273 %unicode|string%(1) "0" 1274 [%u|b%"com_stmt_set_option"]=> 1275 %unicode|string%(1) "0" 1276 [%u|b%"com_stmt_fetch"]=> 1277 %unicode|string%(1) "0" 1278 [%u|b%"com_deamon"]=> 1279 %unicode|string%(1) "0" 1280 [%u|b%"bytes_received_real_data_normal"]=> 1281 %unicode|string%(1) "0" 1282 [%u|b%"bytes_received_real_data_ps"]=> 1283 %unicode|string%(1) "0" 1284} 1285Testing buffered normal... 1286Testing buffered normal... - SELECT id, label FROM test 1287Testing unbuffered normal... 1288Testing unbuffered normal... - SELECT id, label FROM test, not all fetched 1289Testing if implicit fetching and cleaning happens... 1290Testing buffered Prepared Statements... 1291Testing buffered Prepared Statements... - fetching all 1292Testing buffered Prepared Statements... - fetching all but one 1293Testing unbuffered Prepared Statements... - fetching all 1294Testing unbuffered Prepared Statements... - fetching all but one 1295... done with fetch statistics 1296done!
