17475241346

Committed 04 Sep 2025 07:59PM UTC coverage: 5.5%. Remained the same

Build # 17475241346

Build Type

push

github

Committed by

BenMorel

Commit Message

Apply coding standard

Run Details

11 of 200 relevant lines covered (5.5%)

3.8 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Database/Connection/PdoConnection.php

<?php

declare(strict_types=1);

namespace Brick\Lock\Database\Connection;

use Brick\Lock\Database\ConnectionInterface;
use Brick\Lock\Database\QueryException;
use Override;
use PDO;
use PDOException;

use function count;
use function sprintf;

/**
 * Wraps a PDO connection.
 */
final readonly class PdoConnection implements ConnectionInterface
{
    public function __construct(
        private PDO $pdo,
    ) {
    }

    #[Override]
    public function querySingleValue(string $sql, array $params = []): mixed
    {
        /** @phpstan-ignore missingType.checkedException */
        $previousErrorMode = $this->pdo->getAttribute(PDO::ATTR_ERRMODE);

        /** @phpstan-ignore missingType.checkedException */
        $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

        try {
            $statement = $this->pdo->prepare($sql);
            $statement->execute($params);

            /** @var list<list<scalar|null>> $rows */
            $rows = $statement->fetchAll(PDO::FETCH_NUM);
        } catch (PDOException $e) {
            throw new QueryException(sprintf('An error occurred while executing the query "%s"', $sql), $e);
        } finally {
            /** @phpstan-ignore missingType.checkedException */
            $this->pdo->setAttribute(PDO::ATTR_ERRMODE, $previousErrorMode);
        }

        if (count($rows) !== 1) {
            throw new QueryException(sprintf('Query "%s" returned %d rows, expected 1.', $sql, count($rows)));
        }

        $columns = $rows[0];

        if (count($columns) !== 1) {
            throw new QueryException(sprintf('Query "%s" returned %d columns, expected 1.', $sql, count($columns)));
        }

        /** @var scalar|null */
        return $columns[0];
    }

    #[Override]
    public function beginTransaction(): void
    {
        $this->pdo->beginTransaction();
    }

    #[Override]
    public function commit(): void
    {
        $this->pdo->commit();
    }

    #[Override]
    public function rollBack(): void
    {
        $this->pdo->rollBack();
    }
}

1	<?php
2
3	declare(strict_types=1);
4
5	namespace Brick\Lock\Database\Connection;
6
7	use Brick\Lock\Database\ConnectionInterface;
8	use Brick\Lock\Database\QueryException;
9	use Override;
10	use PDO;
11	use PDOException;
12
13	use function count;
14	use function sprintf;
15
16	/**
17	* Wraps a PDO connection.
18	*/
19	final readonly class PdoConnection implements ConnectionInterface
20	{
21	public function __construct(
22	private PDO $pdo,
23	) {
24	}	×
25
26	#[Override]
27	public function querySingleValue(string $sql, array $params = []): mixed
28	{
29	/** @phpstan-ignore missingType.checkedException */
30	$previousErrorMode = $this->pdo->getAttribute(PDO::ATTR_ERRMODE);	×
31
32	/** @phpstan-ignore missingType.checkedException */
33	$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);	×
34
35	try {
36	$statement = $this->pdo->prepare($sql);	×
37	$statement->execute($params);	×
38
39	/** @var list<list<scalar\|null>> $rows */
40	$rows = $statement->fetchAll(PDO::FETCH_NUM);	×
41	} catch (PDOException $e) {	×
42	throw new QueryException(sprintf('An error occurred while executing the query "%s"', $sql), $e);	×
43	} finally {
44	/** @phpstan-ignore missingType.checkedException */
45	$this->pdo->setAttribute(PDO::ATTR_ERRMODE, $previousErrorMode);	×
46	}
47
48	if (count($rows) !== 1) {	×
49	throw new QueryException(sprintf('Query "%s" returned %d rows, expected 1.', $sql, count($rows)));	×
50	}
51
52	$columns = $rows[0];	×
53
54	if (count($columns) !== 1) {	×
55	throw new QueryException(sprintf('Query "%s" returned %d columns, expected 1.', $sql, count($columns)));	×
56	}
57
58	/** @var scalar\|null */
59	return $columns[0];	×
60	}
61
62	#[Override]
63	public function beginTransaction(): void
64	{
65	$this->pdo->beginTransaction();	×
66	}
67
68	#[Override]
69	public function commit(): void
70	{
71	$this->pdo->commit();	×
72	}
73
74	#[Override]
75	public function rollBack(): void
76	{
77	$this->pdo->rollBack();	×
78	}
79	}

brick / lock / 17475241346

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous