您的位置 首页 php

有关PHP中PDO连接数据库的详细教程与实际操作演示

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扩展本身,并不能实现任何数据库的操作,必须使用一个特性的形式把各自的特色表现出来才行。

PDO数据库.png

1-2 PDO的配置与启用

PDO安装与配置.png

1-3 PDO连接数据库

PDO连接数据库.png

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()方法执行建表操作

PDO对象的方法2.png

<?phptry{    //驱动器的名称 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()方法执行插入记录操作

续上面:插入一条或多条记录

<?phptry{    //驱动器的名称 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();};
<?phptry{    //驱动器的名称 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操作

PDO执行其它方法.png

本身是king,修改为king,会是0条记录被影响.

lastInsertId() 只能对插入有影响。

exec()对查询无作用

2-4 [PDO] errorCode()和errorInfo()方法查看错误信息

<?phptry{    //驱动器的名称 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()方法执行查询语句

<?phptry{    //驱动器的名称 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()用于插入数据<?phptry{    //驱动器的名称 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()方法执行查询语句

PDOstatement对象方法.png

<?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();};
<?phptry{    //驱动器的名称 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对象方法的使用,以及参数的绑定与预处识。

PDOstatement对象的方法.png

3-1 [PDO] quote()方法防止SQL注入

带条件查询 登录实现的例子

<?phpheader('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] 预处理语句中的占位符的使用

<?phpheader('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()方法绑定参数

两种方式:命名参数占位符,问号方式

<?phpheader('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();}
<?phpheader('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()方法绑定参数

向用户表插入数据:命名参数占位符,问号方式类似

<?phpheader('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()方法绑定参数

PDOstatement对象的方法3.png

<?phpheader('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()方法从结果集中返回一列

<?phpheader('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()方法打印一条预处理语句

<?phpheader('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种错误处理模式

静默模式<?phpheader('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();}
<?phpheader('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事务处理

PDO对象的方法3.png

<?phpheader('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连接数据库的详细教程与实际操作演示的详细内容,更多请关注求知技术网其它相关文章!

文章来源:智云一二三科技

文章标题:有关PHP中PDO连接数据库的详细教程与实际操作演示

文章地址:https://www.zhihuclub.com/3609.shtml

关于作者: 智云科技

热门文章

网站地图