前言
pdo一是php数据对象（php data object）的缩写。
并不能使用pdo扩展本身执行任何数据库操作，必须使用一个database-specific pdo driver（针对特定数据库的pdo驱动）访问数据库服务器。
pdo并不提供数据库抽象，它并不会重写sql或提供数据库本身缺失的功能，如果你需要这种功能，你需要使用一个更加成熟的抽象层。
最近在做项目时用到了pdo操作mysql数据库，于是自己写了一个类文件，命名为mysql_class.php文件代码如下：
示例代码
我要评论
<?php
class mysql{
//常量声明
const dsn = "mysql:host=[数据库地址];dbname=[数据库名];charset=utf8";//数据库地址与数据库名及编码
const username = "[数据库用户名]";//用户名
const passwd = "[数据库密码]";//密码
//私有变量声明
private $sql = null;//sql语句缓存
private $link = null;//数据库连接
private $result = null;//结果
/*******************************************************************************
* @ 名称：建立连接
* @ 属性：私有
*******************************************************************************/
private function connect(){
try {
$this->link = new \pdo(self::dsn, self::username, self::passwd, array(pdo::attr_errmode => pdo::errmode_exception));//创建连接
}
catch (pdoexception $e) {
die ("error!:".$e->getmessage()."<hr/>");
}
}
/*******************************************************************************
* @ 名称：执行sql语句
* @ 属性：私有
* @ 入口参数：无
* @ 出口参数:执行成功返回真，否则返回假，查询语句存储结果集数组
*******************************************************************************/
private function sql(){
try {
$this->connect();
$this->link->begintransaction();//开启一个事务
$prepare = $this->link->prepare($this->sql);//准备查询语句
$prepare->execute();//执行查询语句并返回结果集
$cmd = strtolower(substr(trim($this->sql),0,6));//截取命令字符
if($cmd == "select"){
$array = $prepare->fetch(pdo::fetch_assoc);//获取结果集中的所有数据
if(count($array)){
$this->result = null;
$this->result = $array;//存储结果集
return true;//查询到结果返回真
}else{
return false;//否则返回假
}
}else if($cmd == "insert" || $cmd == "delete" || $cmd == "update"){
if($prepare){
return true;//执行成功返回真
}else{
return false;//否则返回假
}
}
$this->link->commit(); //如果正确执行完成那么确认commit
} catch (pdoexception $e) {
$this->link->rollback();//如果执行中有错误的情况下回滚
die ("error!:".$e->getmessage()."<hr/>");
}
}
/*******************************************************************************
* @ 名称：sql语句处理
* @ 属性：公有
* @ 入口参数：cmd增删改查字符命令；dsname数据表名；first第一个参数；second第二个参数；
* @ 出口参数：执行成功返回真，否则返回假，查询操作返回结果集数组
* @ 使用示例：
$mysql->handle("insert","abc","openid,nickname","'123','abc'");//增加
$mysql->handle("delete","abc","openid='123'");//删除
$mysql->handle("update","abc","nickname='def'","openid='123'");//更新
$res = $mysql->handle("select","abc","*","openid='123'");//查询
if(is_array($res) == true){
foreach($res as $key=>$val){
echo $key."=".$val."<hr>";
}
}//遍历查询结果数组
*******************************************************************************/
public function handle($cmd,$dsname,$first,$second=null){
switch($cmd){
case 'insert'://插入
$this->sql = "insert into $dsname ($first) values ($second)";
break;
case 'delete'://删除
$this->sql = "delete from $dsname where $first";
break;
case 'update'://更新
$this->sql = "update $dsname set $first where $second";
break;
case 'select'://查询
$this->sql = "select $first from $dsname where $second";
break;
default:
die ("syntax error!");//提示语法错误
break;
}
$res = $this->sql();//执行sql语句
if($res){
if($cmd == 'select'){
return $this->result;//返回查询结果
}else{
return true;//执行成功返回真
}
}else{
return false;//否则返回假
}
$this->link=null;;//关闭数据库
}
}
$mysql = new mysql;//数据库类的实例化
?>
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对移动技术网的支持。
如对本文有疑问， 点击进行留言回复！！
DM数据库：dm.ini参数（五）预先装载表、客户端缓存、REDO 日志、事务相关参数
php+mysql获取7天、30天的统计数据，没有数值的补充0 By勤勤学长
第一章 第六小节Duilib的WindowImplBase基类OnCreate函数中调用AttachDialog函数
网友评论