如何在php中使用mysqli连接池

在 PHP 中，使用 MySQLi 连接池可以通过创建一个自定义类来实现。以下是一个简单的示例，展示了如何实现一个基本的 MySQLi 连接池：

1. 首先，创建一个名为 MysqliConnectionPool 的类，用于管理连接池。

class MysqliConnectionPool {
    private $host = "localhost";
    private $user = "username";
    private $password = "password";
    private $database = "database_name";
    private $poolSize = 5;
    private $connections = [];

    public function __construct($host, $user, $password, $database, $poolSize) {
        $this->host = $host;
        $this->user = $user;
        $this->password = $password;
        $this->database = $database;
        $this->poolSize = $poolSize;
    }

    public function getConnection() {
        if (empty($this->connections)) {
            for ($i = 0; $i < $this->poolSize; $i++) {
                $this->connections[] = new mysqli($this->host, $this->user, $this->password, $this->database);
                if ($this->connections[$i]->connect_error) {
                    die("Connection failed: " . $this->connections[$i]->connect_error);
                }
            }
        }
        $connection = array_pop($this->connections);
        return $connection;
    }

    public function releaseConnection($connection) {
        array_push($this->connections, $connection);
    }
}

2. 然后，实例化 MysqliConnectionPool 类并设置相关参数。

$pool = new MysqliConnectionPool("localhost", "username", "password", "database_name", 5);

3. 使用 getConnection() 方法从连接池中获取一个连接。

$connection = $pool->getConnection();

4. 执行 SQL 查询并处理结果。

$query = "SELECT * FROM your_table";
$result = $connection->query($query);

if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "id: " . $row["id"]. " - Name: " . $row["name"]. "
";
    }
} else {
    echo "0 results";
}

5. 完成查询后，使用 releaseConnection() 方法将连接放回连接池。

$pool->releaseConnection($connection);

这个示例展示了如何创建一个简单的 MySQLi 连接池。你可以根据需要调整连接池的大小、参数等。请注意，这个示例仅用于演示目的，实际生产环境中可能需要更复杂的错误处理和连接管理。