有关PHP中PDO连贯数据库的细致教程与现实操纵演示
简介:PDO扩展为PHP拜访数据库定义了一个轻量级的、一致性的接口,PDO解决了数据库连接不统一的问题。
一、 PDO简介
本章主要介绍PDO的安置与配置,乃至使用PDO连接数据库的办法。
1-1PDO简介
PDO是PHP Data Object(PHP数据对象)的简称,它是与PHP5.1版本一起公布的,当前支撑的数据库包罗Firebird、FreeTDS、Interbase、MySQL、MS SQL Server、ODBC、Oracle、Postgre SQL、SQLite和Sybase。当操纵不一样数据库时,只需要修改PDO中的DSN
(数据库源) ,即可使用PDO的统一接口停止操纵。
PDO特性:
编码一致性:PDO供给可用于各种数据库的简单接口
灵敏性:PDO在运转时必需加载数据库驱动程序,所以不需要每次在使用数据库时,从新配置和从新编译PHP
高机能:PDO是用C说话编写的编译为PHP,与用php编写的其他方案比拟,虽然其他功效雷同,但供给了更高的机能
面向对象特性:PDO是利用的PHP5面向对象的特性,可以获得更高效的数据库通讯。
留意:PDO扩展只是一个抽象的接口层,利用PDO扩展本身,并不克不及实现任何数据库的操纵,必需使用一个特性的情势把各自的特点展现出来才行。
1-2 PDO的配置与启用
1-3 PDO连接数据库
1.通过参数情势连接数据库(重点把握此种方法)
//通过参数情势连接数据库 try{ $dsn='mysql:host=localhost;dbname=school'; $username='root'; $password='root'; $pdo=new PDO($dsn,$username,$password); var_dump($pdo); }catch (PDOException $e){ echo $e->getMessage(); }; 需要留意:dsn是你的数据源 输出结果:object(PDO)#1 (0) { }
二、 PDO对象的使用
主要介绍PDO对象办法的使用。
2-1 [PDO] exec()办法施行建表操纵
<?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //exec():施行一条sql语句并返回其受影响的行数;假如没有受影响的记载,它返回0 //exec关于select没有作用 //PHP是一个Web编程说话,在编程历程中不免会碰到用echo来输出大段的html和javascript足本的状况, //假如用传统的输出办法 ——按字符串输出的话, //必定要有大量的转义符来对字符串中的引号等非凡字符停止转义,避免显现语法错误。 //假如是一两处还可以容忍,但是如果一个完全的 html文本或者是一个200行的js我想是谁都会崩溃的。 //这就是PHP为什么要引入一个定界符的缘由——至少一大部分缘由是这样的。 /* 1.PHP定界符的作用就是依照原样,包罗换行格局什么的,输出在其内部的东西; 2.在PHP定界符中的任何非凡字符都不需要转义; 3.PHP定界符中的PHP变量会被正常的用其值来更换。 PHP中的定界符格局是这样的: <<<Eof …… Eof;*/ $sql=<<<EOF create table if not exists t_teacher( id int UNSIGNED auto_increment primary key, teaname varchar(20) not null UNIQUE, pwd char(32) not null, email varchar(30) not null ); EOF; $res= $pdo->exec($sql); var_dump($res); }catch (PDOException $e){ echo $e->getMessage(); };
输出结果:int(0);
2-2 [PDO] exec()办法施行插入记载操纵
续上面:插入一条或多笔记录
<?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); $sql='insert into t_teacher values(default,"king5","'.md5('king').'","waly@qq.com");'; $res=$pdo->exec($sql); echo $res; }catch (PDOException $e){ echo $e->getMessage(); };
<?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //$sql='insert into t_teacher values(default,"king6","'.md5('king').'","waly@qq.com");'; $sql=<<<EOF insert into t_teacher values (default,"king7","'.md5('king').'","waly@qq.com"), (default,"king8","'.md5('king').'","waly@qq.com"), (default,"king9","'.md5('king').'","waly@qq.com") EOF; $res=$pdo->exec($sql); echo '受影响的记载的条数为:'. $res."<br/>"; //$pdo->lastInsertId():得到新插入记载的ID号 //echo '最后插入的ID号为:'.$pdo->lastInsertId(); }catch (PDOException $e){ echo $e->getMessage(); };
2-3 [PDO] exec()办法施行其他SQL操纵
本身是king,修改为king,会是0笔记录被影响.
lastInsertId() 只能对插入有影响。
exec()对查询无作用
2-4 [PDO] errorCode()和errorInfo()办法查看错误信息
<?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //错误的表名 $sql='insert into t_teacher1 values(default,"king6","'.md5('king').'","waly@qq.com");'; $res=$pdo->exec($sql); if($res===false){ //$pdo->errorCode(); SQLSTATE的值 echo $pdo->errorCode(); echo '<hr/>'; //$pdo->errorInfo():返回的错误信息的数组,数组中包括3个单元 //0=>SQLSTATE(错误编号),1=>CODE(错误码),2=>INFO(错误信息) $errInfo=$pdo->errorInfo(); print_r($errInfo); } }catch (PDOException $e){ echo $e->getMessage(); };
2-5 [PDO] query()办法施行查询语句
<?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //查询一笔记录 //$sql='select * from t_teacher where id=5'; //查询多笔记录 $sql='select * from t_teacher'; //$pdo->query($sql):施行sql语句,返回PDOStatement对象:需要遍历这个对象,将里面的内容取出来 $stmt=$pdo->query($sql); var_dump($stmt); //只能看出这个语句返回的是一个对象 echo '<hr/>'; foreach ($stmt as $row){ print_r($row); echo '<hr/>'; echo '编号:'.$row['id'].'<br/>'; echo '会员名:'.$row['teaname'].'<br/>'; echo '邮箱:'.$row['email'].'<br/>'; echo '<hr/>'; } }catch (PDOException $e){ echo $e->getMessage(); };
Query()用于插入数据 <?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //插入一笔记录 $sql='insert into t_teacher values(default,"king12","'.md5('king').'","waly@qq.com");'; //$pdo->query($sql):施行sql语句,返回PDOStatement对象:需要遍历这个对象,将里面的内容取出来 $stmt=$pdo->query($sql); var_dump($stmt); //只能看出这个语句返回的是一个对象 }catch (PDOException $e){ echo $e->getMessage(); };
留意:更多的用query()查询数据,用exec()实现增删改
2-6 [PDO] prepare()和execute()办法施行查询语句
<?php //查询单条语句 try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //查询一笔记录 $sql='select * from t_teacher where id=5'; //$pdo->prepare($sql);预备sql语句 $stmt=$pdo->prepare($sql); //execute():施行预处置语句 $res=$stmt->execute(); //var_dump($res); //会返回bool(true) //查数据使用 //fetch():得到结果集中的一笔记录(作为索引+关联样式返回) $row=$stmt->fetch(); print_r($row); }catch (PDOException $e){ echo $e->getMessage(); };
<?php try{ //驱动器的名称 mysql $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //查询多笔记录 $sql='select * from t_teacher'; //$pdo->prepare($sql);预备sql语句 $stmt=$pdo->prepare($sql); //execute():施行预处置语句 $res=$stmt->execute(); //var_dump($res); //会返回bool(true) //查数据使用 //fetch():得到结果集中的一笔记录(作为索引+关联数组) /*if($res){ while ($row=$stmt->fetch()){ print_r($row); echo '<hr/>'; } }*/ //fetchAll() 查询所有记载,以二维数组(索引+关联方式) $rows=$stmt->fetchAll(); print_r($rows); }catch (PDOException $e){ echo $e->getMessage(); };
指定类型:我们更多的是想得到关联数组,我们可以通过两种方式来获得,第一种方式:设定其取回数据的方式(设定参数、常量);第二种方式:通过办法
三、 PDOStatement对象的使用
本章主要介绍PDOStatement对象办法的使用,乃至参数的绑定与预处识。
3-1 [PDO] quote()办法防止SQL注入
带前提查询 登录实现的例子
<?php header('content-type:text/html;charset=utf-8'); $username=$_POST['username']; $password=$_POST['password']; try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //向数据库表查寻对应的会员信息//假如存在,证明有这个会员,登录成功;不然登录失败 //输入 'or 1=1 # 可以查看查到的数据 //$sql="select * from t_user WHERE `name`='{$username}' AND `password`='{$password}'"; //通过quote():返回带引号的字符串,过滤字符串中的非凡字符 $username=$pdo->quote($username); $sql="select * from t_user WHERE `name`={$username} AND `password`={$password}"; echo $sql; $stmt=$pdo->query($sql); //PDOStatement对象的办法:rowCount() :关于select操纵返回的结果集中记载的条数, //关于INSERT、UPDATE、DELETE返回受影响的记载的条数 echo $stmt->rowCount(); }catch (PDOException $e){ echo $e->getMessage(); }
3-2 [PDO] 预处置语句中的占位符的使用
<?php header('content-type:text/html;charset=utf-8'); $username=$_POST['username']; $password=$_POST['password']; try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //占位符有两种办法 //第一种办法 $sql="select * from t_user WHERE `name`=:username and `password`=:password"; $stmt=$pdo->prepare($sql); $stmt->execute(array(":username"=>$username,":password"=>$password)); //PDOStatement对象的办法:rowCount() :关于select操纵返回的结果集中记载的条数, //关于INSERT、UPDATE、DELETE返回受影响的记载的条数 echo $stmt->rowCount(); //第二种办法 $sql="select * from t_user WHERE `name`=? and `password`=?"; $stmt=$pdo->prepare($sql); $stmt->execute(array($username,$password)); echo $stmt->rowCount(); }catch (PDOException $e){ echo $e->getMessage(); }
3-3 [PDO] bindParam()办法绑定参数
两种方式:命名参数占位符,问号方式
<?php header('content-type:text/html;charset=utf-8'); try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); // $sql="insert into t_user(`name`,`password`,`sex`) VALUES (:username,:password,:sex)"; $sql="insert into t_user VALUES (DEFAULT ,:username,:password,:sex)"; $stmt=$pdo->prepare($sql); $stmt->bindParam(":username",$username,PDO::PARAM_STR); $stmt->bindParam(":password",$password,PDO::PARAM_STR); $stmt->bindParam(":sex",$sex,PDO::PARAM_STR); $username='张三'; $password='123654'; $sex='M'; $stmt->execute(); echo $stmt->rowCount(); }catch (PDOException $e){ echo $e->getMessage(); }
<?php header('content-type:text/html;charset=utf-8'); try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); // $sql="insert into t_user(`name`,`password`,`sex`) VALUES (:username,:password,:sex)"; $sql="insert into t_user VALUES (DEFAULT ,?,?,?)"; $stmt=$pdo->prepare($sql); $stmt->bindParam(1,$username); $stmt->bindParam(2,$password); $stmt->bindParam(3,$sex); $username='张三1'; $password='1236541'; $sex='F'; $stmt->execute(); echo $stmt->rowCount(); }catch (PDOException $e){ echo $e->getMessage(); }
3-4 [PDO] bindValue()办法绑定参数
向会员表插入数据:命名参数占位符,问号方式相似
<?php header('content-type:text/html;charset=utf-8'); try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); // $sql="insert into t_user(`name`,`password`,`sex`) VALUES (:username,:password,:sex)"; $sql="insert into t_user VALUES (DEFAULT ,?,?,?)"; $stmt=$pdo->prepare($sql); $username='李四'; $password='123654'; $stmt->bindValue(1,$username); $stmt->bindValue(2,$password); $stmt->bindValue(3,'M'); $stmt->execute(); echo $stmt->rowCount(); $username='李四1'; $password='1236541'; $stmt->bindValue(1,$username); $stmt->bindValue(2,$password); $stmt->bindValue(3,'M'); $stmt->execute(); echo $stmt->rowCount(); }catch (PDOException $e){ echo $e->getMessage(); }
3-5 [PDO] bindColumn()办法绑定参数
<?php header('content-type:text/html;charset=utf-8'); try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); // $sql="insert into t_user(`name`,`password`,`sex`) VALUES (:username,:password,:sex)"; $sql="select `name`,`password`,`sex` from t_user"; $stmt=$pdo->prepare($sql); $stmt->execute(); echo '结果集中的列数一共有:'.$stmt->columnCount(); echo "<hr/>"; print_r($stmt->getColumnMeta(0)); $stmt->bindColumn(1,$username); $stmt->bindColumn(2,$password); $stmt->bindColumn(3,$sex); while ($stmt->fetch(PDO::FETCH_BOUND)){ echo '会员名:'.$username."-密码:".$password."-性别:".$sex."<hr/>"; } echo $stmt->rowCount(); }catch (PDOException $e){ echo $e->getMessage(); }
3-6 [PDO] fetchColumn()办法从结果集中返回一列
<?php header('content-type:text/html;charset=utf-8'); try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); $sql="select `name`,`password`,`sex` from t_user"; $stmt=$pdo->query($sql); //索引默许从0开端 echo $stmt->fetchColumn(0),"<br/>"; echo $stmt->fetchColumn(1),"<br/>"; echo $stmt->fetchColumn(2); }catch (PDOException $e){ echo $e->getMessage(); }
3-7 [PDO] debugDumpParams()办法打印一条预处置语句
<?php header('content-type:text/html;charset=utf-8'); try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); // $sql="insert into t_user(`name`,`password`,`sex`) VALUES (:username,:password,:sex)"; $sql="insert into t_user VALUES (DEFAULT ,:username,:password,:sex)"; $stmt=$pdo->prepare($sql); $stmt->bindParam(":username",$username,PDO::PARAM_STR); $stmt->bindParam(":password",$password,PDO::PARAM_STR); $stmt->bindParam(":sex",$sex,PDO::PARAM_STR); $username='张三'; $password='123654'; $sex='M'; $stmt->execute(); $stmt->debugDumpParams(); }catch (PDOException $e){ echo $e->getMessage(); }
四、PDO事务处置
主要介绍怎样使用PDO停止事务处置
4-1 PDO错误处置模式
3种错误处置模式
静默模式 <?php header('content-type:text/html;charset=utf-8'); /*PDO::ERRMODE_SLIENT:默许模式,静默模式*/ try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); $sql="select * from nonet_user"; $stmt=$pdo->query($sql); echo $pdo->errorCode(); echo '<br/>'; echo $pdo->errorInfo(); }catch (PDOException $e){ echo $e->getMessage(); }
<?php header('content-type:text/html;charset=utf-8'); /*PDO::ERRMODE_SLIENT:默许模式,静默模式 *PDO::ERRMODE_WARNING:警告模式 * PDO::ERRMODE_EXCEPTION:非常模式 */ try{ //连接数据库 $pdo=new PDO('mysql:host=localhost;dbname=school','root','root'); //设定警告模式 //$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_WARNING); //设定非常模式:引荐使用 $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION); $sql="select * from nonet_user"; $stmt=$pdo->query($sql); echo $pdo->errorCode(); echo '<br/>'; echo $pdo->errorInfo(); }catch (PDOException $e){ echo $e->getMessage(); }
4-2 PDO事务处置
<?php header('content-type:text/html;charset=utf-8'); try{ $option=array(PDO::ATTR_AUTOCOMMIT,0); $pdo=new PDO('mysql:host=localhost;dbname=school','root','root',$option); //开启事务 $pdo->beginTransaction(); var_dump($pdo->inTransaction()); $sql="update account set money=money-200 WHERE username='king'"; $res=$pdo->exec($sql); if($res==0){ throw new PDOException('转账失败'); } $res1=$pdo->exec('update account set money=money+200 WHERE username="queen"'); if($res1==0){ throw new PDOException('接收失败'); } $pdo->commit(); }catch (PDOException $e){ $pdo->rollBack(); echo $e->getMessage(); }
好了,以上就是关于本文介绍的关于PHP中PDO操纵数据库的具体操纵乃至实例了,相理解更多相关问题请拜访PHP中文网:
PHP视频教程
以上就是有关PHP中PDO连接数据库的具体教程与实际操纵演示的具体内容,更多请关注百分百源码网其它相关文章!