Connection::getPdo() deprecated

Author: dg

src/Database/Connection.php

@@ -79,8 +79,10 @@ public function getDsn(): string
 	}
 
 
+	/** @deprecated use getConnectionDriver()->getNativeConnection() */
 	public function getPdo(): \PDO
 	{
+		trigger_error(__METHOD__ . '() is deprecated, use getConnectionDriver()->getNativeConnection()', E_USER_DEPRECATED);
 		return $this->getConnectionDriver()->getNativeConnection();
 	}
 

src/Database/Helpers.php

@@ -169,15 +169,15 @@ public static function loadFromFile(Connection $connection, string $file, ?calla
 		$count = $size = 0;
 		$delimiter = ';';
 		$sql = '';
-		$pdo = $connection->getPdo(); // native query without logging
+		$driver = $connection->getConnectionDriver(); // native query without logging
 		while (($s = fgets($handle)) !== false) {
 			$size += strlen($s);
 			if (!strncasecmp($s, 'DELIMITER ', 10)) {
 				$delimiter = trim(substr($s, 10));
 
 			} elseif (str_ends_with($ts = rtrim($s), $delimiter)) {
 				$sql .= substr($ts, 0, -strlen($delimiter));
-				$pdo->exec($sql);
+				$driver->query($sql);
 				$sql = '';
 				$count++;
 				if ($onProgress) {
@@ -189,7 +189,7 @@ public static function loadFromFile(Connection $connection, string $file, ?calla
 		}
 
 		if (rtrim($sql) !== '') {
-			$pdo->exec($sql);
+			$driver->query($sql);
 			$count++;
 			if ($onProgress) {
 				$onProgress($count, isset($stat['size']) ? 100 : null);

tests/Database/ResultSet.fetch().phpt

@@ -38,7 +38,7 @@ test('', function () use ($connection, $driverName) {
 test('tests closeCursor()', function () use ($connection, $driverName) {
 	if ($driverName === 'mysql') {
 		$connection->query('CREATE DEFINER = CURRENT_USER PROCEDURE `testProc`(IN param int(10) unsigned) BEGIN SELECT * FROM book WHERE id != param; END;;');
-		$connection->getPdo()->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
+		$connection->getConnectionDriver()->getNativeConnection()->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
 
 		$res = $connection->query('CALL testProc(1)');
 		foreach ($res as $row) {

tests/Database/ResultSet.normalizeRow.mysql.phpt

@@ -147,7 +147,7 @@ Assert::equal([
 ], (array) $res->fetch());
 
 
-$connection->getPdo()->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
+$connection->getConnectionDriver()->getNativeConnection()->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
 $res = $connection->query('SELECT `int`, `decimal`, `decimal2`, `float`, `double` FROM types');
 Assert::equal([
 	'int' => 1,

tests/bootstrap.php

@@ -43,7 +43,7 @@ function connectToDB(): Nette\Database\Explorer
 		Tester\Environment::skip("Connection to '$options[dsn]' failed. Reason: " . $e->getMessage());
 	}
 
-	$driverName = $connection->getPdo()->getAttribute(PDO::ATTR_DRIVER_NAME);
+	$driverName = $connection->getConnectionDriver()->getNativeConnection()->getAttribute(PDO::ATTR_DRIVER_NAME);
 	$cacheMemoryStorage = new Nette\Caching\Storages\MemoryStorage;
 
 	$structure = new Nette\Database\Structure($connection, $cacheMemoryStorage);