pdo_mysql_stmt_closecursor.phpt   [plain text]

--TEST--
MySQL PDOStatement->closeCursor()
--SKIPIF--
<?php
require_once(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'skipif.inc');
require_once(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'mysql_pdo_test.inc');
MySQLPDOTest::skip();
$db = MySQLPDOTest::factory();
?>
--FILE--
<?php
	/* TODO the results look wrong, why do we get 2014 with buffered AND unbuffered queries */
	require_once(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'mysql_pdo_test.inc');
	$db = MySQLPDOTest::factory();

	function pdo_mysql_stmt_closecursor($db) {

		// This one should fail. I let it fail to prove that closeCursor() makes a difference.
		// If no error messages gets printed do not know if proper usage of closeCursor() makes any
		// difference or not. That's why we need to cause an error here.
		$db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
		$stmt1 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		// query() shall fail!
		$stmt2 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		$stmt1->closeCursor();

		// This is proper usage of closeCursor(). It shall prevent any further error messages.
		if (MySQLPDOTest::isPDOMySQLnd()) {
			$stmt1 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		} else {
			// see pdo_mysql_stmt_unbuffered_2050.phpt for an explanation
			unset($stmt1);
			$stmt1 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		}
		// fetch only the first rows and let closeCursor() clean up
		$row1 = $stmt1->fetch(PDO::FETCH_ASSOC);
		$stmt1->closeCursor();

		$stmt2 = $db->prepare('UPDATE test SET label = ? WHERE id = ?');
		$stmt2->bindValue(1, "z");

		$stmt2->bindValue(2, $row1['id']);
		$stmt2->execute();
		$stmt2->closeCursor();

		$db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
		// check if changing the fetch mode from unbuffered to buffered will
		// cause any harm to a statement created prior to the change
		$stmt1->execute();
		$row2 = $stmt1->fetch(PDO::FETCH_ASSOC);
		$stmt1->closeCursor();
		if (!isset($row2['label']) || ('z' !== $row2['label']))
			printf("Expecting array(id => 1, label => z) got %s\n", var_export($row2, true));
		unset($stmt1);

		$stmt1 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		// should work
		$stmt2 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		$stmt1->closeCursor();

		$stmt1 = $db->query('SELECT id, label FROM test ORDER BY id ASC');
		// fetch only the first rows and let closeCursor() clean up
		$row3 = $stmt1->fetch(PDO::FETCH_ASSOC);
		$stmt1->closeCursor();
		assert($row3 == $row2);

		$stmt2 = $db->prepare('UPDATE test SET label = ? WHERE id = ?');
		$stmt2->bindValue(1, "a");
		$stmt2->bindValue(2, $row1['id']);
		$stmt2->execute();
		$stmt2->closeCursor();

		$stmt1->execute();
		$row4 = $stmt1->fetch(PDO::FETCH_ASSOC);
		$stmt1->closeCursor();
		assert($row4 == $row1);

		$offset = 0;
		$stmt = $db->prepare('SELECT id, label FROM test WHERE id > ? ORDER BY id ASC LIMIT 2');
		$in = 0;
		if (!$stmt->bindParam(1, $in))
			printf("[%03d + 1] Cannot bind parameter, %s %s\n", $offset,
				$stmt->errorCode(), var_export($stmt->errorInfo(), true));

		$stmt->execute();
		$id = $label = null;

		if (!$stmt->bindColumn(1, $id, PDO::PARAM_INT))
			printf("[%03d + 2] Cannot bind integer column, %s %s\n", $offset,
				$stmt->errorCode(), var_export($stmt->errorInfo(), true));

		if (!$stmt->bindColumn(2, $label, PDO::PARAM_STR))
			printf("[%03d + 3] Cannot bind string column, %s %s\n", $offset,
				$stmt->errorCode(), var_export($stmt->errorInfo(), true));

		while ($stmt->fetch(PDO::FETCH_BOUND))
			printf("in = %d -> id = %s (%s) / label = %s (%s)\n",
				$in,
				var_export($id, true), gettype($id),
				var_export($label, true), gettype($label));

		$stmt->closeCursor();
		$stmt->execute();

	}


	try {

		printf("Testing emulated PS...\n");
		$db->setAttribute(PDO::MYSQL_ATTR_DIRECT_QUERY, 1);
		if (1 != $db->getAttribute(PDO::MYSQL_ATTR_DIRECT_QUERY))
			printf("[002] Unable to turn on emulated prepared statements\n");

		printf("Buffered...\n");
		$db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
		MySQLPDOTest::createTestTable($db);
		pdo_mysql_stmt_closecursor($db);

		printf("Unbuffered...\n");
		$db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
		MySQLPDOTest::createTestTable($db);
		pdo_mysql_stmt_closecursor($db);

		printf("Testing native PS...\n");
		$db->setAttribute(PDO::MYSQL_ATTR_DIRECT_QUERY, 0);
		if (0 != $db->getAttribute(PDO::MYSQL_ATTR_DIRECT_QUERY))
			printf("[002] Unable to turn off emulated prepared statements\n");

		printf("Buffered...\n");
		MySQLPDOTest::createTestTable($db);
		$db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
		pdo_mysql_stmt_closecursor($db);

		printf("Unbuffered...\n");
		MySQLPDOTest::createTestTable($db);
		$db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
		pdo_mysql_stmt_closecursor($db);

	} catch (PDOException $e) {
		printf("[001] %s [%s] %s\n",
			$e->getMessage(), $db->errorCode(), implode(' ', $db->errorInfo()));
	}

	print "done!";
?>
--CLEAN--
<?php
require dirname(__FILE__) . '/mysql_pdo_test.inc';
$db = MySQLPDOTest::factory();
$db->exec('DROP TABLE IF EXISTS test');
?>
--EXPECTF--
Testing emulated PS...
Buffered...

Warning: PDO::query(): SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other unbuffered queries are active.  Consider using PDOStatement::fetchAll().  Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute. in %s on line %d
in = 0 -> id = 1 (integer) / label = 'a' (string)
in = 0 -> id = 2 (integer) / label = 'b' (string)
Unbuffered...

Warning: PDO::query(): SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other unbuffered queries are active.  Consider using PDOStatement::fetchAll().  Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute. in %s on line %d
in = 0 -> id = 1 (integer) / label = 'a' (string)
in = 0 -> id = 2 (integer) / label = 'b' (string)
Testing native PS...
Buffered...

Warning: PDO::query(): SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other unbuffered queries are active.  Consider using PDOStatement::fetchAll().  Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute. in %s on line %d
in = 0 -> id = 1 (integer) / label = 'a' (string)
in = 0 -> id = 2 (integer) / label = 'b' (string)
Unbuffered...

Warning: PDO::query(): SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other unbuffered queries are active.  Consider using PDOStatement::fetchAll().  Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute. in %s on line %d
in = 0 -> id = 1 (integer) / label = 'a' (string)
in = 0 -> id = 2 (integer) / label = 'b' (string)
done!