PHP系列（十二）数据库抽象层pdo

小木木

　　

　　1、数据库抽象层pdo
　　(1)、PDO(php data object)扩展类库为php访问数据库定义了轻量级的、一致性的接口它可以支持mysql,postgresql,oracle,mssql等多种数据库
　　(2). PDO的安装
　　编辑php.ini文件:
　　– extension=php_pdo.dll
　　– extension=php_pdo_mysql.dll
　　重启apache服务:
　　– httpd –k restart
　　打开phpinfo.php查看是否有pdo
　　2、创建pdo对象
　　Oracle库
　　/*连接如果失败，使用异常处理模式进行捕获 */
　　try{
　　$dbh = newPDO("OCI:dbname=accounts;charset=UTF-8", "scott","tiger");
　　}catch(PDOException$e) {
　　echo "数据库连接失败： " .$e->getMessage();
　　}
　　Mysql库
　　$dsn ='mysql:dbname=testdb;host=127.0.0.1'; //连接MySQL数据库的DSN
　　$user = 'dbuser';//MySQL数据库的用户名
　　$password ='dbpass'; //MySQL数据库的密码
　　try {
　　$dbh = newPDO($dsn, $user, $password);
　　} catch(PDOException $e) {
　　echo '数据库连接失败： ' . $e->getMessage();
　　}
　　Php.ini配置文件中[pdo]下在加入下面文字
　　Pdo.dsn.ssw=”mysql:host=localhosot;dbname=malldb”;
　　try {
　　$dbh = new PDO(ssw,root, sswqzx);
　　} catch(PDOException $e) {
　　echo '数据库连接失败： ' . $e->getMessage();
　　}
　　//设置持久连接的选项数组作为最后一个参数,可以一起设置多个元素
　　$opt =array(PDO::ATTR_PERSISTENT => true);
　　try {
　　$db = newPDO('mysql:host=localhost;dbname=test'，'dbuser'，'passwrod',$opt);
　　} catch(PDOException $e) {
　　echo "数据库连接失败： " .$e->getMessage();
　　}
　　3、PDO与连接有关的选项
　　         try {
　　                   $pdo=new  PDO("mysql:host=localhost;dbname=malldb","root","123456",array(PDO::ATTR_AUTOCOMMIT=>false,PDO::ATTR_PERSISTENT=>1 ));
　　         }catch(PDOException $e) {
　　                   echo "数据库连接失败：".$e->getMessage();
　　                   exit;
　　         }
　　//var_dump($pdo);
　　//      $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,false);
　　
　　         echo "PDO是否关闭自动提交功能：".$pdo->getAttribute(PDO::ATTR_AUTOCOMMIT);
　　         echo "当前PDO的错误处理的模式：". $pdo->getAttribute(PDO::ATTR_ERRMODE);
　　         echo "表字段字符的大小写转换： ".$pdo->getAttribute(PDO::ATTR_CASE);
　　         echo "与连接状态相关特有信息： ".$pdo->getAttribute(PDO::ATTR_CONNECTION_STATUS);
　　         echo "空字符串转换为SQL的null：". $pdo->getAttribute(PDO::ATTR_ORACLE_NULLS);
　　         echo "应用程序提前获取数据大小：".$pdo->getAttribute(PDO::ATTR_PERSISTENT);
　　         echo "与数据库特有的服务器信息：".$pdo->getAttribute(PDO::ATTR_SERVER_INFO);
　　         echo "数据库服务器版本号信息：".$pdo->getAttribute(PDO::ATTR_SERVER_VERSION);
　　         echo "数据库客户端版本号信息：".$pdo->getAttribute(PDO::ATTR_CLIENT_VERSION);
　　4、PDO的错误处理模式
　　/*
　　setAttribute();
　　PDO::ATTR_ERRMODE;
　　1、默认的错误模式（不提示、我们看到问题、被忽视）
　　2、警告模式：PDO::ERRMODE_WARNING
　　3、异常的模式：PDO::ERRMODE_EXCEPTION
　　*/
　　try(
　　//创建对象
　　$pdo = newPDO("mysql:host=localhost;dbname=malldb","root","sswqzx");
　　//设置错误使用异常的模式
　　$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
　　)catch(PDOException $e){
　　echo"数据库链接失败".$e->getMessage();
　　exit;
　　}
　　try(
　　//使用PDO中的方法执行语句
　　$affected_rows = $pdo ->exec("delete from hello");
　　)catch(PDOException $e){
　　echo "错误".$e->getMessage();
　　}
　　5、使用PDO执行SQL语句
　　代码1：
　　/*
　　PDO中执行SQL语句的方法有二个主要的：
　　1、exec() 用来处理非结果集的: insert updatedelete create ....
　　返回影响的函数
　　2、query() 用来处理有结果集的语句: select descshow
　　set naees utf8;
　　$pdo -> query("set namesutf8");
　　$pdo -> exec("set namesutf8");
　　*/
　　try{
　　//创建对象
　　$pdo = new PDO("mysql:host=localhost;dbname=malldb","root","sswqzx");
　　//设置错误使用异常的模式
　　$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
　　}catch(PDOException $e){
　　echo"数据库链接失败".$e->getMessage();
　　exit;
　　}
　　try{
　　//使用PDO中的方法执行语句
　　$affected_rows = $pdo ->exec("insert into user(name,pass,sex,age,email)values('aa','bb','cc','20','ee@qq.com')");
　　echo $affected_rows."";
　　echo $pdo->lastinsertid();
　　}catch(PDOException $e){
　　echo "错误".$e->getMessage();
　　}
　　代码2：