如何配置PHP容器支持多种数据库 PHP环境兼容MySQL与PostgreSQL

# Dockerfile 示例：构建一个支持 MySQL 和 PostgreSQL 的 PHP FPM 容器
FROM php:8.2-fpm-alpine

# 安装必要的系统依赖和客户端库
# 对于 Alpine Linux (apk)，我们需要 postgresql-client 和 mysql-client 以及它们的开发包
# libpq-dev 和 mysql-dev 是编译 PHP 扩展所必需的头文件和库
RUN apk add --no-cache \
    postgresql-client \
    mysql-client \
    libpq \
    libpq-dev \
    mysql-dev \
    # 额外添加一些常用工具，方便调试，非必需
    bash \
    curl \
    git \
    vim \
    # 清理缓存，减小镜像大小
    && rm -rf /var/cache/apk/*

# 安装 PHP 的 PDO MySQL 和 PDO PostgreSQL 扩展
# docker-php-ext-install 是 PHP 官方镜像提供的一个便利命令
RUN docker-php-ext-install pdo_mysql pdo_pgsql

# 设置工作目录
WORKDIR /var/www/html

# 将你的应用代码复制到容器中
# COPY . /var/www/html

# 如果你的应用需要 Composer 依赖，可以在这里安装
# COPY composer.json composer.lock ./
# RUN composer install --no-dev --optimize-autoloader --no-interaction

# 暴露 FPM 端口
EXPOSE 9000

# 启动 PHP-FPM 服务
CMD ["php-fpm"]

docker build -t my-php-app:latest .

version: '3.8'
services:
  php-app:
    build: . # 使用当前目录的 Dockerfile 构建
    # image: my-php-app:latest # 如果你已经构建好镜像，可以直接指定
    volumes:
      - ./src:/var/www/html # 将本地代码挂载到容器中
    ports:
      - "9000:9000" # 如果需要直接访问 FPM，通常通过 Nginx/Apache 反向代理
    environment:
      # 这里可以定义数据库连接的环境变量
      MYSQL_HOST: mysql_db
      MYSQL_DATABASE: your_mysql_db
      MYSQL_USER: your_mysql_user
      MYSQL_PASSWORD: your_mysql_password
      PGSQL_HOST: pgsql_db
      PGSQL_DATABASE: your_pgsql_db
      PGSQL_USER: your_pgsql_user
      PGSQL_PASSWORD: your_pgsql_password
    depends_on:
      - mysql_db
      - pgsql_db

  mysql_db:
    image: mysql:8.0
    environment:
      MYSQL_ROOT_PASSWORD: root_password
      MYSQL_DATABASE: your_mysql_db
      MYSQL_USER: your_mysql_user
      MYSQL_PASSWORD: your_mysql_password
    ports:
      - "3306:3306" # 仅为开发方便，生产环境不建议直接暴露

  pgsql_db:
    image: postgres:14
    environment:
      POSTGRES_DB: your_pgsql_db
      POSTGRES_USER: your_pgsql_user
      POSTGRES_PASSWORD: your_pgsql_password
    ports:
      - "5432:5432" # 仅为开发方便，生产环境不建议直接暴露

<?php

// 最佳实践：通过环境变量获取数据库配置
// 例如，在 docker-compose.yml 中设置 MYSQL_HOST, PGSQL_HOST 等
$dbConfig = [
    'mysql' => [
        'host' => getenv('MYSQL_HOST') ?: 'mysql_db', // 默认使用 docker-compose 服务名
        'port' => getenv('MYSQL_PORT') ?: '3306',
        'database' => getenv('MYSQL_DATABASE') ?: 'your_mysql_db',
        'user' => getenv('MYSQL_USER') ?: 'your_mysql_user',
        'password' => getenv('MYSQL_PASSWORD') ?: 'your_mysql_password',
        'charset' => 'utf8mb4'
    ],
    'pgsql' => [
        'host' => getenv('PGSQL_HOST') ?: 'pgsql_db', // 默认使用 docker-compose 服务名
        'port' => getenv('PGSQL_PORT') ?: '5432',
        'database' => getenv('PGSQL_DATABASE') ?: 'your_pgsql_db',
        'user' => getenv('PGSQL_USER') ?: 'your_pgsql_user',
        'password' => getenv('PGSQL_PASSWORD') ?: 'your_pgsql_password',
    ]
];

/**
 * 获取一个数据库连接实例
 * @param string $type 'mysql' 或 'pgsql'
 * @return PDO
 * @throws Exception 如果不支持的数据库类型或连接失败
 */
function getDbConnection(string $type = 'mysql'): PDO
{
    global $dbConfig; // 访问全局配置
    $config = $dbConfig[$type];

    try {
        if ($type === 'mysql') {
            $dsn = "mysql:host={$config['host']};port={$config['port']};dbname={$config['database']};charset={$config['charset']}";
            $pdo = new PDO($dsn, $config['user'], $config['password']);
        } elseif ($type === 'pgsql') {
            // PostgreSQL 的 DSN 格式略有不同，可以直接在 DSN 中包含用户和密码
            $dsn = "pgsql:host={$config['host']};port={$config['port']};dbname={$config['database']};user={$config['user']};password={$config['password']}";
            $pdo = new PDO($dsn);
        } else {
            throw new Exception("Unsupported database type: {$type}");
        }

        // 设置 PDO 属性：错误模式为异常，默认获取模式为关联数组
        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);

        return $pdo;

    } catch (PDOException $e) {
        // 在生产环境中，这里通常会记录日志而非直接输出错误，避免敏感信息泄露
        error_log("Database connection error ({$type}): " . $e->getMessage());
        // 可以抛出自定义异常或返回 null，让上层调用者处理
        throw new Exception("Could not connect to the {$type} database.", 0, $e);
    } catch (Exception $e) {
        error_log("Configuration or general error: " . $e->getMessage());
        throw $e; // 重新抛出其他异常
    }
}

// 示例用法：
try {
    $mysqlPdo = getDbConnection('mysql');
    echo "成功连接到 MySQL!\n";
    // 执行一些 MySQL 查询...
    // $stmt = $mysqlPdo->query("SELECT VERSION()");
    // $version = $stmt->fetchColumn();
    // echo "MySQL Version: " . $version . "\n";

    $pgsqlPdo = getDbConnection('pgsql');
    echo "成功连接到 PostgreSQL!\n";
    // 执行一些 PostgreSQL 查询...
    // $stmt = $pgsqlPdo->query("SELECT version()");
    // $version = $stmt->fetchColumn();
    // echo "PostgreSQL Version: " . $version . "\n";

} catch (Exception $e) {
    echo "连接数据库时发生错误: " . $e->getMessage() . "\n";
}