从Doctrine DBAL Connection获取原生PHP数据库句柄

<?php

use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Connection;

// 假设这些是您的数据库连接参数
$connectionParams = array(
    'dbname'   => 'your_database_name',
    'user'     => 'your_username',
    'password' => 'your_password',
    'host'     => 'localhost',
    'driver'   => 'mysqli', // 或 'pdo_mysql', 'pdo_pgsql' 等
);

try {
    // 1. 获取 Doctrine DBAL Connection 对象
    $conn = DriverManager::getConnection($connectionParams);

    // 2. 获取底层的 Driver Connection 对象
    $driverConnection = $conn->getWrappedConnection();

    // 3. 获取原生 PHP 数据库句柄
    // 如果驱动是 'mysqli'，这里将得到一个 mysqli 对象
    // 如果驱动是 'pdo_mysql'，这里将得到一个 PDO 对象
    $nativeHandle = $driverConnection->getWrappedResourceHandle();

    // 现在您可以使用 $nativeHandle 进行原生操作了
    if ($nativeHandle instanceof mysqli) {
        echo "成功获取到 mysqli 对象！\n";
        // 示例：使用 mysqli_ping 检查连接
        if ($nativeHandle->ping()) {
            echo "数据库连接活跃。\n";
        } else {
            echo "数据库连接已断开: " . $nativeHandle->error . "\n";
        }
        // 示例：执行原生查询 (通常不推荐，优先使用DBAL的query/executeStatement)
        // $result = $nativeHandle->query("SELECT VERSION()");
        // if ($result) {
        //     $row = $result->fetch_row();
        //     echo "MySQL 版本: " . $row[0] . "\n";
        //     $result->close();
        // }
    } elseif ($nativeHandle instanceof PDO) {
        echo "成功获取到 PDO 对象！\n";
        // 示例：使用 PDO::getAttribute 检查连接状态
        echo "PDO 驱动名称: " . $nativeHandle->getAttribute(PDO::ATTR_DRIVER_NAME) . "\n";
    } else {
        echo "获取到未知类型的原生句柄。\n";
    }

    // 务必关闭连接，尽管在脚本结束时通常会自动关闭
    // $conn->close(); // DBAL Connection 提供了 close 方法
} catch (\Exception $e) {
    echo "连接数据库失败: " . $e->getMessage() . "\n";
}

?>

foreach((array)$conn->getWrappedConnection() as $mysqli){
    // ...
    break;
}