pdo类的封装
1. PDO类.rar
2. PHP代码
<?php
/**
* Created by tudou.
* Date: 13-2-4
* Time: 下午9:57
*/
/**
其他未实现的
1、绑定列到php变量请使用 $db->statement->bindColumn(1,$name);
*/
class pdo_class {
private $pdo = null;
public $statement = null;
private $is_addsla = false;
public $options = array(
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES ",
);
public function __construct($host,$user="root",$pass="",$dbname="",$persistent=false,$charset="utf8"){
$this->options[PDO::MYSQL_ATTR_INIT_COMMAND] .= $charset;
if($persistent){
$this->options[PDO::ATTR_PERSISTENT] = true;
}
$dsn = "mysql:host={$host};dbname={$dbname}";
$this->pdo = new PDO($dsn,$user,$pass,$this->options);
}
/**
全局属性设置，包括：列名格式和错误提示类型 可以使用数字也能直接使用参数
*/
public function setAttr($param,$val=''){
if(is_array($param)){
foreach($param as $key=>$val){
$this->pdo->setAttribute($key,$val);
}
}else{
if($val!=''){
$this->pdo->setAttribute($param,$val);
}else{
return false;
}
}
}
/**
生成一个编译好的sql语句模版 你可以使用 ? :name 的形式
返回一个statement对象
*/
public function prepare($sql=""){
if($sql==""){
return false;
}
$this->statement = $this->pdo->prepare($sql);
return $this->statement;
}
/**
执行Sql语句，一般用于 增、删、更新或者设置 返回影响的行数
*/
public function exec($sql){
if($sql==""){
return false;
}
try{
return $this->pdo->exec($sql);
}catch(Exception $e){
return $e->getMessage();
}
}
/**
执行有返回值的查询，返回PDOStatement 可以通过链式操作，可以通过这个类封装的操作获取数据
*/
public function query($sql){
if($sql=""){
return false;
}
$this->statement = $this->pdo->query($sql);
return $this->statement;
}
/**
开启事务
*/
public function beginTA(){
return $this->pdo->beginTransaction();
}
/**
提交事务
*/
public function commit(){
return $this->pdo->commit();
}
/**
事务回滚
*/
public function rollBack(){
return $this->pdo->rollBack();
}
public function lastInertId(){
return $db->lastInsertId();
}
//** PDOStatement 类操作封装 **//
/**
让模版执行SQL语句，1、执行编译好的 2、在执行时编译
*/
public function execute($param=""){
if(is_array($param)){
try{
return $this->statement->execute($param);
}catch (Exception $e){
//return $this->errorInfo();
return $e->getMessage();
}
}else{
try{
return $this->statement->execute();
}catch(Exception $e){
/* 返回的错误信息格式
[0] => 42S22
[1] => 1054
[2] => Unknown column 'col' in 'field list'
return $this->errorInfo();
*/
return $e->getMessage();
}
}
}
/**
参数1说明：
PDO::FETCH_BOTH 也是默认的，两者都有（索引，关联）
PDO::FETCH_ASSOC 关联数组
PDO::FETCH_NUM 索引
PDO::FETCH_OBJ 对象
PDO::FETCH_LAZY 对象 会附带queryString查询SQL语句
PDO::FETCH_BOUND 如果设置了bindColumn，则使用该参数
*/
public function fetch($fetch_style=PDO::FETCH_BOTH){
if(is_object($this->statement)){
return $this->statement->fetch($fetch_style);
}else{
return false;
}
}
/**
参数1说明：
PDO::FETCH_BOTH 也是默认的，两者都有（索引，关联）
PDO::FETCH_ASSOC 关联数组
PDO::FETCH_NUM 索引
PDO::FETCH_OBJ 对象
PDO::FETCH_COLUMN 指定列 参数2可以指定要获取的列
PDO::FETCH_CLASS 指定自己定义的类
PDO::FETCH_FUNC 自定义类 处理返回的数据
PDO_FETCH_BOUND 如果你需要设置bindColumn，则使用该参数
参数2说明：
给定要处理这个结果的类或函数
*/
public function fetchAll($fetch_style=PDO::FETCH_BOTH,$handle=''){
if($handle!=''){
return $this->statement->fetchAll($fetch_style,$handle);
}else{
return $this->statement->fetchAll($fetch_style);
}
}
/**
以对象形式返回 结果 跟fetch(PDO::FETCH_OBJ)一样
*/
public function fetchObject($class_name){
if($clss_name!=''){
return $this->statement->fetchObject($class_name);
}else{
return $this->statement->fetchObject();
}
}
/**
public function bindColumn($array=array(),$type=EXTR_OVERWRITE){
if(count($array)>0){
extract($array,$type);
}
//$this->statement->bindColumn()
}
*/
/**
以引用的方式绑定变量到占位符(可以只执行一次prepare，执行多次bindParam达到重复使用的效果)
*/
public function bindParam($parameter,$variable,$data_type=PDO::PARAM_STR,$length=6){
return $this->statement->bindParam($parameter,$variable,$data_type,$length);
}
/**
返回statement记录集的行数
*/
public function rowCount(){
return $this->statement->rowCount();
}
public function count(){
return $this->statement->rowCount();
}
/**
关闭编译的模版
*/
public function close(){
return $this->statement->closeCursor();
}
public function closeCursor(){
return $this->statement->closeCursor();
}
/**
返回错误信息也包括错误号
*/
private function errorInfo(){
return $this->statement->errorInfo();
}
/**
返回错误号
*/
private function errorCode(){
return $this->statement->errorCode();
}
//简化操作
public function insert($table,$data){
if(!is_array($data)){
return false;
}
$cols = array();
$vals = array();
foreach($data as $key=>$val){
$cols[]=$key;
$vals[]="'".$this->addsla($val)."'";
}
$sql = "INSERT INTO {$table} (";
$sql .= implode(",",$cols).") VALUES (";
$sql .= implode(",",$vals).")";
return $this->exec($sql);
}
public function update($table,$data,$where=""){
if(!is_array($data)){
return false;
}
$set = array();
foreach($data as $key=>$val){
$set[] = $key."='".trim($this->addsla($val))."'";
}
$sql = "UPDATE {$table} SET ";
$sql .= implode(",",$set);
$sql .= " WHERE ".$where;
return $this->exec($sql);
}
public function delete($table,$where=""){
$sql = "DELETE FROM {$table} WHERE ".$where;
return $this->exec($sql);
}
private function addsla($data){
if($this->is_addsla){
return trim(addslashes($data));
}
return $data;
}
}
以上就是PDO类的封装的内容，更多相关内容请关注PHP中文网（www.php.cn）！
