Skip to content

Commit 95525d1

Browse files
committed
Add support of doctrine/dbal 4.0
1 parent f444b07 commit 95525d1

File tree

5 files changed

+33
-48
lines changed

5 files changed

+33
-48
lines changed

composer.json

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,13 @@
22
"name": "code-tool/doctrine-dbal-jaeger",
33
"license": "MIT",
44
"require": {
5-
"php": "^7.4 || ^8",
6-
"doctrine/dbal": "^3.0",
5+
"php": "^8.1",
6+
"doctrine/dbal": "^4.2",
77
"code-tool/jaeger-client-php": "^3"
8-
},
8+
}
9+
,
910
"require-dev": {
10-
"phpunit/phpunit": "^7.2 || ^8"
11+
"roave/security-advisories": "dev-latest"
1112
},
1213
"config": {
1314
"sort-packages": true

src/Wrapper/JaegerConnectionWrapper.php

Lines changed: 11 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -14,16 +14,12 @@
1414

1515
class JaegerConnectionWrapper extends AbstractConnectionMiddleware
1616
{
17-
private TracerInterface $tracer;
18-
19-
private ?int $maxSqlLength;
20-
21-
public function __construct(Connection $wrappedConnection, TracerInterface $tracer, ?int $maxSqlLength = null)
22-
{
17+
public function __construct(
18+
Connection $wrappedConnection,
19+
private readonly TracerInterface $tracer,
20+
private readonly ?int $maxSqlLength = null
21+
) {
2322
parent::__construct($wrappedConnection);
24-
25-
$this->tracer = $tracer;
26-
$this->maxSqlLength = $maxSqlLength;
2723
}
2824

2925
public function prepare(string $sql): Statement
@@ -89,13 +85,13 @@ public function exec(string $sql): int
8985
}
9086
}
9187

92-
public function beginTransaction(): bool
88+
public function beginTransaction(): void
9389
{
9490
$span = $this->tracer
9591
->start('dbal.transaction');
9692

9793
try {
98-
return parent::beginTransaction();
94+
parent::beginTransaction();
9995
} catch (\Throwable $t) {
10096
$span
10197
->addTag(new DbalErrorCodeTag($t->getCode()))
@@ -107,13 +103,13 @@ public function beginTransaction(): bool
107103
}
108104
}
109105

110-
public function commit(): bool
106+
public function commit(): void
111107
{
112108
$span = $this->tracer
113109
->start('dbal.commit');
114110

115111
try {
116-
return parent::commit();
112+
parent::commit();
117113
} catch (\Throwable $t) {
118114
$span
119115
->addTag(new DbalErrorCodeTag($t->getCode()))
@@ -125,13 +121,13 @@ public function commit(): bool
125121
}
126122
}
127123

128-
public function rollBack(): bool
124+
public function rollBack(): void
129125
{
130126
$span = $this->tracer
131127
->start('dbal.rollback');
132128

133129
try {
134-
return parent::rollBack();
130+
parent::rollBack();
135131
} catch (\Throwable $t) {
136132
$span
137133
->addTag(new DbalErrorCodeTag($t->getCode()))

src/Wrapper/JaegerDriverWrapper.php

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -13,16 +13,12 @@
1313

1414
class JaegerDriverWrapper extends AbstractDriverMiddleware
1515
{
16-
private TracerInterface $tracer;
17-
18-
private ?int $maxSqlLength;
19-
20-
public function __construct(Driver $wrappedDriver, TracerInterface $tracer, ?int $maxSqlLength = null)
21-
{
16+
public function __construct(
17+
private readonly Driver $wrappedDriver,
18+
private readonly TracerInterface $tracer,
19+
private readonly ?int $maxSqlLength = null
20+
) {
2221
parent::__construct($wrappedDriver);
23-
24-
$this->tracer = $tracer;
25-
$this->maxSqlLength = $maxSqlLength;
2622
}
2723

2824
public function connect(array $params): DriverConnection
@@ -42,7 +38,7 @@ public function connect(array $params): DriverConnection
4238

4339
throw $t;
4440
} finally {
45-
$span->addTag(new DbType(\get_class($this->getDatabasePlatform())));
41+
$span->addTag(new DbType($this->wrappedDriver::class));
4642

4743
$this->tracer->finish($span);
4844
}

src/Wrapper/JaegerMiddleware.php

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,10 @@
99

1010
class JaegerMiddleware implements Middleware
1111
{
12-
private TracerInterface $tracer;
13-
14-
private ?int $maxSqlLength;
15-
16-
public function __construct(TracerInterface $tracer, ?int $maxSqlLength = null)
17-
{
18-
$this->tracer = $tracer;
19-
$this->maxSqlLength = $maxSqlLength;
12+
public function __construct(
13+
private readonly TracerInterface $tracer,
14+
private readonly ?int $maxSqlLength = null
15+
) {
2016
}
2117

2218
public function wrap(Driver $driver): Driver

src/Wrapper/JaegerStatementWrapper.php

Lines changed: 7 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -13,26 +13,22 @@
1313

1414
class JaegerStatementWrapper extends AbstractStatementMiddleware
1515
{
16-
private TracerInterface $tracer;
17-
18-
private string $sql;
19-
20-
public function __construct(Statement $wrappedStatement, TracerInterface $tracer, string $sql)
21-
{
16+
public function __construct(
17+
Statement $wrappedStatement,
18+
private readonly TracerInterface $tracer,
19+
private readonly string $sql
20+
) {
2221
parent::__construct($wrappedStatement);
23-
24-
$this->tracer = $tracer;
25-
$this->sql = $sql;
2622
}
2723

28-
public function execute($params = null): Result
24+
public function execute(): Result
2925
{
3026
$span = $this->tracer
3127
->start('dbal.stmt.execute')
3228
->addTag(new DbStatementTag($this->sql));
3329

3430
try {
35-
return parent::execute($params);
31+
return parent::execute();
3632
} catch (\Throwable $t) {
3733
$span
3834
->addTag(new DbalErrorCodeTag($t->getCode()))

0 commit comments

Comments
 (0)