工厂模式下实例化 ProductRepository（含健壮的参数校验与异常处理）
下面的示例展示如何在工厂模式下实例化 Domain\Repository\ProductRepository。代码遵循 PSR-12、严格类型、合理的异常封装与参数校验，避免硬编码敏感凭证，推荐从环境变量加载配置。
完整PHP代码
<?php
declare(strict_types=1);
namespace Domain\Repository\Exception;
use RuntimeException;
/**
* 封装仓储创建相关的异常，避免向上层泄露底层驱动细节和敏感信息
*/
final class RepositoryCreationException extends RuntimeException
{
}
namespace Domain\Repository;
use Domain\Repository\Exception\RepositoryCreationException;
use PDO;
use PDOException;
/**
* 产品仓储（示例）
* - 使用 PDO 连接数据库
* - 内置参数校验、DSN 构建与异常封装
*/
final class ProductRepository
{
private PDO $pdo;
/**
* @param string $driver 例如：mysql、pgsql、sqlite（默认 mysql）
* @param array<string, mixed> $config 连接配置：
* - mysql/pgsql: host, dbname, user, password[, port, charset]
* - sqlite: path
*
* 注意：不得在代码中硬编码敏感凭证（如 password）。请优先从环境变量或安全配置源加载。
*
* @throws RepositoryCreationException
*/
public function __construct(string $driver = 'mysql', array $config = [])
{
$this->pdo = $this->connect($driver, $config);
}
/**
* 示例：按主键查询产品
*
* @return array<string, mixed>|null
*/
public function findById(int $id): ?array
{
$stmt = $this->pdo->prepare('SELECT id, name, price FROM products WHERE id = :id');
$stmt->bindValue(':id', $id, PDO::PARAM_INT);
$stmt->execute();
$row = $stmt->fetch();
return $row !== false ? $row : null;
}
/**
* 建立 PDO 连接并返回实例
*
* @throws RepositoryCreationException
*/
private function connect(string $driver, array $config): PDO
{
$driver = strtolower($driver);
$allowedDrivers = ['mysql', 'pgsql', 'sqlite'];
if (!in_array($driver, $allowedDrivers, true)) {
throw new RepositoryCreationException(
"Unsupported driver '{$driver}'. Allowed: " . implode(', ', $allowedDrivers)
);
}
$config = $this->normalizeConfig($driver, $config);
[$dsn, $user, $password] = $this->buildDsn($driver, $config);
$options = [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES => false,
];
try {
// 对于 sqlite，$user/$password 可为 null
return new PDO($dsn, $user, $password, $options);
} catch (PDOException $e) {
// 打包安全的配置，避免泄露密码
$safeConfig = $config;
if (isset($safeConfig['password'])) {
$safeConfig['password'] = '***redacted***';
}
$message = 'Failed to create PDO connection: ' . $e->getMessage()
. ' | config=' . json_encode($safeConfig, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
throw new RepositoryCreationException($message, (int) $e->getCode(), $e);
}
}
/**
* 规范化与校验配置，优先从环境变量读取缺失项
*
* @param array<string, mixed> $config
* @return array<string, mixed>
*
* @throws RepositoryCreationException
*/
private function normalizeConfig(string $driver, array $config): array
{
if ($driver === 'sqlite') {
$config['path'] = $config['path'] ?? ($_ENV['DB_PATH'] ?? getenv('DB_PATH') ?: '');
if ($config['path'] === '') {
throw new RepositoryCreationException('SQLite requires a non-empty "path" in config or DB_PATH env.');
}
return $config;
}
// 非 sqlite：从环境变量补全
$config['host'] = $config['host'] ?? ($_ENV['DB_HOST'] ?? getenv('DB_HOST') ?? '127.0.0.1');
$config['dbname'] = $config['dbname'] ?? ($_ENV['DB_NAME'] ?? getenv('DB_NAME') ?? null);
$config['user'] = $config['user'] ?? ($_ENV['DB_USER'] ?? getenv('DB_USER') ?? null);
$config['password'] = $config['password'] ?? ($_ENV['DB_PASSWORD'] ?? getenv('DB_PASSWORD') ?? '');
// 必填校验（避免空值导致隐式连接到错误库）
foreach (['host', 'dbname', 'user'] as $key) {
if (empty($config[$key]) || !is_string($config[$key])) {
throw new RepositoryCreationException("Invalid or missing '{$key}' in config.");
}
}
if (!is_string($config['password'])) {
throw new RepositoryCreationException('Invalid "password" type in config.');
}
// 基础字符校验，防止将恶意字符注入 DSN（密码不做字符限制）
$safePattern = '/^[A-Za-z0-9_\-\.]+$/';
if (!preg_match($safePattern, $config['host'])) {
throw new RepositoryCreationException('Host contains invalid characters.');
}
if (!preg_match($safePattern, $config['dbname'])) {
throw new RepositoryCreationException('Database name contains invalid characters.');
}
if (!preg_match('/^[\w\-.]+$/', $config['user'])) {
throw new RepositoryCreationException('User contains invalid characters.');
}
// 可选项：port, charset
$config['port'] = isset($config['port']) && is_int($config['port']) ? $config['port'] : null;
$config['charset'] = $config['charset'] ?? 'utf8mb4';
return $config;
}
/**
* 构建 DSN 及认证信息
*
* @param array<string, mixed> $config
* @return array{0:string,1:?string,2:?string} [dsn, user, password]
*/
private function buildDsn(string $driver, array $config): array
{
if ($driver === 'mysql') {
$dsn = sprintf(
'mysql:host=%s;%sdbname=%s;charset=%s',
$config['host'],
isset($config['port']) ? 'port=' . (int) $config['port'] . ';' : '',
$config['dbname'],
$config['charset']
);
return [$dsn, $config['user'], $config['password']];
}
if ($driver === 'pgsql') {
$dsn = sprintf(
'pgsql:host=%s;%sdbname=%s',
$config['host'],
isset($config['port']) ? 'port=' . (int) $config['port'] . ';' : '',
$config['dbname']
);
return [$dsn, $config['user'], $config['password']];
}
// sqlite
$dsn = 'sqlite:' . $config['path'];
return [$dsn, null, null];
}
}
namespace Domain\Factory;
use Domain\Repository\ProductRepository;
/**
* 仓储工厂：集中管理仓储实例的创建逻辑
*/
final class RepositoryFactory
{
/**
* @param string $driver
* @param array<string, mixed> $config
*/
public static function createProductRepository(string $driver = 'mysql', array $config = []): ProductRepository
{
// 如需扩展：可在此添加缓存、日志、代理包装等
return new ProductRepository($driver, $config);
}
}
// ========================= 使用示例（Client Code） =========================
// 说明：以下为用法示例，建议放在应用启动处（例如 bootstrap 或容器配置）。
// 实际项目中请使用 Composer PSR-4 自动加载，并通过 dotenv 或安全配置中心加载环境变量。
namespace App;
use Domain\Factory\RepositoryFactory;
use Domain\Repository\Exception\RepositoryCreationException;
$config = [
// 不要硬编码敏感信息；这里仅示例从环境加载，缺失项将由构造器进行校验并抛出异常
'host' => $_ENV['DB_HOST'] ?? getenv('DB_HOST') ?? '127.0.0.1',
'dbname' => $_ENV['DB_NAME'] ?? getenv('DB_NAME') ?? '',
'user' => $_ENV['DB_USER'] ?? getenv('DB_USER') ?? '',
'password' => $_ENV['DB_PASSWORD'] ?? getenv('DB_PASSWORD') ?? '',
// 'port' => 3306,
// 'charset'=> 'utf8mb4',
];
try {
$productRepository = RepositoryFactory::createProductRepository('mysql', $config);
// $product = $productRepository->findById(1);
} catch (RepositoryCreationException $e) {
// 记录日志并按需处理；避免向前端暴露内部错误细节
error_log($e->getMessage());
// 可在此回退或中止启动
}
代码逻辑分步解析
-
命名空间与自动加载
- ProductRepository 位于 Domain\Repository 命名空间，工厂 RepositoryFactory 位于 Domain\Factory。
- 异常 RepositoryCreationException 统一封装在 Domain\Repository\Exception。
- 符合 PSR-4，可通过 Composer 配置自动加载。
-
工厂模式实例化
- 使用 RepositoryFactory::createProductRepository($driver, $config) 生成 ProductRepository 实例。
- 工厂集中管理实例创建，便于后续添加代理、缓存、拦截器或容器集成。
-
构造函数与依赖处理
- ProductRepository 构造函数接收 driver 与 config，内部统一完成：
- 配置规范化与校验（必填项、字符合法性、环境变量补全）。
- 构建 DSN（支持 mysql、pgsql、sqlite）。
- 创建 PDO 对象，设置安全属性（异常模式、关联数组、禁用模拟预处理）。
-
安全与异常处理
- RepositoryCreationException 保证异常向上抛出时不泄露密码。
- DSN 构建前对 host、dbname、user 做基本字符校验，降低注入风 险。
- 使用 PDO::ATTR_EMULATE_PREPARES = false，启用原生预处理，减少 SQL 注入风险。
-
示例方法
- findById 使用预处理语句，类型安全绑定参数，示范仓储查询的基本写法。
使用注意事项与最佳实践
-
配置来源
- 切勿硬编码敏感凭证（如密码）；通过环境变量、密钥管理服务（如 Vault）、CI/CD 注入或配置中心获取。
- 推荐使用 vlucas/phpdotenv 在开发环境管理 .env 文件（生产环境仍使用安全配置源）。
-
PDO 驱动
- 请确保启用了相应的 PDO 驱动扩展（pdo_mysql/pdo_pgsql/pdo_sqlite）。
- 远程连接生产数据库时建议启用 TLS，并配置相应的 PDO SSL 选项（如 MySQL 的 PDO::MYSQL_ATTR_SSL_CA 等）。
-
连接配置
- MySQL 建议 charset 使用 utf8mb4。
- 若有端口，显式传入 port（int）。
- SQLite 必须提供 path。
-
错误处理
- 捕获 RepositoryCreationException 并记录日志，不要向前端泄露内部错误和配置细节。
- 对于频繁的实例化，建议将实例交由依赖注入容器管理，避免重复建立连接。
-
代码质量
- 保持 PSR-12 规范与严格类型 declare(strict_types=1)。
- 将不同类放置到独立文件中，便于维护与自动加载。
常见问题解决方案
以上方案严格遵守安全与可维护性要求，并采用工厂模式实现 ProductRepository 的标准化实例化流程。
