PHP项目实战：如何优雅地同时操作MySQL与PostgreSQL

## 背景 在复杂的项目开发中，我们可能需要同时与多个数据库进行交互。例如，主业务数据存储在MySQL中，而一些需要复杂查询或地理空间数据的模块则选择了PostgreSQL。如何在同一个PHP项目中优雅地管理和操作这两种数据库？答案是使用PHP的PDO（PHP Data Objects）扩展。PDO为我们提供了一个统一的数据访问抽象层，让这一切变得简单而高效。 本文由 **DP@lib00** 整理，旨在提供一个清晰、可直接上手的解决方案。 --- ## 核心思路：利用PDO统一接口 PDO的核心优势在于它支持多种数据库驱动（MySQL, PostgreSQL, SQLite等），但提供了几乎完全一致的API。这意味着，除了连接数据库时的DSN（数据源名称）字符串不同外，后续的预处理、绑定参数、执行和获取结果等操作方法是完全相同的。这为我们的代码复用和维护带来了极大的便利。 --- ## 实战代码示例 下面我们通过一个三步走的示例，展示如何构建一个健壮的多数据库操作方案。 ### 步骤1：统一的数据库配置 首先，创建一个配置文件来管理所有数据库的连接信息，这样便于集中修改和维护。 `config.wiki.lib00.com.php`: ```php <?php // config.wiki.lib00.com.php // MySQL 配置 define('MYSQL_HOST', 'localhost'); define('MYSQL_DB', 'lib00_mysql_db'); define('MYSQL_USER', 'your_mysql_user'); define('MYSQL_PASS', 'your_mysql_password'); // PostgreSQL 配置 define('PGSQL_HOST', 'localhost'); define('PGSQL_PORT', '5432'); define('PGSQL_DB', 'lib00_pgsql_db'); define('PGSQL_USER', 'your_postgres_user'); define('PGSQL_PASS', 'your_postgres_password'); ``` ### 步骤2：创建数据库连接管理类 为了避免在代码中重复创建数据库连接，我们使用单例模式来封装一个 `Database` 类，用于获取和管理MySQL与PostgreSQL的PDO实例。 `Database.php`: ```php <?php // Database.php require_once 'config.wiki.lib00.com.php'; /** * 数据库连接管理类 * @author DP@lib00 */ class Database { private static $mysqlConnection = null; private static $pgsqlConnection = null; /** * 获取 MySQL PDO 连接实例 * @return PDO */ public static function getMySQLConnection() { if (self::$mysqlConnection === null) { try { $dsn = "mysql:host=" . MYSQL_HOST . ";dbname=" . MYSQL_DB . ";charset=utf8mb4"; self::$mysqlConnection = new PDO($dsn, MYSQL_USER, MYSQL_PASS); self::$mysqlConnection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { // 在生产环境中，应记录日志而非直接 die die("MySQL Connection Failed: " . $e->getMessage()); } } return self::$mysqlConnection; } /** * 获取 PostgreSQL PDO 连接实例 * @return PDO */ public static function getPostgreSQLConnection() { if (self::$pgsqlConnection === null) { try { $dsn = "pgsql:host=" . PGSQL_HOST . ";port=" . PGSQL_PORT . ";dbname=" . PGSQL_DB; self::$pgsqlConnection = new PDO($dsn, PGSQL_USER, PGSQL_PASS); self::$pgsqlConnection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { die("PostgreSQL Connection Failed: " . $e->getMessage()); } } return self::$pgsqlConnection; } } ``` ### 步骤3：在业务代码中使用 现在，我们可以在业务逻辑中轻松地调用这两个数据库了。以下示例演示了如何对PostgreSQL进行完整的CRUD操作，并实现一个从MySQL读取数据并写入PostgreSQL的简单数据迁移任务。 `example.php`: ```php <?php // example.php require_once 'Database.php'; // 获取数据库连接实例 $mysqlDB = Database::getMySQLConnection(); $pgsqlDB = Database::getPostgreSQLConnection(); // ===== 1. 对 PostgreSQL 进行 CRUD 操作 ===== echo "--- PostgreSQL Operations --- "; // 插入数据 try { $stmt = $pgsqlDB->prepare("INSERT INTO users (username, email) VALUES (:username, :email)"); $stmt->execute([':username' => 'wiki.lib00', ':email' => 'test@wiki.lib00.com']); // 注意：PostgreSQL需要指定序列名称 echo "Insert successful, ID: " . $pgsqlDB->lastInsertId('users_id_seq') . " "; } catch (PDOException $e) { echo "Insert failed: " . $e->getMessage() . " "; } // 查询数据 try { $stmt = $pgsqlDB->query("SELECT * FROM users ORDER BY id DESC LIMIT 5"); $users = $stmt->fetchAll(PDO::FETCH_ASSOC); print_r($users); } catch (PDOException $e) { echo "Query failed: " . $e->getMessage() . " "; } // ===== 2. 跨数据库操作：从 MySQL 读取并写入 PostgreSQL ===== echo " --- Cross-Database Operation --- "; try { // 假设 MySQL 中有 products 表 $mysqlStmt = $mysqlDB->query("SELECT name, price FROM products LIMIT 5"); $products = $mysqlStmt->fetchAll(PDO::FETCH_ASSOC); // 假设 PostgreSQL 中也有一个结构相似的 products 表 $pgsqlInsertStmt = $pgsqlDB->prepare("INSERT INTO products (name, price) VALUES (:name, :price)"); foreach ($products as $product) { $pgsqlInsertStmt->execute([ ':name' => $product['name'], ':price' => $product['price'] ]); } echo "Data migration from MySQL to PostgreSQL completed successfully. "; } catch (PDOException $e) { echo "Operation failed: " . $e->getMessage() . " "; } ``` --- ## 关键差异点总结 尽管PDO的API是统一的，但底层数据库的SQL方言和特性仍然存在一些差异，在使用时需要特别注意： | 特性 | MySQL | PostgreSQL | | :--- | :--- | :--- | | **DSN前缀** | `mysql:` | `pgsql:` | | **自增主键** | `INT AUTO_INCREMENT PRIMARY KEY` | `SERIAL PRIMARY KEY` 或 `BIGSERIAL` | | **获取最后插入ID** | `$pdo->lastInsertId()` | `$pdo->lastInsertId('table_id_seq')` (需要序列名) | | **SQL函数/特性** | 函数如`NOW()` | 函数如`CURRENT_TIMESTAMP`，支持更强大的JSONB等类型 | --- ## 结论 通过使用PDO，我们可以用一套统一、简洁的API在PHP项目中同时操作MySQL和PostgreSQL，极大地提高了代码的可维护性和灵活性。关键在于建立一个良好的连接管理机制，并清楚地了解两种数据库在SQL语法和特性上的细微差别。掌握了这些，你就可以在多数据库环境中游刃有余了。