<?php class UnitOfWork { private $pdo; private $repositories = []; public function __construct(PDO $pdo) { $this->pdo = $pdo; } public function registerRepository(RepositoryInterface $repository) { $this->repositories[$repository->getEntityName()] = $repository; } public function beginTransaction() { $this->pdo->beginTransaction(); } public function commit() { $this->pdo->commit(); } public function rollback() { $this->pdo->rollBack(); } public function persist($entity) { $repositoryName = get_class($entity); if (!isset($this->repositories[$repositoryName])) { throw new Exception("Repository for entity '$repositoryName' not registered."); } $this->repositories[$repositoryName]->persist($entity); } public function flush() { foreach ($this->repositories as $repository) { $repository->flush(); } } public function __destruct() { if ($this->pdo->inTransaction()) { $this->rollback(); //Rollback on error or destruction } } } interface RepositoryInterface { public function getEntityName(): string; public function persist($entity); public function flush(); } //Example Repository class UserRepository implements RepositoryInterface{ private $pdo; public function __construct(PDO $pdo){ $this->pdo = $pdo; } public function getEntityName(): string{ return "User"; } public function persist($user){ //Insert or update user data into the database using PDO $stmt = $this->pdo->prepare("INSERT INTO users (name, email) VALUES (?, ?)"); $stmt->execute([$user->name, $user->email]); } public function flush(){ //Usually handled implicitly within persist() in this simplified example } } // Example Usage $pdo = new PDO('mysql:host=localhost;dbname=mydatabase', 'username', 'password'); $unitOfWork = new UnitOfWork($pdo); $userRepository = new UserRepository($pdo); $unitOfWork->registerRepository($userRepository); $unitOfWork->beginTransaction(); try{ $user = new User; // Assume User class exists $user->name = 'John Doe'; $user->email = 'john.doe@example.com'; $unitOfWork->persist($user); $unitOfWork->flush(); $unitOfWork->commit(); echo "Transaction successful!"; } catch (Exception $e){ $unitOfWork->rollback(); echo "Transaction failed: " . $e->getMessage(); } ?>
try...catch
>塊中包裝所有數據庫操作。 如果發生異常,則應調用單位工程單位的catch
rollback()
方法。 catch (Exception $e)
,而不是通用PDOException
,請考慮捕獲特定的異常(例如,try...catch
實施工作單位的有效實施需要仔細考慮以避免幾個常見的陷阱:
try...catch
以上是如何在PHP中實施交易管理的工作模式單位?的詳細內容。更多資訊請關注PHP中文網其他相關文章!