PDO 连接 MySQL 实例

PDO 连接 MySQL 实例

PDO 应用在 12 种不同数据库中,所以我们直接只用PDO连接数据库,一劳永逸!在这里我们需要根据PHP的手册中进行学习.

<?php
  const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
  const USER_NAME = "root";
  const PASSWORD = "";

  try{
      $conn = new PDO(DSN,USER_NAME,PASSWORD);

      echo "连接成功";
  }catch (PDOException $e){
      echo $e->getMessage();
  }finally{
      $conn = null;
      echo "关闭数据库连接";
  }
?>

注意在以上 PDO 实例中我们已经指定了数据库 (myDB)。PDO 在连接过程需要设置数据库名。如果没有指定，则会抛出异常。

PDO的属性获取和设置

异常错误处理的模式PDO::ATTR_ERRMODE：错误报告

  1. 默认的错误模式(不提示,我们看到的问题会被自动忽略,仅设置错误代码)
  2. 警告模式 : PDO::ERRMODE_WARNING
  3. 异常模式(推荐) PDO::ERRMODE_EXCEPTION: 抛出 exceptions 异常。

使用PDO执行SQL语句

执行SQL语句的方法主要有两种:

  1. exec() 主要用来处理非结果集的 insert update delete create 等
  2. query() 主要用来处理有结果集的语句 select desc show等

插入数据

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES ('wukong','123','悟空')";
        $rows = $pdo->exec($sql);
        //返回主键方法
        echo "影响的行数为:".$rows.",获取主键ID:".$pdo->lastInsertId();

    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

插入多条SQL语句

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

        //4.关闭自动提交
        $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,0);

        //5.开启事务
        $pdo->beginTransaction();
        //设置多条SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES ('bajie','123','八戒')";
        $rows = $pdo->exec($sql);
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES ('tangseng','ddddd','唐僧')";
        $rows = $pdo->exec($sql);
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES ('shaseng','123','沙僧')";
        $rows = $pdo->exec($sql);

        //6.事务提交
        $pdo->commit();

        //7.回复自动提交
        $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,1);

    }catch (PDOException $e){
        $pdo->rollBack();
        echo $e->getMessage();
        exit;
    }

?>

提示： 使用 PDO 的最大好处是在数据库查询过程出现问题时可以使用异常类来 处理问题。如果 try{ } 代码块出现异常，脚本会停止执行并会跳到第一个 catch(){ } 代码块执行代码。 在以上捕获的代码块中我们输出了 SQL 语句并生成错误信息。

添加大量数据参考博文: http://www.cnblogs.com/zlx7/p/4816247.html

PDO 中的预处理语句

索引数组绑定数据

我们在 PDO 中使用了预处理语句并绑定参数:

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES (?,?,?)";
        $ps = $pdo->prepare($sql);
        //数据绑定
        $ps->bindParam(1,$account);
        $ps->bindParam(2,$password);
        $ps->bindParam(3,$user_name);

        //设置数据
        $account = "liu'bei";
        $password="1234567890abcdefg";
        $user_name="刘备";

        //执行SQL语句
        $ps->execute();


        //返回主键方法
        echo "获取主键ID:".$pdo->lastInsertId();

    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

索引数组绑定数据 - 简写方式

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES (?,?,?)";
        $ps = $pdo->prepare($sql);

        //执行SQL语句  --- 简写方式
        $ps->execute(array("zhangfei","123456","张飞"));


        //返回主键方法
        echo "获取主键ID:".$pdo->lastInsertId();

    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

关联数组绑定数据

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES (:account,:pwd,:user_name)";
        $ps = $pdo->prepare($sql);
        //数据绑定
        $ps->bindParam("account",$account);
        $ps->bindParam("pwd",$password);
        $ps->bindParam("user_name",$user_name);

        //设置数据
        $account = "caochao";
        $password="1234567890abcdefg";
        $user_name="曹操";

        //执行SQL语句
        $ps->execute();


        //返回主键方法
        echo "获取主键ID:".$pdo->lastInsertId();

    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

关联数组绑定数据 -- 简写方式

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES (:account,:password,:user_name)";
        $ps = $pdo->prepare($sql);

        //执行SQL语句  --- 简写方式
        $ps->execute(array("account"=>"guanyu","password"=>"123123","user_name"=>"关羽"));


        //返回主键方法
        echo "获取主键ID:".$pdo->lastInsertId();

    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

简化客户端传递数据 - 有约定

客户端传递的数据名称和关联数组的KEY保持一致即可

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "INSERT INTO sys_user(account,password,user_name) VALUES (:account,:password,:user_name)";
        $ps = $pdo->prepare($sql);

        //执行SQL语句
        $ps->execute($_GET);


        //返回主键方法
        echo "获取主键ID:".$pdo->lastInsertId();

    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

演示图解

PDO 中的预处理查询语句

列表:返回数组形式

<?php
    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "SELECT user_id,account,password,user_name FROM sys_user";
        $ps = $pdo->prepare($sql);
        //执行SQL语句
        $ps->execute();

        //可以设置结果集的模式,默认情况下支持索引和关联两种形式
        $ps->setFetchMode(PDO::FETCH_NUM);
        
        echo "<table border='1' width='300' align='center'>";
        while(list($user_id,$account,$password,$user_name) = $ps -> fetch()){
            echo "<tr>";
            echo "<td>".$user_id."</td>";
            echo "<td>".$account."</td>";
            echo "<td>".$password."</td>";
            echo "<td>".$user_name."</td>";
            echo "</tr>";
        }

        echo "</table>";

        /*echo "显示全部数据";
        echo "<hr/>";

        echo "<pre>";
        print_r($ps->fetchAll());
        echo "</pre>";*/



    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

列表:存储为一个对象

<?php
    require_once "User.class.php";


    const DSN = "mysql:host=127.0.0.1:3306;dbname=shxt";
    const USER_NAME = "root";
    const PASSWORD = "";

    try{
        //1.创建PDO对象
        $pdo = new PDO(DSN,USER_NAME,PASSWORD);
        //2.设置编码格式
        $pdo->exec("SET names utf8");
        //3.设置错误使用的异常模式
        $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    }catch (PDOException $e){
        echo $e->getMessage();
        exit;
    }

    try{
        //使用PDO中的方法执行SQL语句
        $sql = "SELECT user_id,account,password,user_name FROM sys_user";
        $ps = $pdo->prepare($sql);
        //执行SQL语句
        $ps->execute();

        //存储为一个对象
        $user = new User();
        $ps->setFetchMode(PDO::FETCH_INTO,$user);

        echo "<table border='1' width='300' align='center'>";
        while($ps -> fetch()){
            echo "<tr>";
            echo "<td>".$user->getUserId()."</td>";
            echo "<td>".$user->getAccount()."</td>";
            echo "<td>".$user->getPassword()."</td>";
            echo "<td>".$user->getUserName()."</td>";
            echo "</tr>";
        }

        echo "</table>";

        /*echo "显示全部数据";
        echo "<hr/>";

        echo "<pre>";
        print_r($ps->fetchAll());
        echo "</pre>";*/



    }catch (PDOException $e){
        echo "错误原因为:".$e->getMessage();
        exit;
    }

?>

User.class.php

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2017/9/2
 * Time: 10:38
 */

class User
{

    private $user_id;
    private $account;
    private $password;
    private $user_name;
    //省略getter和setter方法

}

推荐文章 : https://sjolzy.cn/PDO-query-results-achieved-in-many-ways.html

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 194,242评论 5赞 459
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 81,769评论 2赞 371
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 141,484评论 0赞 319
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 52,133评论 1赞 263
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 61,007评论 4赞 355
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 46,080评论 1赞 272
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 36,496评论 3赞 381
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 35,190评论 0赞 253
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 39,464评论 1赞 290
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,549评论 2赞 309
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,330评论 1赞 326
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 32,205评论 3赞 312
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 37,567评论 3赞 298
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,889评论 0赞 17
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,160评论 1赞 250
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 41,475评论 2赞 341
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 40,650评论 2赞 335

推荐阅读更多精彩内容

  • pdo类
    pdo类PDO是一个“数据库访问抽象层”，作用是统一各种数据库的访问接口，与mysql和mysqli的函数库相比，...
    桖辶殇阅读 846评论 0赞 0
  • Java初级面试题
    1. Java基础部分 基础部分的顺序：基本语法，类相关的语法，内部类的语法，继承相关的语法，异常的语法，线程的语...
    子非鱼_t_阅读 31,493评论 18赞 399
  • MarkDown
    1. 简介 1.1 什么是 MyBatis ？ MyBatis 是支持定制化 SQL、存储过程以及高级映射的优秀的...
    笨鸟慢飞阅读 5,398评论 0赞 4
  • [3/4]我所经历的大数据平台发展史（三）：互联网时代 • 上篇
    //我所经历的大数据平台发展史（三）：互联网时代 • 上篇http://www.infoq.com/cn/arti...
    葡萄喃喃呓语阅读 51,149评论 10赞 200
  • 中秋——真正快乐
    阖家团圆，中秋快乐，今天选择这样一个特殊的日子开始我的第一篇文章。国庆中秋两相撞，放假的天数也很讨喜，我们总说国庆...
    宝宝Bling阅读 174评论 0赞 1