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() 关闭游标，使该声明再次执行

<?php
    require './config.php';
try {
    $pdo=new PDO(DSN,USER,PASS);
    $pdo->query("set names utf8");
} catch (PDOException $e) {
    echo "连接数据库失败！原因：".$e->getMessage();
    die;
}    
    

    $stmt=$pdo->query("select * from stu");
    
    //第一种解析方式    直接循环对象
/*    foreach ($stmt as $stu) {
        echo $stu['id'].":".$stu['name']."<br>";
    }*/

    //第二种    一次拿出所有数据
    /*$list=$stmt->fetchAll(PDO::FETCH_ASSOC);
    var_dump($list);*/

    //第三种    一次拿一条数据
    while ($row=$stmt->fetch(PDO::FETCH_ASSOC)) {
        var_dump($row);
    }
?>

在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();

<?php
//PDO操作
require './config.php';

try {

    $driver=array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION);
    $pdo=new PDO(DSN,USER,PASS,$driver);

} catch (Exception $e) {
    die("PDO实例化失败！原因：".$e->getMessage());
}

try {
    //别名式
    $sql="insert into stu values(null,:name,:sex,:age,:classid)";
    //?号式
    //$sql="insert into stu values(null,?,?,?,?)";
    $stmt=$pdo->prepare($sql);

    //可以无序
    $data=array(
            array("name"=>"pp04","sex"=>"w","age"=>22,"classid"=>"lamp149"),
            array("sex"=>"m","name"=>"pp05","age"=>20,"classid"=>"lamp145"),
            array("name"=>"pp01","sex"=>"w","age"=>22,"classid"=>"lamp150"),
        );

    //?号式，注意顺序
    /* $data=array(
            array("pp09","w","22","lamp145"),
            array("pp07","m","20","lamp149"),
            array("pp08","w","22","lamp149"),
        );*/
    $m=0;
    foreach ($data as $v) {
        $stmt->execute($v);
        $m+=$stmt->rowCount();
    }
} catch (Exception $e) {
    echo "添加失败！原因：".$e->getMessage()."<br>";
}
    echo "成功添加{$m}条！";

?> 

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);

<?php

require './config.php';

try {
    $pdo=new PDO(DSN,USER,PASS);
    //设置异常模式[默认情况下SQL执行失败忽略]
    $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
} catch (Exception $e) {
    die("PDO实例化失败！原因：".$e->getMessage());
}

try {
    //开启事务
    $pdo->beginTransaction();

    $sql="insert into stu values(null,?,?,?,?)";
    $stmt=$pdo->prepare($sql);

    $data=array(
            array("pp09","w","22","lamp145"),
            array("pp10","m","20","lamp149"),
            array("pp08","w","22","lamp149"),
        );
    $m=0;
    foreach ($data as $v) {
        $stmt->execute($v);
        $m+=$stmt->rowCount();
    }
    //如果前面都没有异常说明SQL全部执行成功，提交事务
    $pdo->commit();
} catch (Exception $e) {
    echo "添加失败！原因：".$e->getMessage();
    //捕获到异常，执行回滚
    $pdo->rollback();
    $m=0;
}
echo "成功添加{$m}条数据";
?>