美文网首页php程序员PHP经验分享
PDO 连接 MySQL 实例

PDO 连接 MySQL 实例

作者: 胖先森 | 来源:发表于2017-09-02 10:51 被阅读1854次

    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

    相关文章

      网友评论

        本文标题：PDO 连接 MySQL 实例

        本文链接：https://www.haomeiwen.com/subject/fhgljxtx.html

        延伸阅读

        深度阅读

        • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

        栏目导航

        热点阅读

        php

        程序员

        PHP经验分享

        关于我们|服务条款|联系我们|PDO 连接 MySQL 实例|投稿指南|网站地图|RSS订阅|排版工具|手机版

        提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

        Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

        备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

        本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

        所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！