Skip to content

Commit

Permalink
Update for amphp/sql 2.0.0-beta.6
Browse files Browse the repository at this point in the history
  • Loading branch information
trowski committed Dec 9, 2023
1 parent 0689e04 commit 283e52e
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 6 deletions.
2 changes: 1 addition & 1 deletion composer.json
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
"require": {
"php": ">=8.1",
"amphp/amp": "^3",
"amphp/sql": "dev-refactor-transactions as 2.0"
"amphp/sql": "^2-beta.6"
},
"require-dev": {
"amphp/php-cs-fixer-config": "^2",
Expand Down
5 changes: 5 additions & 0 deletions src/ConnectionPool.php
Original file line number Diff line number Diff line change
Expand Up @@ -141,6 +141,11 @@ public function __destruct()
$this->close();
}

public function getTransactionIsolation(): TransactionIsolation
{
return $this->transactionIsolation;
}

public function setTransactionIsolation(TransactionIsolation $isolation): void
{
$this->transactionIsolation = $isolation;
Expand Down
2 changes: 1 addition & 1 deletion src/ConnectionTransaction.php
Original file line number Diff line number Diff line change
Expand Up @@ -176,7 +176,7 @@ public function isActive(): bool
return $this->active && !$this->executor->isClosed();
}

public function getIsolationLevel(): TransactionIsolation
public function getIsolation(): TransactionIsolation
{
return $this->isolation;
}
Expand Down
4 changes: 2 additions & 2 deletions src/NestedTransaction.php
Original file line number Diff line number Diff line change
Expand Up @@ -265,9 +265,9 @@ public function getSavepointIdentifier(): string
return $this->identifier;
}

public function getIsolationLevel(): TransactionIsolation
public function getIsolation(): TransactionIsolation
{
return $this->transaction->getIsolationLevel();
return $this->transaction->getIsolation();
}

public function getLastUsedAt(): int
Expand Down
4 changes: 2 additions & 2 deletions src/PooledTransaction.php
Original file line number Diff line number Diff line change
Expand Up @@ -172,9 +172,9 @@ public function getSavepointIdentifier(): ?string
return $this->transaction->getSavepointIdentifier();
}

public function getIsolationLevel(): TransactionIsolation
public function getIsolation(): TransactionIsolation
{
return $this->transaction->getIsolationLevel();
return $this->transaction->getIsolation();
}

public function getLastUsedAt(): int
Expand Down

0 comments on commit 283e52e

Please sign in to comment.