在 PHP 的 Service 层中确保数据一致性的方法主要涉及到两方面:事务处理和错误处理。以下是一些建议:
示例(使用 PDO):
try {
// 连接数据库
$pdo = new PDO($dsn, $user, $password);
$pdo->beginTransaction();
// 执行数据库操作
$pdo->exec("INSERT INTO table1 (column1, column2) VALUES ('value1', 'value2')");
$pdo->exec("UPDATE table2 SET column1 = 'value3' WHERE column2 = 'value2'");
// 提交事务
$pdo->commit();
} catch (Exception $e) {
// 发生错误时回滚事务
if ($pdo->inTransaction()) {
$pdo->rollBack();
}
// 抛出异常
throw $e;
}
示例:
class UserService {
private $userRepository;
public function __construct(UserRepository $userRepository) {
$this->userRepository = $userRepository;
}
public function createUser(array $userData) {
try {
// 执行数据库操作
$this->userRepository->create($userData);
} catch (Exception $e) {
// 记录错误日志
// ...
// 根据错误类型采取相应的措施
// ...
// 抛出异常
throw $e;
}
}
}
通过合理地使用事务和错误处理,可以在 PHP 的 Service 层中确保数据一致性。