Tests for mysqli_stmt_send_long_data()

3 files changed, 319 insertions, 0 deletions

diff --git a/ext/mysqli/tests/mysqli_stmt_send_long_data.phpt b/ext/mysqli/tests/mysqli_stmt_send_long_data.phpt
new file mode 100644
index 0000000000..c745a9851b
--- /dev/null
+++ b/ext/mysqli/tests/mysqli_stmt_send_long_data.phpt
@@ -0,0 +1,128 @@
+--TEST--
+mysqli_stmt_send_long_data()
+--SKIPIF--
+<?php require_once('skipif.inc'); ?>
+<?php require_once('skipifemb.inc'); ?>
+--FILE--
+<?php
+	include "connect.inc";
+
+	$tmp    = NULL;
+	$link   = NULL;
+
+	if (!is_null($tmp = @mysqli_stmt_send_long_data()))
+		printf("[001] Expecting NULL, got %s/%s\n", gettype($tmp), $tmp);
+
+	if (!is_null($tmp = @mysqli_stmt_send_long_data($link)))
+		printf("[002] Expecting NULL, got %s/%s\n", gettype($tmp), $tmp);
+
+	require('table.inc');
+
+	if (!$stmt = mysqli_stmt_init($link))
+		printf("[003] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (NULL !== ($tmp = @mysqli_stmt_send_long_data($stmt, '')))
+		printf("[004] Expecting NULL, got %s/%s\n", gettype($tmp), $tmp);
+
+	if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
+		printf("[005] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_query($link, sprintf("CREATE TABLE test(id INT NOT NULL AUTO_INCREMENT, label LONGBLOB, PRIMARY KEY(id)) ENGINE = %s", $engine)))
+		printf("[006] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_stmt_prepare($stmt, "INSERT INTO test(id, label) VALUES (?, ?)"))
+		printf("[007] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	$id = null;
+	$label = null;
+	if (!mysqli_stmt_bind_param($stmt, "ib", $id, $label))
+		printf("[008] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	if (!$res = mysqli_query($link, 'SHOW VARIABLES LIKE "max_allowed_packet"'))
+		printf("[009] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!$row = mysqli_fetch_assoc($res))
+		printf("[010] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	mysqli_free_result($res);
+
+	if (0 === ($max_allowed_packet = (int)$row['Value']))
+		printf("[011] Cannot determine max_allowed_packet size and/or bogus max_allowed_packet setting used.\n");
+
+	// let's ignore upper limits for LONGBLOB (2^32) ...
+	// maximum packet size up to which we test is 10M
+	$tmp = '';
+	$blob = '';
+	for ($i = 0; $i < 1024; $i++) {
+		$tmp .= 'a';
+	}
+
+	$limit = min(floor($max_allowed_packet / 1024 / 2), 10240);
+	for ($i = 0; $i < $limit; $i++)
+			$blob .= $tmp;
+	/*
+	if (floor($max_allowed_packet / 1024) <= 10240) {
+			$limit = strlen($blob) - $max_allowed_packet - 1;
+			for ($i = 0; $i < $limit; $i++)
+					$blob .= 'a';
+	}
+	*/
+	assert(strlen($blob) <= $max_allowed_packet);
+
+	if (false !== ($tmp = mysqli_stmt_send_long_data($stmt, -1, $blob)))
+		printf("[012] Expecting boolean/false, got %s/%s. [%d] %s\n",
+			gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	if (false !== ($tmp = mysqli_stmt_send_long_data($stmt, PHP_INT_MAX + 1, $blob)))
+		printf("[013] Expecting boolean/false, got %s/%s. [%d] %s\n",
+			gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	if (false !== ($tmp = mysqli_stmt_send_long_data($stmt, 999, $blob)))
+		printf("[014] Expecting boolean/false, got %s/%s. [%d] %s\n",
+			gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	if (true !== ($tmp = mysqli_stmt_send_long_data($stmt, 1, $blob)))
+		printf("[015] Expecting boolean/true, got %s/%s. [%d] %s\n",
+			gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	$id = 1;
+	if (true !== mysqli_stmt_execute($stmt))
+		printf("[016] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+	mysqli_stmt_close($stmt);
+
+	if (!$res = mysqli_query($link, "SELECT id, label FROM test ORDER BY id"))
+		printf("[017] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (1 != ($tmp = mysqli_num_rows($res)))
+		printf("[018] Expecting 1 rows, mysqli_num_rows() reports %d rows. [%d] %s\n",
+			$tmp, mysqli_errno($link), mysqli_error($link));
+
+	if (!$row = mysqli_fetch_assoc($res))
+		printf("[019] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	mysqli_free_result($res);
+
+	if (empty($row['id']) || empty($row['label']) || ($row['id'] != 1))
+		printf("[020] Record seems to be incomplete\n");
+
+	if ($blob != $row['label'])
+		printf("[021] Blob value has not been stored properly!\n");
+
+	if (NULL !== ($tmp = @mysqli_stmt_send_long_data($stmt, '')))
+		printf("[022] Expecting NULL, got %s/%s\n");
+
+	/* Check that the function alias exists. It's a deprecated function,
+	but we have not announce the removal so far, therefore we need to check for it */
+	if (!is_null($tmp = @mysqli_send_long_data()))
+		printf("[023] Expecting NULL, got %s/%s\n", gettype($tmp), $tmp);
+
+	mysqli_close($link);
+	print "done!";
+?>
+--EXPECTF--
+Warning: mysqli_stmt_send_long_data(): Invalid parameter number in %s on line %d
+
+Warning: mysqli_stmt_send_long_data(): Invalid parameter number in %s on line %d
+
+Warning: mysqli_stmt_send_long_data(): Invalid parameter number in %s on line %d
+done!
\ No newline at end of file
diff --git a/ext/mysqli/tests/mysqli_stmt_send_long_data_packet_size_libmysql.phpt b/ext/mysqli/tests/mysqli_stmt_send_long_data_packet_size_libmysql.phpt
new file mode 100644
index 0000000000..7a915fb951
--- /dev/null
+++ b/ext/mysqli/tests/mysqli_stmt_send_long_data_packet_size_libmysql.phpt
@@ -0,0 +1,93 @@
+--TEST--
+mysqli_stmt_send_long_data() - exceed packet size, libmysql - bug #26824
+--SKIPIF--
+<?php require_once('skipif.inc'); ?>
+<?php
+require_once('skipifemb.inc');
+if (stristr(mysqli_get_client_info(), 'mysqlnd'))
+	die("skip: test for libmysql");
+?>
+--FILE--
+<?php
+	include "connect.inc";
+	require('table.inc');
+
+	if (!$stmt = mysqli_stmt_init($link))
+		printf("[001] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
+		printf("[002] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_query($link, sprintf("CREATE TABLE test(id INT NOT NULL AUTO_INCREMENT, label LONGBLOB, PRIMARY KEY(id)) ENGINE = %s", $engine)))
+		printf("[003] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_stmt_prepare($stmt, "INSERT INTO test(id, label) VALUES (?, ?)"))
+		printf("[004] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	$id = null;
+	$label = null;
+	if (!mysqli_stmt_bind_param($stmt, "ib", $id, $label))
+		printf("[005] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	if (!$res = mysqli_query($link, 'SHOW VARIABLES LIKE "max_allowed_packet"'))
+		printf("[006] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!$row = mysqli_fetch_assoc($res))
+		printf("[007] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	mysqli_free_result($res);
+
+	if (0 === ($max_allowed_packet = (int)$row['Value']))
+		printf("[008] Cannot determine max_allowed_packet size and/or bogus max_allowed_packet setting used.\n");
+
+	// let's ignore upper limits for LONGBLOB (2^32) ...
+	// maximum packet size up to which we test is 10M
+	$tmp = '';
+	$blob = '';
+	for ($i = 0; $i < 1024; $i++) {
+		$tmp .= 'a';
+	}
+
+	$limit = min(floor($max_allowed_packet / 1024 / 2), 10240);
+	for ($i = 0; $i < $limit; $i++)
+		$blob .= $tmp;
+
+	assert(strlen($blob) <= $max_allowed_packet);
+
+	if (true != ($tmp = mysqli_stmt_send_long_data($stmt, 1, $blob)))
+		printf("[009] Expecting boolean/true, got %s/%s. [%d] %s\n",
+			gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	$id = 1;
+	if (true !== mysqli_stmt_execute($stmt))
+		printf("[010] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	/*
+	TODO - we skip this part of the test for now, because of bugs.mysql.com/26824
+	if (floor($max_allowed_packet / 1024 / 2) <= 10240) {
+			// test with a blob smaller than 10M allows us to test
+			// for too long packages without wasting too much memory
+			$limit = $max_allowed_packet - strlen($blob) + 1;
+			$blob2 = $blob;
+			for ($i = 0; $i < $limit; $i++)
+					$blob2 .= 'b';
+
+			assert(strlen($blob2) > $max_allowed_packet);
+
+			if (true != ($tmp = mysqli_stmt_send_long_data($stmt, 1, $blob2)))
+					printf("[011] Expecting boolean/false, got %s/%s. [%d] %s\n",
+							gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+			$id = 2;
+			if (false !== ($tmp = mysqli_stmt_execute($stmt)))
+					printf("[012] Expecting boolean/false, got %s/%s, [%d] %s\n",
+							gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+	}
+	*/
+	mysqli_stmt_close($stmt);
+	mysqli_close($link);
+
+	print "done!";
+?>
+--EXPECTF--
+done!
\ No newline at end of file
diff --git a/ext/mysqli/tests/mysqli_stmt_send_long_data_packet_size_mysqlnd.phpt b/ext/mysqli/tests/mysqli_stmt_send_long_data_packet_size_mysqlnd.phpt
new file mode 100644
index 0000000000..8a3419171a
--- /dev/null
+++ b/ext/mysqli/tests/mysqli_stmt_send_long_data_packet_size_mysqlnd.phpt
@@ -0,0 +1,98 @@
+--TEST--
+mysqli_stmt_send_long_data() - exceed packet size, mysqlnd
+--SKIPIF--
+<?php require_once('skipif.inc'); ?>
+<?php
+require_once('skipifemb.inc');
+if (!stristr(mysqli_get_client_info(), 'mysqlnd'))
+	die("skip: warnings only available in mysqlnd");
+?>
+--FILE--
+<?php
+	include "connect.inc";
+	require('table.inc');
+
+	if (!$stmt = mysqli_stmt_init($link))
+		printf("[001] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
+		printf("[002] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_query($link, sprintf("CREATE TABLE test(id INT NOT NULL AUTO_INCREMENT, label LONGBLOB, PRIMARY KEY(id)) ENGINE = %s", $engine)))
+		printf("[003] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!mysqli_stmt_prepare($stmt, "INSERT INTO test(id, label) VALUES (?, ?)"))
+		printf("[004] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	$id = null;
+	$label = null;
+	if (!mysqli_stmt_bind_param($stmt, "ib", $id, $label))
+		printf("[005] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	if (!$res = mysqli_query($link, 'SHOW VARIABLES LIKE "max_allowed_packet"'))
+		printf("[006] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	if (!$row = mysqli_fetch_assoc($res))
+		printf("[007] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
+
+	mysqli_free_result($res);
+
+	if (0 === ($max_allowed_packet = (int)$row['Value']))
+		printf("[008] Cannot determine max_allowed_packet size and/or bogus max_allowed_packet setting used.\n");
+
+	// let's ignore upper limits for LONGBLOB (2^32) ...
+	// maximum packet size up to which we test is 10M
+	$tmp = '';
+	$blob = '';
+	$tmp = str_repeat('a', 1024);
+
+	$limit = min(floor($max_allowed_packet / 1024 / 2), 10240);
+	$blob = str_repeat($tmp, $limit);
+
+	assert(strlen($blob) <= $max_allowed_packet);
+
+	if (true !== ($tmp = mysqli_stmt_send_long_data($stmt, 1, $blob)))
+		printf("[009] Expecting boolean/true, got %s/%s. [%d] %s\n",
+			gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+	$id = 1;
+	if (true !== mysqli_stmt_execute($stmt))
+		printf("[010] [%d] %s\n", mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+		/*
+		TODO - we skip this because of the open bug http://bugs.mysql.com/bug.php?id=26824
+		It would always fail.
+
+		This should be added to the EXPECTF, if you reactivate the test
+Warning: mysqli_stmt_send_long_data(): Skipped %d bytes. Last command STMT_SEND_LONG_DATA hasn't consumed all the output from the server in %s on line %d
+
+Warning: mysqli_stmt_send_long_data(): There was an error while sending long data. Probably max_allowed_packet_size is smaller than the data. You have to increase it or send smaller chunks of data. Answer was %d bytes long. in %s on line %d
+
+
+
+		if (floor($max_allowed_packet / 1024 / 2) <= 10240) {
+				// test with a blob smaller than 10M allows us to test
+				// for too long packages without wasting too much memory
+				$limit = $max_allowed_packet - strlen($blob) + 1;
+				$blob2 = $blob;
+		$blob2 .= str_repeat('b', $limit);
+
+				assert(strlen($blob2) > $max_allowed_packet);
+
+				if (false !== ($tmp = mysqli_stmt_send_long_data($stmt, 1, $blob2)))
+						printf("[011] Expecting boolean/false, got %s/%s. [%d] %s\n",
+								gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+
+				$id = 2;
+				if (false !== ($tmp = mysqli_stmt_execute($stmt)))
+						printf("[012] Expecting boolean/false, got %s/%s, [%d] %s\n",
+								gettype($tmp), $tmp, mysqli_stmt_errno($stmt), mysqli_stmt_error($stmt));
+		}
+		*/
+	mysqli_stmt_close($stmt);
+	mysqli_close($link);
+
+	print "done!";
+?>
+--EXPECTF--
+done!
\ No newline at end of file