Connection: the driver is created in the constructor

src/Database/Connection.php

@@ -28,7 +28,7 @@ class Connection
 	public array $onQuery = [];
 	private Drivers\Driver $driver;
 	private Drivers\Engine $engine;
-	private SqlPreprocessor $preprocessor;
+	private ?SqlPreprocessor $preprocessor;
 	private ?PDO $pdo = null;
 
 	/** @var callable(array, ResultSet): array */
@@ -39,7 +39,6 @@ class Connection
 
 	public function __construct(
 		private readonly string $dsn,
-		#[\SensitiveParameter]
 		private readonly ?string $user = null,
 		#[\SensitiveParameter]
 		private readonly ?string $password = null,
@@ -48,7 +47,11 @@ public function __construct(
 		if (($options['newDateTime'] ?? null) === false) {
 			$this->rowNormalizer = fn($row, $resultSet) => Helpers::normalizeRow($row, $resultSet, DateTime::class);
 		}
-		if (empty($options['lazy'])) {
+		$lazy = $options['lazy'] ?? false;
+		unset($options['newDateTime'], $options['lazy']);
+
+		$this->driver = (new Factory)->createDriverFromDsn($dsn, $user, $password, $options);
+		if (!$lazy) {
 			$this->connect();
 		}
 	}
@@ -61,15 +64,12 @@ public function connect(): void
 		}
 
 		try {
-			$this->pdo = new PDO($this->dsn, $this->user, $this->password, $this->options);
+			$this->pdo = $this->driver->connect();
 		} catch (PDOException $e) {
 			throw ConnectionException::from($e);
 		}
 
-		$this->driver = (new Factory)->createDriverFromDsn($this->dsn, $this->user, $this->password, $this->options);
-		$this->engine = $this->driver->createDatabaseEngine();
-		$this->preprocessor = new SqlPreprocessor($this);
-		$this->engine->initialize($this, $this->options);
+		$this->engine = $this->driver->createDatabaseEngine($this);
 		Arrays::invoke($this->onConnect, $this);
 	}
 
@@ -241,6 +241,7 @@ public function queryArgs(string $sql, array $params): ResultSet
 	public function preprocess(string $sql, ...$params): array
 	{
 		$this->connect();
+		$this->preprocessor ??= new SqlPreprocessor($this);
 		return $params
 			? $this->preprocessor->process(func_get_args())
 			: [$sql, []];

tests/Database/Connection.lazy.phpt

@@ -16,30 +16,28 @@ require __DIR__ . '/../bootstrap.php';
 
 test('non lazy', function () {
 	Assert::exception(
-		fn() => new Nette\Database\Connection('dsn', 'user', 'password'),
-		Nette\Database\DriverException::class,
-		'%a%valid data source %a%',
+		fn() => new Nette\Database\Connection('xxx', 'user', 'password'),
+		LogicException::class,
+		"Unknown PDO driver 'xxx'.",
 	);
 });
 
 
-test('lazy', function () {
-	$connection = new Nette\Database\Connection('dsn', 'user', 'password', ['lazy' => true]);
+test('lazy & explorer', function () {
+	$connection = new Nette\Database\Connection('mysql:', 'user', 'password', ['lazy' => true]);
 	$explorer = new Nette\Database\Explorer($connection, new Structure($connection, new DevNullStorage));
 	Assert::exception(
 		fn() => $explorer->query('SELECT ?', 10),
 		Nette\Database\DriverException::class,
-		'%a%valid data source %a%',
 	);
 });
 
 
-test('', function () {
-	$connection = new Nette\Database\Connection('dsn', 'user', 'password', ['lazy' => true]);
+test('lazy', function () {
+	$connection = new Nette\Database\Connection('mysql:', 'user', 'password', ['lazy' => true]);
 	Assert::exception(
 		fn() => $connection->quote('x'),
 		Nette\Database\DriverException::class,
-		'%a%valid data source %a%',
 	);
 });