PHP使用PDO连接MySQL数据库的函数

PHP 代码：【复制】 
function database_connection($host, $database, $User, $password, $port=3306) {
    // 初始化返回数据
    $json = ['code' => 500, 'msg' => ''];
    try {
        // 补充端口参数（关键！原代码未使用port）
        $dsn = "mysql:host=$host;port=$port;dbname=$database;charset=utf8mb4";
        $options = [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 可选，默认关联数组
            PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8mb4" // 确保字符集
        ];
        $pdo = new PDO($dsn, $User, $password, $options);
        return $pdo;
    } catch (PDOException $e) {
        $json['msg'] = '数据库连接失败：' . $e->getMessage();
        // 开发环境可打印错误码，生产环境建议日志记录
        // $json['error_code'] = $e->getCode();
        die(json_encode($json, JSON_UNESCAPED_UNICODE));
    }
}