php程序员PHP经验分享

PDO 连接 MySQL 实例

2017-09-02  本文已影响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

上一篇 下一篇

猜你喜欢

热点阅读