PDO 用法学习「建议收藏」

PDO 用法学习「建议收藏」PDO:phpdataobject 数据库访问抽象层 基于驱动: 1、安装扩展php_pdo.dll 2、安装驱动php_pdo_mysql.dlllinux编译时参数:–with-pd

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

 

PDO: php data object
数据库访问抽象层

基于驱动:
1、安装扩展 php_pdo.dll
2、安装驱动 php_pdo_mysql.dll

linux 编译时参数:–with-pdo=mysql=/usr/local/mysql

三个类:
PDO类, 数据库连接有关(连接、执行sql)
PDOStatement 处理结果集
PDOException 异常处理类
一些常量

相比mysqli方法少,常量多

dsn:data source name(数据源) 包括 主机、库名、驱动名
#部分参数可以省略,参数没有顺序
mysql: #最短 会自动调取 php.in 中 mysql.default_host 参数信息

dsn示例:

mysql:host=localhost;port=3307;dbname=testdb
mysql:unix_socket=/tmp/mysql.sock;dbname=testdb

获取pdo对象

 

$dsn = "mysql:host=127.0.0.1;port=3306;dbname=test";
$opts = array(PDO::ATTR_AUTOCOMMIT=>0, PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION, PDO::ATTR_AUTOCOMMIT=>0 #关闭自动提交, PDO::ATTR_TIMEOUT => 3 #设置超时时间);
$pdo = new PDO($dsn, 'root', '', $opts);
ee($pdo->getAttribute(PDO::ATTR_AUTOCOMMIT)); // setAttribute 可以设置属性
$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);  #设置获取的方式 

 

执行sql语句: exec() 、query()、 perpare();

1、query用来处理有结果集的,如select, 返回 PDOStatement 对象,失败返回false(当为 PDO::ERRMODE_SILENT,这也是默认的值)
2、exec用来处理有返回影响行数的(int),如  insert(插入的行数)、 delete(删除的行数) 、update(和原数值不等才算), 失败返回false (当为 PDO::ERRMODE_SILENT,这也是默认的值)

3、prepare 执行所有sql,可以完全替代 query,exec的功能

错误报告是针对执行的sql出错时

PDO::ERRMODE_SILENT(0) :默认 不提示任何错误 ,连接时无论如何都会提示,只有在执行后面的方法时才会起作用
PDO::ERRMODE_WARNING(1) : 警告
PDO::ERRMODE_EXCEPTION(2):异常(推荐使用) 用try catch捕获,也可以手动抛出异常 new PDOException($message, $code, $previous)

 

#exec用法
try {
    $sql = "insert into limove(`id`, `name`, `order`) values(null, 'sjk', 1),(null, 'sjk',2)";
    $rows = $pdo->exec($sql);  //影响的条数 2
    $pdo->lastInsertId(); //最后插入的id,有多条时返回的是第一条的id
} catch (Exception $e) {
    ee($pdo->errorInfo());
}

 

#query方法同样也可以执行insert,delete 只是返回的结果集的格式
#同样 lastInsertId 照样也可以使用
$params = array (
                PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\'' ,
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        );
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;port=3306', 'root', '',$params);


$statement = "insert into card (id, json_str, f) values(null, 'ok', 2.3),(null, 'ok', 2.3)";

$flag = $pdo->query($statement);
ee($flag);

ee($pdo->lastInsertId());

PDOStatement Object
(
    [queryString] => insert into card (id, json_str, f) values(null, 'ok', 2.3),(null, 'ok', 2.3)
)

 

#query可以实现所有exec的功能
$params = array (
                PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\'' ,
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        );
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;port=3306', 'root', '',$params);


$statement = "insert into card. (id, json_str, f) values(null, 'ok', 2.3),(null, 'ok', 2.3)";
$statement = "select * from card";
$statement = "delete  from card where id = 625";
$statement = "update card set f=5 where id = 624";

$stmt = $pdo->query($statement); ee($stmt->rowCount());

 

 总结:

  1、query和exec都可以执行所有的sql语句,只是返回值不同而已。

  2、query可以实现所有exec的功能。

  3、当把select语句应用到 exec 时,总是返回 0

 注意:批量插入时,依次插入当遇到错误时后面的插入失败,但是前面的会插入成功。

预处理语句(prepare)示例,sql只编译一次,执行相同的sql效率会高。单个相比exec,query效率也高。

 

#prepare 在不恰当的位置调用用法可能会出异常

$params = array (
                PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\'' ,
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        );
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;port=3306', 'root', '',$params);
 

// $sql = "insert into card (id, json_str, f) values(null, 'ok', 2.3),(null, 'ok', 2.3)";
// $sql = "select * from card";
$sql = "delete  from card where id = 625";
// $sql = "update card set f=5 where id = 624";
// $sql = "show create table card";
// $sql = "desc card";

// $stmt = $pdo->query($sql);
// ee($stmt->fetchAll());
// ee($stmt);

$stmt = $pdo->prepare($sql);
$stmt->execute();
 ee($stmt->rowCount());
ee($stmt->fetch(pdo::FETCH_ASSOC));


Fatal error:  Uncaught exception 'PDOException' with message 'SQLSTATE[HY000]: General error' in E:\wamp\www\test\song.php:27
Stack trace:
#0 E:\wamp\www\test\song.php(27): PDOStatement->fetch(2)
#1 {main}
  thrown in E:\wamp\www\test\song.php on line 27

 

 

$dsn = "mysql:host=127.0.0.1;port=3306;dbname=test";
$opts = array(PDO::ATTR_AUTOCOMMIT=>0, PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION, PDO::ATTR_AUTOCOMMIT=>0);
try {
    $pdo = new PDO($dsn, 'root', '', $opts);
}catch(PDOException $e){
    echo $e->getMessage();
}


/* pdo中有两种占位符号
 *
*  ? 参数             --- 索引数组, 按索引顺序使用
*  名子参数           ----关联数组, 按名称使用,和顺序无关
*/


//准备好了一条语句,并入到服务器端,也已经编译过来了,就差为它分配数据过来
//同样适用于更新操作
$stmt=$pdo->prepare("insert into limove(`name`, `order`) values(:name,:order)");

//绑定参数,引用方式传递
$stmt->bindParam(":name", $name);
$stmt->bindParam(":order", $order);


// $stmt=$pdo->prepare("insert into limove(`name`, `order`) values(?, ?)"); //所有SQL都可执行

// //绑定参数,引用方式传递
// $stmt->bindParam(1, $name, PDO::PARAM_STR); #起始值为 1 
// $stmt->bindParam(2, $order, PDO::PARAM_INT);

#变量放到 bindParam 前后都可
$name="wwww";
$order = 1;

if($stmt->execute()){
    echo "执行成功";
    echo "最后插入的ID:".$pdo->lastInsertId();
}else{
    echo "执行失败!";
}

 

还支持执行时绑定

    #无序方式
    $stmt=$pdo->prepare("insert into shops(name, price, num, desn) values(:name,:price, :num, :desn)"); 
    $stmt->execute(array(":price"=>77, ":name"=>"kkk3", ":num"=>"453", ":desn"=>"aaaaaa3"));
 $stmt->execute(array(":price"=>77, ":name"=>"kkk3", ":num"=>"453", ":desn"=>"aaaaaa3"));

    #有序方式
    $stmt=$pdo->prepare("insert into shops(name, price, num, desn) values(?, ?, ?, ?)"); //所有SQL都可执行
    $stmt->execute(array("myname1", 11.2, 55, "very good"));
    $stmt->execute(array("myname1", 11.2, 55, "very good"));

 

 

获取结果

//获取结果
$stmt = $pdo->prepare("select * from limove where `order` = :order");
$stmt->execute(array(':order'=>8));

//设置获取的方式
$stmt->setFetchMode(PDO::FETCH_ASSOC);

$data = array();

//方式1
//$data = $stmt->fetchAll();

//方式2
while($row = $stmt->fetch(PDO::FETCH_ASSOC))
{
    $data[] = $row;
}
ee($data);

 

//bindColumn 把取出的值绑定到一个变量上
$stmt->bindColumn('name', $name);
$stmt->bindColumn(2, $sex); # 还可以根据顺序绑定,可以混合使用

 

#所有的条数,select insert delete update
$stmp->rowCount();

 

 

 

事务举例:

<?php
    try{
        $pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456", array(PDO::ATTR_AUTOCOMMIT=>0)); #一定要关闭自动提交
        $pdo->setAttribute(PDO::ATTR_ERRMODE,  PDO::ERRMODE_EXCEPTION); #开启异常模式
    }catch(PDOException $e){
        echo "数据库连接失败:".$e->getMessage();
        exit;
    }

    //执行SQL语句 exec() query()  prepare()
    //一是有结果集的query(), 执行select语句
    //exec()用来执行有影响行数的,update, delete insert, other
    //exec()返回的是影响的行数
    /*
     *
     * 事务处理
     *
     *   张三从李四那里买了一台 2000 元的电脑
     *
     *     从张三帐号中扣出 2000元
     *
     *     向李四账号中加入 2000元
     *
     *     从商品表中减少一台电脑
     *
     *     MyIsAM  InnoDB
     *
     */

    try{
        $pdo->beginTransaction();
        
        $price=500;

        $sql="update zhanghao set price=price-{$price} where id=1";

        $affected_rows=$pdo->exec($sql);

        if(!$affected_rows)
            throw new PDOException("张三转出失败");

        $sql="update zhanghao set price=price+{$price} where id=3";

        $affected_rows=$pdo->exec($sql);
            
        if(!$affected_rows) #发现问题手动抛出异常
            throw new PDOException("向李四转入失败");

        echo "交易成功!";
        $pdo->commit();
    }catch(PDOException $e){
        echo $e->getMessage();
        $pdo->rollback(); //只要捕获异常则回滚
    }
    
    //不管执行成功还是失败最后都要在关闭自动提交
    $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);
    
    //设置错误报告模式 ERRMODE_SILENT    ERRMODE_WARNING

 

 

user contribute comments 

/**
To avoid exposing your connection details should you fail to remember to catch any exception thrown by the PDO constructor you can use the following class to implicitly change the exception handler temporarily.
*/

Class SafePDO extends PDO {

    public static function exception_handler($e) {
        // Output the exception details
        die('Uncaught exception:'.$e->getMessage());
    }

    public function __construct($dsn, $username='', $password='', $driver_options=array()) {

        // Temporarily change the PHP exception handler while we . . .
        set_exception_handler(array(__CLASS__, 'exception_handler'));

        // . . . create a PDO object
        parent::__construct($dsn, $username, $password, $driver_options);

        // Change the exception handler back to whatever it was before
        restore_exception_handler();
    }

}

$dsn = 'mysql:host=127.0.0.1;dbname=tesst;port=3306';
$pdo = new SafePDO($dsn);

 

#占位符的无效使用
$stmt = $dbh->prepare("SELECT * FROM REGISTRY where name LIKE '%?%'");
$stmt->execute(array($_GET['name']));

// 占位符必须被用在整个值的位置
$stmt = $dbh->prepare("SELECT * FROM REGISTRY where name LIKE ?");
$stmt->execute(array("%$_GET[name]%"));

 

#开启两次失误会报错,下面解决了这个问题
class Database extends \\PDO 
{ 
    protected $transactionCounter = 0; 
    function beginTransaction() 
    { 
        if(!$this->transactionCounter++) 
            return parent::beginTransaction(); 
       return $this->transactionCounter >= 0; 
    } 

    function commit() 
    { 
       if(!--$this->transactionCounter) 
           return parent::commit(); 
       return $this->transactionCounter >= 0; 
    } 

    function rollback() 
    { 
        if($this->transactionCounter >= 0) 
        { 
            $this->transactionCounter = 0; 
            return parent::rollback(); 
        } 
        $this->transactionCounter = 0; 
        return false; 
    } 
//... 
} 

 

#模拟事务的嵌套使用,执行commit时会提交所有的事务
class Database extends PDO
{

    protected $transactionCount = 0;

    public function beginTransaction()
    {
        if (!$this->transactionCounter++) {
            return parent::beginTransaction();
        }
        $this->exec('SAVEPOINT trans'.$this->transactionCounter);
        return $this->transactionCounter >= 0;
    }

    public function commit()
    {
        if (!--$this->transactionCounter) {
            return parent::commit();
        }
        return $this->transactionCounter >= 0;
    }

    public function rollback()
    {
        if (--$this->transactionCounter) {
            $this->exec('ROLLBACK TO trans'.$this->transactionCounter + 1);
            return true;
        }
        return parent::rollback();
    }
    
}

 

 

/**
 * If you do not fetch all of the data in a result set before issuing your next call to PDO::query(), your call may fail. Call PDOStatement::closeCursor() to release the database resources associated with the PDOStatement object before issuing your next call to PDO::query().
 */
$dsn = 'mysql:host=127.0.0.1;dbname=test;port=3306';
$params = array (
                PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\'' ,
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::MYSQL_ATTR_USE_BUFFERED_QUERY =>0, //@warn
        );
$pdo = new PDO($dsn, 'root', '',$params);


$sql_1 = "select * from card";

$stmt = $pdo->query($sql_1);
$one = $stmt->fetch();
ee($one);

// $stmt->closeCursor();

$sql_2 = "select * from card";

$stmt = $pdo->query($sql_2);
$all = $stmt->fetchAll();
ee($all);

 

/**
获取select的条数,需要公用一个数据库链接才行,会受到limit的影响
MySQL does not seem to return anything in rowCount for a select statement, but you can easily and efficiently get the row count as follows:

*/
class db extends PDO {
  public function last_row_count() {
    return $this->query("SELECT FOUND_ROWS()")->fetchColumn();
  }
}

$myDb = new db('mysql:host=myhost;dbname=mydb', 'login', 'password' );

Then, after running your query:

if ( $myDb->last_row_count() == 0 ) {
  echo "Do something!";
  }

 

更好的获取条数

$db = new PDO(DSN...); 
$db->setAttribute(array(PDO::MYSQL_USE_BUFFERED_QUERY=>TRUE)); 
$rs  = $db->query('SELECT SQL_CALC_FOUND_ROWS * FROM table LIMIT 5,15'); 
$rs1 = $db->query('SELECT FOUND_ROWS()'); 
$rowCount = (int) $rs1->fetchColumn(); 

 

 

/*  使用一个数组的值执行一条含有 IN 子句的预处理语句 */
$params = array(1, 21, 63, 171);
/*  创建一个填充了和params相同数量占位符的字符串 */
$place_holders = implode(',', array_fill(0, count($params), '?'));

/*
    对于 $params 数组中的每个值,要预处理的语句包含足够的未命名占位符 。
    语句被执行时, $params 数组中的值被绑定到预处理语句中的占位符。
    这和使用 PDOStatement::bindParam() 不一样,因为它需要一个引用变量。
    PDOStatement::execute() 仅作为通过值绑定的替代。
*/
$sth = $dbh->prepare("SELECT id, name FROM contacts WHERE id IN ($place_holders)");
$sth->execute($params);

 

/**
$placeHolder
*/
data = ['a'=>'foo','b'=>'bar'];

$keys = array_keys($data);
$fields = '`'.implode('`, `',$keys).'`';

#here is my way 
$placeholder = substr(str_repeat('?,',count($keys),0,-1));

$pdo->prepare("INSERT INTO `baz`($fields) VALUES($placeholder)")->execute(array_values($data));

 

 

1、事务通常是通过把一批更改“积蓄”起来然后使之同时生效而实现的;这样做的好处是可以大大地提供这些更改的效率。

2、当脚本结束或连接即将被关闭时,如果尚有一个未完成的事务,那么 PDO 将自动回滚该事务。这种安全措施有助于在脚本意外终止时避免出现不一致的情况——如果没有显式地提交事务,那么假设是某个地方出错了,所以执行回滚来保证数据安全。

3、预处理语句 的好处
1、查询仅需解析(或预处理)一次,但可以用相同或不同的参数执行多次。 2、提供给预处理语句的参数不需要用引号括起来,驱动程序会自动处理。如果应用程序只使用预处理语句,可以确保不会发生S QL 注入。(然而,如果查询的其他部分是由未转义的输入来构建的,则仍存在 SQL 注入的风险)。

4、在事务中,lastInsertId 应该用在 commit之前,否则会得到 0

5、对于大多数数据库,PDOStatement::rowCount() 不能返回受一条 SELECT 语句影响的行数。替代的方法是,使用 PDO::query() 来发出一条和原打算中的SELECT语句有相同条件表达式的 SELECT COUNT(*) 语句,然后用 PDOStatement::fetchColumn() 来取得返回的行数。这样应用程序才能正确执行。

6、quote 增加引号

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/167196.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • C++面试题之虚函数(表)实现机制

    C++面试题之虚函数(表)实现机制前言大家都应该知道C++的精髓是虚函数吧?虚函数带来的好处就是:可以定义一个基类的指针,其指向一个继承类,当通过基类的指针去调用函数时,可以在运行时决定该调用基类的函数还是继承类的函数.虚函数是实现多态(动态绑定)/接口函数的基础.可以说:没有虚函数,C++将变得一无是处!既然是C++的精髓,那么我们有必要了解一下她的实现方式吗?有必要!既然C++是从C语言的基础上发展而来…

  • Java中的List与Set转换「建议收藏」

    Java中的List与Set转换「建议收藏」一、List列表与Set列表的区别List列表是有序、可以重复、线程不安全的列表,Set是无序、不能重复、线程不安全的列表。但List和Set可以通过方法来转换为线程安全的,加互斥锁。Set<Long>set=newHashSet<>();//转换为线程安全的集合Collections.synchronizedSet(…

  • assertthat和assertequals的区别_assertEquals

    assertthat和assertequals的区别_assertEqualsASSERT_VALID()与ASSERT()异同ASSERT()是MFC库中的断言,用法是ASSERT(布尔表达式).ASSERT宏用于确保参数内的表达式正确,如果表达式为false,则会显示一个消息对话框,其中有源文件的名字和当前行号,用户可以

  • ubuntu域名服务器配置_linux虚拟主机配置

    ubuntu域名服务器配置_linux虚拟主机配置像我一样刚开始接触Ubuntu系统朋友不知道怎么配置虚拟主机的可以看一下,这里完整记录了我配置虚拟主机的全部过程

  • delphi xe5 激活成功教程

    delphi xe5 激活成功教程通过测试可用,RADStudioXE5激活成功教程补丁及方法第一步,将下载下来的“delphicbuilder_xe5_win.iso”解压到任意盘,任意目录。http://altd.embarcadero.com/download/radstudio/xe5/delphicbuilder_xe5_win.iso第二步,将“免序列号安装授权文件”文件夹中的“RADS

  • Apache 配置ssl证书

    Apache 配置ssl证书1.首先确保已经安装了apacherpm-qa|grephttpd:查询版本,如果能查出版本则说明已经安装了2.安装ssl模块#yuminstallmod_ssl-yPs:安装完成后,会在/etc/httpd/conf.d/下生成一个ssl.conf配置文件。3.新建一个目录用来放ssl证书文件#mkdir/etc/httpd/ssl/上传证书到此目录下4.编辑修改ssl配置文件DocumentRoot”/var…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号