php pdo 封装类,php pdo封装类代码(支持事务)
/**
* PDO數據庫
* @copyright By GOOGLE
*/
class pdo_db
{
/**
* PDO實例
* @var PDO
*/
protected $_db;
/**
* PDO準備語句
* @var PDOStatement
*/
protected $_stmt;
/**
* 最后的SQL語句
* @var string
*/
protected $_sql;
/**
* 配置信息 $config=array('dsn'=>xxx,'name'=>xxx,'password'=>xxx,'option'=>xxx)
* @var array
*/
protected $_config;
/**
* 構造函數
* @param array $config
*/
public function __construct($config)
{
$this->_config = $config;
}
/**
* 連接數據庫
* @return void
*/
public function connect()
{
$this->_db = new PDO($this->_config['dsn'], $this->_config['name'], $this->_config['password'], $this->_config['option']);
//默認把結果序列化成stdClass
// $this->_db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
$this->_db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
//自己寫代碼捕獲Exception
$this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
}
/**
* 斷開連接
* @return void
*/
public function disConnect()
{
$this->_db = null;
$this->_stmt = null;
}
/**
* 執行sql，返回新加入的id
* @param string $statement
* @return string
*/
public function exec($statement)
{
if ($this->_db->exec($statement)){
$this->_sql = $statement;
return $this->lastId();
}
$this->errorMessage();
}
/**
* 查詢sql
* @param string $statement
* @return pdo_db
*/
public function query($statement)
{
$res = $this->_db->query($statement);
if ($res){
$this->_stmt = $res;
$this->_sql = $statement;
return $this;
}
$this->errorMessage();
}
/**
* 序列化一次數據
* @return mixed
*/
public function fetchOne()
{
return $this->_stmt->fetch();
}
/**
* 序列化所有數據
* @return array
*/
public function fetchAll()
{
return $this->_stmt->fetchAll();
}
/**
* 最后添加的id
* @return string
*/
public function lastId()
{
return $this->_db->lastInsertId();
}
/**
* 影響的行數
* @return int
*/
public function affectRows()
{
return $this->_stmt->rowCount();
}
/**
* 預備語句
* @param string $statement
* @return pdo_db
*/
public function prepare($statement)
{
$res = $this->_db->prepare($statement);
if ($res){
$this->_stmt = $res;
$this->_sql = $statement;
return $this;
}
$this->errorMessage();
}
/**
* 綁定數據
* @param array $array
* @return pdo_db
*/
public function bindArray($array)
{
foreach ($array as $k => $v){
if (is_array($v)){
//array的有效結構 array('value'=>xxx,'type'=>PDO::PARAM_XXX)
$this->_stmt->bindValue($k + 1, $v['value'], $v['type']);
} else{
$this->_stmt->bindValue($k + 1, $v, PDO::PARAM_STR);
}
}
return $this;
}
/**
* 執行預備語句
* @return bool
*/
public function execute()
{
if ($this->_stmt->execute()){
return true;
}
$this->errorMessage();
}
/**
* 開啟事務
* @return bool
*/
public function beginTransaction()
{
return $this->_db->beginTransaction();
}
/**
* 執行事務
* @return bool
*/
public function commitTransaction()
{
return $this->_db->commit();
}
/**
* 回滾事務
* @return bool
*/
public function rollbackTransaction()
{
return $this->_db->rollBack();
}
/**
* 拋出錯誤
* @throws Error
* @return void
*/
public function errorMessage()
{
return;
$msg = $this->_db->errorInfo();
throw new Exception('數據庫錯誤：' . $msg[2]);
}
//---------------------
/**
* 單例實例
* @var pdo_db
*/
protected static $_instance;
/**
* 默認數據庫
* @static
* @param array $config
* @return pdo_db
*/
public static function instance($config)
{
if (!self::$_instance instanceof pdo_db){
self::$_instance = new pdo_db($config);
self::$_instance->connect();
}
return self::$_instance;
}
//----------------------
/**
* 獲取PDO支持的數據庫
* @static
* @return array
*/
public static function getSupportDriver(){
return PDO::getAvailableDrivers();
}
/**
* 獲取數據庫的版本信息
* @return array
*/
public function getDriverVersion(){
$name = $this->_db->getAttribute(PDO::ATTR_DRIVER_NAME);
return array($name=>$this->_db->getAttribute(PDO::ATTR_CLIENT_VERSION));
}
}
總結
以上是生活随笔為你收集整理的php pdo 封装类,php pdo封装类代码(支持事务)的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： php curl 句柄 复用,PHP-c
- 下一篇： php日志导出oracle,一个php导