PHP连接MariaDB数据库 PHP操作兼容MySQL教程

<?php

$host = 'localhost'; // 数据库主机地址
$port = '3306'; // 数据库端口，MariaDB默认也是3306
$dbname = 'your_database_name'; // 数据库名
$user = 'your_username'; // 用户名
$pass = 'your_password'; // 密码

try {
    $dsn = "mysql:host=$host;port=$port;dbname=$dbname;charset=utf8mb4";
    $pdo = new PDO($dsn, $user, $pass);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 错误处理
    $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); // 设置默认fetch模式

    echo "连接成功！\n";

    // 示例查询
    $stmt = $pdo->query("SELECT * FROM your_table");
    $results = $stmt->fetchAll();

    foreach ($results as $row) {
        print_r($row);
    }

} catch (PDOException $e) {
    echo "连接失败: " . $e->getMessage() . "\n";
} finally {
    // 关闭连接
    $pdo = null;
}

?>

// 简易连接池示例（仅供参考，生产环境需完善）
class ConnectionPool {
    private static $pool = [];
    private static $maxConnections = 10;
    private static $dbConfig = [
        'host' => 'localhost',
        'port' => '3306',
        'dbname' => 'your_database_name',
        'user' => 'your_username',
        'pass' => 'your_password'
    ];

    public static function getConnection() {
        if (count(self::$pool) > 0) {
            return array_pop(self::$pool);
        }

        if (count(self::$pool) < self::$maxConnections) {
            try {
                $dsn = "mysql:host=".self::$dbConfig['host'].";port=".self::$dbConfig['port'].";dbname=".self::$dbConfig['dbname'].";charset=utf8mb4";
                $pdo = new PDO($dsn, self::$dbConfig['user'], self::$dbConfig['pass']);
                $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
                $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
                return $pdo;
            } catch (PDOException $e) {
                echo "连接失败: " . $e->getMessage() . "\n";
                return null;
            }
        } else {
            // 超过最大连接数，等待或抛出异常
            echo "连接池已满，请稍后重试。\n";
            return null; // 或者抛出异常
        }
    }

    public static function releaseConnection($pdo) {
        if ($pdo !== null) {
            self::$pool[] = $pdo;
        }
    }
}

// 使用示例
$conn = ConnectionPool::getConnection();
if ($conn) {
    // ... 使用 $conn 进行数据库操作 ...
    ConnectionPool::releaseConnection($conn);
}

// 版本判断示例
$version = $pdo->query("SELECT VERSION()")->fetchColumn();
echo "数据库版本：".$version."\n";

if (strpos($version, 'MariaDB') !== false) {
    // MariaDB specific code
    echo "这是MariaDB数据库。\n";
} else {
    // MySQL specific code
    echo "这是MySQL数据库。\n";
}