createMock(Connection::class); $driver = $this->createMock(Driver::class); $driver->method('connect') ->willReturn($connection); $this->logger = new TestLogger(); $middleware = new Middleware($this->logger); $this->driver = $middleware->wrap($driver); } public function testConnectAndDisconnect(): void { $this->driver->connect([ 'username' => 'admin', 'password' => 'Passw0rd!', 'url' => 'mysql://user:secret@localhost/mydb', ]); self::assertTrue($this->logger->hasInfo([ 'message' => 'Connecting with parameters {params}', 'context' => [ 'params' => [ 'username' => 'admin', 'password' => '', 'url' => '', ], ], ])); } public function testQuery(): void { $connection = $this->driver->connect([]); $connection->query('SELECT 1'); self::assertTrue($this->logger->hasDebug([ 'message' => 'Executing query: {sql}', 'context' => ['sql' => 'SELECT 1'], ])); } public function testExec(): void { $connection = $this->driver->connect([]); $connection->exec('DROP DATABASE doctrine'); self::assertTrue($this->logger->hasDebug([ 'message' => 'Executing statement: {sql}', 'context' => ['sql' => 'DROP DATABASE doctrine'], ])); } public function testBeginCommitRollback(): void { $connection = $this->driver->connect([]); $connection->beginTransaction(); $connection->commit(); $connection->rollBack(); self::assertTrue($this->logger->hasDebug('Beginning transaction')); self::assertTrue($this->logger->hasDebug('Committing transaction')); self::assertTrue($this->logger->hasDebug('Rolling back transaction')); } public function testExecuteStatementWithUntypedParameters(): void { $connection = $this->driver->connect([]); $statement = $connection->prepare('SELECT ?'); $statement->execute([42]); self::assertTrue($this->logger->hasDebug([ 'message' => 'Executing statement: {sql} (parameters: {params}, types: {types})', 'context' => [ 'sql' => 'SELECT ?', 'params' => [42], 'types' => [], ], ])); } public function testExecuteStatementWithTypedParameters(): void { $connection = $this->driver->connect([]); $statement = $connection->prepare('SELECT ?, ?'); $statement->bindValue(1, 42, ParameterType::INTEGER); $statement->bindParam(2, $byRef, ParameterType::STRING); $byRef = 'Test'; $statement->execute(); self::assertTrue($this->logger->hasDebug([ 'message' => 'Executing statement: {sql} (parameters: {params}, types: {types})', 'context' => [ 'sql' => 'SELECT ?, ?', 'params' => [1 => 42, 2 => 'Test'], 'types' => [1 => ParameterType::INTEGER, 2 => ParameterType::STRING], ], ])); } public function testExecuteStatementWithNamedParameters(): void { $connection = $this->driver->connect([]); $statement = $connection->prepare('SELECT :value'); $statement->bindValue('value', 'Test'); $statement->execute(); self::assertTrue($this->logger->hasDebug([ 'message' => 'Executing statement: {sql} (parameters: {params}, types: {types})', 'context' => [ 'sql' => 'SELECT :value', 'params' => ['value' => 'Test'], 'types' => ['value' => ParameterType::STRING], ], ])); } }