@@ -38,7 +38,7 @@ public function run(string $statement, iterable $parameters = [], ?string $alias
38
38
public function runStatement (Statement $ statement , ?string $ alias = null ): ?SummarizedResult
39
39
{
40
40
return $ this ->handler ->handle (
41
- fn (Statement $ statement ) => $ this ->client ->runStatement ($ statement , $ alias ),
41
+ fn (Statement $ statement ) => $ this ->client ->runStatement ($ statement , $ alias ),
42
42
$ statement ,
43
43
$ alias ,
44
44
null
@@ -62,7 +62,7 @@ public function beginTransaction(
62
62
): UnmanagedTransactionInterface {
63
63
$ tsx = new SymfonyTransaction ($ this ->client ->beginTransaction (null , $ alias , $ config ), $ this ->handler , $ alias );
64
64
65
- $ runHandler = fn (Statement $ statement ): CypherList => $ tsx ->runStatement ($ statement );
65
+ $ runHandler = fn (Statement $ statement ): CypherList => $ tsx ->runStatement ($ statement );
66
66
67
67
foreach (($ statements ?? []) as $ statement ) {
68
68
$ this ->handler ->handle ($ runHandler , $ statement , $ alias , null );
@@ -85,7 +85,7 @@ public function writeTransaction(
85
85
$ session = $ this ->client ->getDriver ($ alias )->createSession ($ sessionConfig );
86
86
87
87
return TransactionHelper::retry (
88
- fn () => new SymfonyTransaction ($ session ->beginTransaction ([], $ config ), $ this ->handler , $ alias ),
88
+ fn () => new SymfonyTransaction ($ session ->beginTransaction ([], $ config ), $ this ->handler , $ alias ),
89
89
$ tsxHandler
90
90
);
91
91
}
@@ -99,7 +99,7 @@ public function readTransaction(
99
99
$ session = $ this ->client ->getDriver ($ alias )->createSession ($ sessionConfig );
100
100
101
101
return TransactionHelper::retry (
102
- fn () => new SymfonyTransaction ($ session ->beginTransaction ([], $ config ), $ this ->handler , $ alias ),
102
+ fn () => new SymfonyTransaction ($ session ->beginTransaction ([], $ config ), $ this ->handler , $ alias ),
103
103
$ tsxHandler
104
104
);
105
105
}
0 commit comments