php實現(xiàn)mysql連接池效果實現(xiàn)代碼

?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::DB;
    $username = self::USERNAME;
    $password = self::PASSWORD;
    $host = self::HOST;

    //持久化連接
    $presistent = array(PDO::ATTR_PERSISTENT => true);

    for ($i=0; $i  self::POOLSIZE; $i++) { 
      $connection = new PDO("mysql:dbname=$db;host=$host", $username, $password);
      // sleep(3);
      array_push($this->_pools, $connection);
    }
  }

  //從數(shù)據(jù)庫連接池中獲取一個數(shù)據(jù)庫鏈接資源
  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>數(shù)據(jù)庫連接池中已無鏈接資源，請稍后重試!/mark>" );
    }
  }

  //將用完的數(shù)據(jù)庫鏈接資源放回到數(shù)據(jù)庫連接池
  public function release($conn)
  {
    echo 'release' . count($this->_pools) . "br>";
    if (count($this->_pools) >= self::POOLSIZE) {
      throw new ErrorException ( "mark>數(shù)據(jù)庫連接池已滿!/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;
for ($i=0; $i  10; $i++) { 
  $res = $dbhelper->query($sql);
  // var_dump($res) . PHP_EOL;
}

class BaseMysql extends Model {
  protected $connection = array(
    'db_type' => 'mysql',
    'db_user' => '***',
    'db_pwd' => '*******',
    'db_host' => '*******',
    'db_port' => '3306',
    'db_name' => 'custom',
    'db_params' => array('persist' => true),
  );
}