dsn = isset($arr['dsn'])?$arr['dsn']:'mysql:host=localhost;dbname=project;';
$this->user = isset($arr['user'])?$arr['user']:'root';
$this->password = isset($arr['password'])?$arr['password']:'759114';
$this->pdo= new PDO($this->dsn,$this->user,$this->password); #实例化pdo对象
}
//利用PDO实现数据库操作
/*
@param string $sql 对sql语句进行判定
*/
private function _Exec($sql){
try{ #进行错误处理
$res = $this->pdo->exec($sql);
if(!$res){ #语句错误，抛出异常
throw new PDOException('出错啦！');
}else{
return $res;
}
}
catch(PDOException $e){
echo $e->getMessage(); #输出异常信息
echo ""; echo "错误所在行：".$e->getLine()."
"; echo "错误编号：".$this->pdo->errorInfo()[1]."
"; echo "错误信息：".$this->pdo->errorInfo()[2]."
"; exit(); } } // 进行插入操作 /* * @param string $sql *@return int 受影响行数 */ public function db_insert($sql){ $res = $this->_Exec($sql); #执行操作 return $this->pdo->lastInsertId(); } // 进行插入操作 /* * @param string $sql *@return int 受影响行数 */ public function db_delete($sql){ $affected = $this->_Exec($sql); #执行操作 return $affected; } //进行更新操作 /* @param string $sql 要插入的sql语句 @retutn int 受影响的行数 */ public function db_update($sql){ $affected = $this->_Exec($sql); #执行操作 return $affected; #返回受影响的行数 } // 判断查询语句的语法是否正确 private function Iserror($sql){ try{ //执行语句 $res = $this->pdo->query($sql); if(!$res){ #语句错误，抛出异常 throw new PDOException('出错啦！'); } return $res; //语句正确 }catch(PDOException $e){ echo $e->getMessage(); #输出错误信息 echo "
"; echo "错误所在行：".$e->getLine()."
"; echo "错误编号：".$this->pdo->errorInfo()[1]."
"; echo "错误信息：".$this->pdo->errorInfo()[2]."
"; exit(); } } //进行获取操作 /* @param string $sql @return array 返回一个数组 */ public function db_getOne($sql){ $stmt = $this->Iserror($sql); #执行sql 语句进行查询， 与exec 方法不同 $row = $stmt->fetch(PDO::FETCH_ASSOC); #返回一个关联数组 return $row; } #获取多行数据 /* @param string $sql 要执行的语句 @return array 返回一个数组 */ public function db_getAll($sql){ $stmt = $this->Iserror($sql); $rows =$stmt->fetchAll($stmt,PDO::FETCH_ASSOC); return $rows; } //pdo 事务处理 /* Tran_start 开启事务 @param string $sp 保存点，默认是sp1 @return boolean */ public function db_tran_start($sp='sp1'){ #执行语句，开启事务 $res = $this->pdo->beginTransaction(); return true; } /* 事务提交 @return boolean */ public function db_tran_commit(){ $this->pdo->commit(); } //事务回滚 public function db_tran_rollback(){ $this->rollBack(); } //预编译处理 /* @param string $sql #sql 语句中使用 ? 作为占位符 @param array $params @param array $arr */ public function db_prepare($sql ,$params ){ #prepare的 预编译语句不需要 Iserror判断 $stmt = $this->pdo->prepare($sql); #执行语句 $stmt->execute($params); $res = $stmt->fetchAll(PDO::FETCH_ASSOC); return $res; } }
以上就介绍了我的PDO 类，包括了方面的内容，希望对PHP教程有兴趣的朋友有所帮助。