|
循环从mysql连接池中获取连接，不必须重复创建新的连接。
参考配置修改：能够参考下面的文案
防止拜访量过大，把连接数占满了
<?php
/**
* @author xuleyan
* @title mysql类
*/
class DbHelper{
//连接池
private $_pools = [];
//连接池体积
const POOLSIZE = 5;
const USERNAME = "root";
const PASSWORD = "root";
const HOST = "127.0.0.1";
const DB = "test";
public function __construct()
{
$db = self: B;
$username = self::USERNAME;
$password = self: ASSWORD;
$host = self::HOST;
//持久化连接
$presistent = array(PDO::ATTR_PERSISTENT => true);
for ($i=0; $i < self:OOLSIZE; $i++) {
$connection = new PDO("mysql:dbname=$db;host=$host", $username, $password);
// sleep(3);
array_push($this->_pools, $connection);
}
}
//从数据库连接池中获取一个数据库链接资源
public function getConnection()
{
echo get . count($this->_pools) . "<br>";
if (count($this->_pools) > 0) {
$one = array_pop($this->_pools);
echo getAfter . count($this->_pools) . "<br>";
return $one;
} else {
throw new ErrorException ( "<mark>数据库连接池中已没链接资源，请稍后重试!</mark>" );
}
}
//将用完的数据库链接资源放回到数据库连接池
public function release($conn)
{
echo release . count($this->_pools) . "<br>";
if (count($this->_pools) >= self:OOLSIZE) {
throw new ErrorException ( "<mark>数据库连接池已满!</mark>" );
} else {
array_push($this->_pools, $conn);
// $conn = null;
echo releaseAfter . count($this->_pools) . "<br>";
}
}
public function query($sql)
{
try {
$conn = $this->getConnection();
$res = $conn->query($sql);
$this->release($conn);
return $res;
} catch (ErrorException $e) {
print error: . $e->getMessage();
die;
}
}
public function queryAll($sql)
{
try {
$conn = $this->getConnection();
$sth = $conn->prepare($sql);
$sth->execute();
$result = $sth->fetchAll();
return $result;
} catch (PDOException $e) {
print error: . $e->getMessage();
die;
}
}
}
在另一的文件这般调用
<?php
require_once db.php;
$sql = select * from user;
$dbhelper = new DbHelper;
f
| 
发表于 2024-7-10 17:50:53
