自写的利用PDO对mysql数据库增删改查操作类
前言
PDO一是PHP数据对象（PHPDataObject）的缩写。
并不能使用PDO扩展本身执行任何数据库操作，必须使用一个database-specificPDOdriver（针对特定数据库的PDO驱动）访问数据库服务器。
PDO并不提供数据库抽象，它并不会重写SQL或提供数据库本身缺失的功能，如果你需要这种功能，你需要使用一个更加成熟的抽象层。
最近在做项目时用到了PDO操作mysql数据库，于是自己写了一个类文件，命名为mysql_class.php文件代码如下：
示例代码
link=new\PDO(self::DSN,self::USERNAME,self::PASSWD,array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION));//创建连接
}
catch(PDOException$e){
die("Error!:".$e->getMessage()."
");
}
}
/*******************************************************************************
*@名称：执行sql语句
*@属性：私有
*@入口参数：无
*@出口参数:执行成功返回真，否则返回假，查询语句存储结果集数组
*******************************************************************************/
privatefunctionsql(){
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;//存储结果集
returntrue;//查询到结果返回真
}else{
returnfalse;//否则返回假
}
}elseif($cmd=="insert"||$cmd=="delete"||$cmd=="update"){
if($prepare){
returntrue;//执行成功返回真
}else{
returnfalse;//否则返回假
}
}
$this->link->commit();//如果正确执行完成那么确认commit
}catch(PDOException$e){
$this->link->rollBack();//如果执行中有错误的情况下回滚
die("Error!:".$e->getMessage()."
");
}
}
/*******************************************************************************
*@名称：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($resas$key=>$val){
echo$key."=".$val."
";
}
}//遍历查询结果数组
*******************************************************************************/
publicfunctionhandle($cmd,$dsname,$first,$second=NULL){
switch($cmd){
case'insert'://插入
$this->sql="insertinto$dsname($first)values($second)";
break;
case'delete'://删除
$this->sql="deletefrom$dsnamewhere$first";
break;
case'update'://更新
$this->sql="update$dsnameset$firstwhere$second";
break;
case'select'://查询
$this->sql="select$firstfrom$dsnamewhere$second";
break;
default:
die("SyntaxError!");//提示语法错误
break;
}
$res=$this->sql();//执行sql语句
if($res){
if($cmd=='select'){
return$this->result;//返回查询结果
}else{
returntrue;//执行成功返回真
}
}else{
returnfalse;//否则返回假
}
$this->link=NULL;;//关闭数据库
}
}
$mysql=newmysql;//数据库类的实例化
?>
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对毛票票的支持。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。