PHP面向对象(七)

PHP操作MySQL数据库方式有三种:
  1. mysql 最原始的、纯过程化的 如连接: mysql_connect(主机名,账号,密码);
    mysql_query();

  2. mysqli 改进版的、兼容过程化和面向对象化操作
    如:连接: mysqli_connect(主机名,账号,密码,库名) //过程化
    new mysqli(主机名,账号,密码,库名) //面向对象

  3. PDO 通用的,兼容其他数据库 , 纯面向对象方式
    如: 连接: new PDO(DSN,账号,密码);

  选择PDO的原因(优点):
    1> 跨数据库
    2> 带预处理(防sql注入)
    3> 支持事务操作

  PDO(php data object)扩展类库为php访问数据库定义了轻量级的、一致性的接口,它提供了一个数据库访问抽象层,这样,无论你使用什么数据库,都可以通过一致的函数执行查询和获取数据,大大简化了数据库的捉拿和,并能够屏蔽不同数据库之间的差异,使用pdo可以很方便地进行跨数据库程序的开发,以及不同数据库间的移植,它可以支持mysql,postgresql,oracle,mssql等多种数据库。

  PDO安装:
    1. 编辑php.ini文件:
      extension=php_pdo.dll
      extension=php_pdo_mysql.dll
    2.重启apache服务:
      httpd –k restart
    3.打开phpinfo.php查看是否有pdo

PDO中的构造方法:
  PDO __construct( string dsn
            [, string username
            [, string password
            [, array driver_options]]] );

  其中:dsn数据库连接信息如“mysql:host=localhost;dbname=库名”
    dsn的格式:”驱动名:host=主机名;dbname=库名“
    username:用户名
    password:密码
    driver_options:配置选项:
      如: PDO::ATTR_PERSISTENT=>true,是否开启持久链接
         PDO::ATTR_ERRMODE=>错误处理模式:(可以是以下三个)(3)
         PDO::ERRMODE_SILENT:不报错误(忽略)(0)
         PDO::ERRMODE_WARNING:以警告的方式报错(1)
         PDO::ERRMODE_EXCEPTION:以异常的方式报错(推荐使用)。(2)

实例化一个PDO对象:
  $pdo = new PDO("mysql:host=localhost;dbname=LAMP","root","123456");
设置php连接mysql时的客户端字符串和连接字符串集为:
  $pdo->exec("set names utf8");
  或者:
  $pdo->query("set names utf8");

PDO类中的成员方法:
  1.  query($sql); 用于执行查询SQL语句。返回PDOStatement对象
  2.  exec($sql); 用于执行增、删、改操作,返回影响行数;
  3.  getAttribute(); 获取一个"数据库连接对象"属性。
  4.  setAttribute(); 设置一个"数据库连接对象"属性。
  5.  beginTransaction 开启一个事物(做一个回滚点)
  6.  commit 提交事务
  7.  rollBack 事务回滚操作。
  8.  errorCode 获取错误码
  9.  errorInfo 获取错误信息
  10.lastInsertId 获取刚刚添加的主键值。
  11.prepare 创建SQL的预处理,返回PDOStatement对象
  12.quote 为sql字串添加单引号。

PDO对预处理语句的支持:
  PDO提供了一种名为预处理语句(Prepared Statement)的机制。它可以将整个SQL命令向数据库服务器发送一次,以后只要参数发生变化,数据库服务器只需要对命令的结构做一次分析就够了,即编译一次,可以多次执行。不仅可以有效的提高命令的处理效率,还能有效防止SQL注入。(MySQL数据库本身就支持预处理机制,PDO扩展类库支持了预处理机制)

PDOStatement类中的成员方法:
  1、fetch() 返回结果集的下一行,结果指针下移,到头返回false 。
    参数:   PDO::FETCH_BOTH (default)、:索引加关联数组模式
        PDO::FETCH_ASSOC、 :关联数组模式
        PDO::FETCH_NUM、 :索引数组模式
        PDO::FETCH_OBJ、 :对象模式
        PDO::FETCH_LAZY :所有模式(SQL语句和对象)

  2、fetchAll() 通过一次调用返回所有结果,结果是以数组形式保存
    参数:  PDO::FETCH_BOTH (default)、
        PDO::FETCH_ASSOC、
        PDO::FETCH_NUM、
        PDO::FETCH_OBJ、
        PDO::FETCH_COLUMN表示取指定某一列,
    如:$rslist = $stmt->fetchAll(PDO::FETCH_COLUMN,2);取第三列
  3、execute() 负责执行一个准备好了的预处理语句
  4. fetchColumn()返回结果集中下一行某个列的值
  5. setFetchMode()设置需要结果集合的类型
  6. rowCount() 返回使用增、删、改、查操作语句后受影响的行总数
  7. setAttribute()为一个预处理语句设置属性
  8. getAttribute()获取一个声明的属性
  9. errorCode() 获取错误码
  10. errorInfo() 获取错误信息
  11. bindParam() 将参数绑定到相应的查询占位符上

    bool PDOStatement::bindParam ( mixed $parameter , mixed &$variable [, int $data_type [, int $length [, mixed $driver_options ]]] ) 其中: $parameter:占位符名或索引偏移量 &$variable:参数的值,需要按引用传递也就是必须放一个变量
    其中参数:$data_type:数据类型PDO::PARAM_BOOL/PDO::PARAM_NULL/PDO::PARAM_INT/PDO::PARAM_STR/
    PDO::PARAM_LOB/PDO::PARAM_STMT/PDO::PARAM_INPUT_OUTPUT
    $length:指数据类型的长度 $driver_options:驱动选项。

  12. bindColumn() 用来匹配列名和一个指定的变量名,这样每次获取各行记录时,会自动将相应的值赋给变量。
  13. bindValue() 将一值绑定到对应的一个参数中
  14. nextRowset() 检查下一行集
  15. columnCount() 在结果集中返回列的数目
  16. getColumnMeta() 在结果集中返回某一列的属性信息
  17. closeCursor() 关闭游标,使该声明再次执行

 1 <?php
 2     require './config.php';
 3 try {
 4     $pdo=new PDO(DSN,USER,PASS);
 5     $pdo->query("set names utf8");
 6 } catch (PDOException $e) {
 7     echo "连接数据库失败!原因:".$e->getMessage();
 8     die;
 9 }    
10     
11 
12     $stmt=$pdo->query("select * from stu");
13     
14     //第一种解析方式    直接循环对象
15 /*    foreach ($stmt as $stu) {
16         echo $stu['id'].":".$stu['name']."<br>";
17     }*/
18 
19     //第二种    一次拿出所有数据
20     /*$list=$stmt->fetchAll(PDO::FETCH_ASSOC);
21     var_dump($list);*/
22 
23     //第三种    一次拿一条数据
24     while ($row=$stmt->fetch(PDO::FETCH_ASSOC)) {
25         var_dump($row);
26     }
27 ?>

在PDO中参数式的SQL语句有两种(预处理sql):
  1.insert into stu(id,name) value(?,?); //?号式(适合参数少的)
  2.insert into stu(id,name) value(:id,:name); // 别名式(适合参数多的)

在PDO中为参数式SQL语句赋值有三种:
  1.使用数组
    $stmt->execute(array("LAMP","qq2"));
    $stmt->execute(array("id"=>"LAMP","name"=>"qq2"));
  2.使用方法单个赋值
    $stmt->bindValue(1,"LAMP");
    $stmt->bindValue(2,"qq2");
    $stmt->execute();

    $stmt->bindValue(":id","LAMP",PDO::PARAM_STR); //带指定类型
    $stmt->bindValue(":name","qq2",PDO::PARAM_STR);
    $stmt->execute();

  3. 使用方法绑定变量
    $stmt->bindParam(":id",$id);
    $stmt->bindParam(":name",$name);
    $id="LAMP";
    $name="qq2";
    $stmt->execute();

 1 <?php
 2 //PDO操作
 3 require './config.php';
 4 
 5 try {
 6 
 7     $driver=array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION);
 8     $pdo=new PDO(DSN,USER,PASS,$driver);
 9 
10 } catch (Exception $e) {
11     die("PDO实例化失败!原因:".$e->getMessage());
12 }
13 
14 try {
15     //别名式
16     $sql="insert into stu values(null,:name,:sex,:age,:classid)";
17     //?号式
18     //$sql="insert into stu values(null,?,?,?,?)";
19     $stmt=$pdo->prepare($sql);
20 
21     //可以无序
22     $data=array(
23             array("name"=>"pp04","sex"=>"w","age"=>22,"classid"=>"lamp149"),
24             array("sex"=>"m","name"=>"pp05","age"=>20,"classid"=>"lamp145"),
25             array("name"=>"pp01","sex"=>"w","age"=>22,"classid"=>"lamp150"),
26         );
27 
28     //?号式,注意顺序
29     /* $data=array(
30             array("pp09","w","22","lamp145"),
31             array("pp07","m","20","lamp149"),
32             array("pp08","w","22","lamp149"),
33         );*/
34     $m=0;
35     foreach ($data as $v) {
36         $stmt->execute($v);
37         $m+=$stmt->rowCount();
38     }
39 } catch (Exception $e) {
40     echo "添加失败!原因:".$e->getMessage()."<br>";
41 }
42     echo "成功添加{$m}条!";
43 
44 ?> 

MySQL的事务处理:
  事务:将多条sql操作(增删改)作为一个操作单元,要么都成功,要么都失败。
  MySQL对事务的支持:
    第一、被操作的表必须是innoDB类型的表(支持事务)
        MySQL常用的表类型:MyISAM(非事务)增删改速度快、InnodB(事务型)安全性高
        更改表的类型为innoDB类型
          mysql> alter table stu engine=innodb;
          Query OK, 29 rows affected (0.34 sec)
          Records: 29 Duplicates: 0 Warnings: 0
          mysql> show create table stuG; //查看表结构
    第二:使用PDO就可以操作数据库了
      使用到了PDO中的方法:
        beginTransaction 开启一个事物(做一个回滚点)
        commit 提交事务
        rollBack 事务回滚操作。

    使用情况:当做多条sql语句处理时(增删改),要求是都必须成功。

  开启一次事务:
    $pdo->beginTransaction();
  提交一次事务:
    $pdo->commit();
  回滚一次事务:
    $pdo->rollback();
  注意如下设置:
    1.$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,0);
    2.$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,1);

 1 <?php
 2 
 3 require './config.php';
 4 
 5 try {
 6     $pdo=new PDO(DSN,USER,PASS);
 7     //设置异常模式[默认情况下SQL执行失败忽略]
 8     $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
 9 } catch (Exception $e) {
10     die("PDO实例化失败!原因:".$e->getMessage());
11 }
12 
13 try {
14     //开启事务
15     $pdo->beginTransaction();
16 
17     $sql="insert into stu values(null,?,?,?,?)";
18     $stmt=$pdo->prepare($sql);
19 
20     $data=array(
21             array("pp09","w","22","lamp145"),
22             array("pp10","m","20","lamp149"),
23             array("pp08","w","22","lamp149"),
24         );
25     $m=0;
26     foreach ($data as $v) {
27         $stmt->execute($v);
28         $m+=$stmt->rowCount();
29     }
30     //如果前面都没有异常说明SQL全部执行成功,提交事务
31     $pdo->commit();
32 } catch (Exception $e) {
33     echo "添加失败!原因:".$e->getMessage();
34     //捕获到异常,执行回滚
35     $pdo->rollback();
36     $m=0;
37 }
38 echo "成功添加{$m}条数据";
39 ?>    
原文地址:https://www.cnblogs.com/yexiang520/p/5675018.html