用PHP的PDO方法操作MySQL数据库方法(查询 更新 删除)

全屏阅读
  • 基本信息
  • 作者：
  • 作者已发布：924篇文章
  • 发布时间：2021年03月23日 23:14:36
  • 所属分类：Mysql优化, PHP+MySql
  • 阅读次数：1922次阅读
  • 标签：

用PHP连接MYSQL数据库有3种方法：

本文将举详细例子向大家展示PHP是如何使用MySQL原生API、MySQLi面向过程、MySQLi面向对象、PDO操作MySQL数据库的。

为了后面的测试，先建立数据库表test。包含表名user,score。

CREATE TABLE `user` (  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,  `name` varchar(25) NOT NULL DEFAULT '',  `gender` tinyint(1) NOT NULL DEFAULT '1',  `age` int(11) NOT NULL DEFAULT '0',  `flag` tinyint(1) NOT NULL DEFAULT '1',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;/*Data for the table `user` */insert  into `user`(`id`,`name`,`gender`,`age`,`flag`) values (1,'allen',1,20,1),(2,'alice',2,18,1),(3,'bob',1,21,1),(4,'dave',1,25,1),(5,'eve',2,20,1),(6,'joy',1,21,1),(7,'june',1,23,1),(8,'linda',2,22,1),(9,'lisa',2,22,1),(10,'liz',2,23,1);CREATE TABLE `score` (  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,  `uid` int(11) NOT NULL DEFAULT '0',  `score` int(11) NOT NULL DEFAULT '0',  `flag` tinyint(1) NOT NULL DEFAULT '1',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;/*Data for the table `score` */insert  into `score`(`id`,`uid`,`score`,`flag`) values (1,1,89,1),(2,2,98,1),(3,3,78,1),(4,4,88,1),(5,5,99,1),(6,6,89,1),(7,7,90,1),(8,8,93,1),(9,9,95,1),(10,10,99,1);

使用原生 MySQL API#

MySQL API 大部分扩展自 PHP 5.5.0 起已废弃，并在将来会被移除。应使用 MySQLi或 PDO_MySQL 扩展来替换之。

配置并连接数据库

<?php//配置$db = array(    'dsn' => 'mysql:host=localhost;dbname=test',    'host' => 'localhost',    'dbname' => 'test',    'username' => 'root',    'password' => '123456',    'charset' => 'utf8',
);//建立连接$link = mysql_connect($db['host'], $db['username'], $db['password']) or die( 'Could not connect: '  .  mysql_error ());//选择数据库mysql_select_db($db['dbname'], $link) or die ( 'Can\'t use foo : '  .  mysql_error ($link));

mysql_set_charset($db['charset'], $link);

查询并遍历数据：

//普通查询，返回资源//mysql_query() 仅对 SELECT，SHOW，DESCRIBE, EXPLAIN 和其他语句 语句返回一个 resource ，如果查询出现错误则返回 FALSE 。 $result  = mysql_query('select * from user', $link);//取得结果集中行的数目 echo $num_rows  =  mysql_num_rows ( $result );while ($row = mysql_fetch_array($result, MYSQL_NUM)){
    print_r($row);
}

其中：

mysql_fetch_array($result) //第二个参数支持：MYSQL_ASSOC，MYSQL_NUM 和 MYSQL_BOTH。默认是MYSQL_BOTH。//可以直接使用下列代替：mysql_fetch_assoc($result) //返回关联类型mysql_fetch_row($result) //返回Num类型mysql_fetch_object($result) //返回对象类型//另外：mysql_fetch_field($result) //返回一个包含字段信息的对象

注意：上面一系列方法在运行后将返回结果集的下一行，如果没有更多行则返回 FALSE 。适合使用while循环遍历，遍历完停止。

新增：

//如果不给出字段名，VALUES部分要按顺序全部给出值
//建议使用sprintf方式
$insert_sql = sprintf("insert into user values('0', '%s', '%d', '%d', '%d')", 'test', 1, 22, 1);//不省略字段只需赋值给需要的字段，其它字段默认
$insert_sql = sprintf("insert into user(name,gender,age) values('%s', '%d', '%d')", 'test', 1, 22);

mysql_query($insert_sql) or die(mysql_error());//新增的记录数
echo $affected_rows = mysql_affected_rows(); // 1//返回新增的id
echo $id = mysql_insert_id(); // 13

更新：

mysql_query(sprintf("update user set name = '%s' where id = %d", 'test2', 11));

//更新的记录数
echo $affected_rows = mysql_affected_rows();

删除：

mysql_query(sprintf("delete from user where id = %d", 11));

//删除的记录数
echo $affected_rows = mysql_affected_rows();

如何判断成功：

mysql_num_rows($result) //返回结果集中行的数目。此命令仅对 SELECT 语句有效
mysql_affected_rows($link) //取得前一次 MySQL 操作所影响的记录行数，仅对INSERT，UPDATE 或 DELETE 有效

关闭连接：

mysql_close($link);

原生 MySQL API里$link都是可以省略的，如果没有填写，默认使用上一次的连接。建议写上。

使用MySQLi类#

MySQLi面向过程#

与原生 MySQL API基本用法是一样的，只需将mysql替换成mysqli且把$link放在方法的第一个参数就行了。

对比看看：

$result  = mysql_query('select * from user', $link);$result  = mysqli_query($link, 'select * from user');$row = mysql_fetch_assoc($result)$row = mysqli_fetch_assoc($result)

全部代码：

<?php

$db = array(    'dsn' => 'mysqli:host=localhost;dbname=test',    'host' => 'localhost',    'port' => '3306',    'dbname' => 'test',    'username' => 'root',    'password' => '123456',    'charset' => 'utf8',
);//mysqli过程化风格

//建立连接:相比mysql_connect可以直接选择dbname、port
//$link = mysqli_connect($db['host'], $db['username'], $db['password'], $db['dbname'], $db['port']);
$link = mysqli_connect($db['host'], $db['username'], $db['password']) or die( 'Could not connect: '  .  mysqli_error ($link));//选择数据库
mysqli_select_db($link, $db['dbname']) or die ( 'Can\'t use foo : '  .  mysqli_error ($link));

mysqli_set_charset($link, $db['charset']);//数据库查询

//普通查询，返回资源
$result  = mysqli_query($link, 'select * from user');//取得结果集中行的数目 
$num_rows  =  mysqli_num_rows ( $result );//新增：
/*
$insert_sql = sprintf("insert into user(name,gender,age) values('%s', '%d', '%d')", 'test', 1, 22);
mysqli_query($link, $insert_sql) or die(mysqli_error($link));

echo $affected_rows = mysqli_affected_rows($link);
echo $id = mysqli_insert_id($link);

*/

//更新
/*
mysqli_query($link, sprintf("update user set name = '%s' where id = %d", 'test2', 12));

echo $affected_rows = mysqli_affected_rows($link);
*/

//删除
/*
mysqli_query($link, sprintf("delete from user where id = %d", 12));

echo $affected_rows = mysqli_affected_rows($link);
*/

//遍历结果集
while ($row = mysqli_fetch_assoc($result)){
    echo '<pre>';
    print_r($row);
}

//关闭数据库
mysqli_close($link);

相比原生 MySQL API，面向过程化的MySQLi里的$link是不可以省略的，如果没有填写，会抛出一个警告。由上面代码也可以看出，面向过程化的MySQLi与原生 MySQL API基本一致。

MySQLi面向对象#

MySQLi还支持面向对象编程，推荐使用。

<?php$db = array(    //同上);//mysqli对象化风格//建立连接$link = new mysqli($db['host'], $db['username'], $db['password'], $db['dbname'], $db['port']);if ( $link -> connect_error ) {    die( 'Connect Error ('  .  $link -> connect_errno  .  ') '
        .  $link -> connect_error );
}//选择数据库//$link->select_db($link, $db['dbname']);//设置字符集$link->set_charset($db['charset']);//查询$result  = $link->query('select * from user') or die($link->errno . ':' .$link->error);//取得结果集中行的数目 echo $num_rows  =  $result->num_rows .'<br/>'; //14//新增：/*
$insert_sql = sprintf("insert into user(name,gender,age) values('%s', '%d', '%d')", 'test', 1, 22);
$link->query($insert_sql);

echo $affected_rows = $link->affected_rows .'<br/>'; //1
echo $id = $link->insert_id .'<br/>';  //14
*///更新/*
$link->query(sprintf("update user set name = '%s' where id = %d", 'test2', 13));

echo $affected_rows = $link->affected_rows .'<br/>'; //1
*///删除/*
$link->query(sprintf("delete from user where id = %d", 13));

echo $affected_rows = $link->affected_rows .'<br/>'; //1
*///遍历结果集while ($row = $result->fetch_assoc()){    echo '<pre>';
    print_r($row);
}/* 释放结果集 */  $link -> free ();//关闭数据库$link -> close();

比较重要的是MySQLi类和mysqli_result类，前者用于发送查询，后者用于从结果集返回数据。

使用PDO#

不管是使用原生的MySQL API，还是MySQLi，都还是有缺陷的。
1、不支持事务机制；
2、仅支持MySQL，不能使用其它数据库。
3、不安全，可能有注入风险
4、不支持异常处理

PHP的PDO扩展巧妙的解决了这些问题。

PDO使用dsn连接，支持众多类型的数据库，如mysql,postgresql,oracle,mssql等。

PDO(php data object)扩展类库为php访问数据库定义了轻量级的、一致性的接口,它提供了一个数据库访问抽象层。这样,无论你使用什么数据库,都可以通过一致的函数执行查询和获取数据。

PDO大大简化了数据库的操作并能够屏蔽不同数据库之间的差异，使用pdo可以很方便地进行跨数据库程序的开发,以及不同数据库间的移植,是将来php在数据库处理方面的主要发展方向。

<?php$db = array(    'dsn' => 'mysql:host=localhost;dbname=test;port=3306;charset=utf8',    'host' => 'localhost',    'port' => '3306',    'dbname' => 'test',    'username' => 'root',    'password' => '123456',    'charset' => 'utf8',
);//连接$options = array(
    PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, //默认是PDO::ERRMODE_SILENT, 0, (忽略错误模式)
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认是PDO::FETCH_BOTH, 4);try{
    $pdo = new PDO($db['dsn'], $db['username'], $db['password'], $options);
}catch(PDOException $e){    die('数据库连接失败:' . $e->getMessage());
}//或者更通用的设置属性方式://$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);    //设置异常处理方式//$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);   //设置默认关联索引遍历echo '<pre/>';//1 查询//1)使用query$stmt = $pdo->query('select * from user limit 2'); //返回一个PDOStatement对象//$row = $stmt->fetch(); //从结果集中获取下一行，用于while循环$rows = $stmt->fetchAll(); //获取所有$row_count = $stmt->rowCount(); //记录数，2//print_r($rows);echo '<br>';//2)使用prepare 推荐!$stmt = $pdo->prepare("select * from user where name = :name and age = :age ");
$stmt->execute(array(    ":name" => "test",    ":age" => 22));  //执行一条预处理语句 .成功时返回 TRUE, 失败时返回 FALSE $rows = $stmt->fetchAll();
print_r($rows);//2 新增、更新、删除//1)普通操作//$count  =  $pdo->exec("insert into user(name,gender,age)values('test',2,23)"); //返回受影响的行数 //echo $pdo->lastInsertId();//$count  =  $pdo->exec("update user set name='test2' where id = 15"); //返回受影响的行数//$count  =  $pdo->exec("delete from  user where id = 15"); //返回受影响的行数//2)使用prepare 推荐!/*
$stmt = $pdo->prepare("insert into user(name,gender,age)values(:name,:gender,:age)");
$stmt->execute(array(
    ":name" => "test",
    ":gender" => 1,
    ":age" => 22
));
*/

pdo::query()方法
当执行返回结果集的select查询时,或者所影响的行数无关紧要时,应当使用pdo对象中的query()方法.
如果该方法成功执行指定的查询,则返回一个PDOStatement对象.
如果使用了query()方法,并想了解获取数据行总数,可以使用PDOStatement对象中的rowCount()方法获取.

pdo::exec()方法
当执行insert,update,delete没有结果集的查询时,使用pdo对象中的exec()方法去执行.
该方法成功执行时,将返回受影响的行数.注意,该方法不能用于select查询.

PDO事务：

$pdo->beginTransaction();//开启事务处理try{	//PDO预处理以及执行语句...
	
	$pdo->commit();//提交事务}catch(PDOException $e){
	$pdo->rollBack();//事务回滚
	
	//相关错误处理
	throw $e;
}

先建立数据库。复制代码到TXT文件，然后另存为'建立数据库.txt' 最后修改为'建立数据库.sql',最后用navicat运行数据库文件。就建好数据库了。

代码如下：

CREATE TABLE `user` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(25) NOT NULL DEFAULT '',
  `gender` tinyint(1) NOT NULL DEFAULT '1',
  `age` int(11) NOT NULL DEFAULT '0',
  `flag` tinyint(1) NOT NULL DEFAULT '1',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;
 
/*Data for the table `user` */
 
insert  into `user`(`id`,`name`,`gender`,`age`,`flag`) values (1,'allen',1,20,1),(2,'alice',2,18,1),(3,'bob',1,21,1),(4,'dave',1,25,1),(5,'eve',2,20,1),(6,'joy',1,21,1),(7,'june',1,23,1),(8,'linda',2,22,1),(9,'lisa',2,22,1),(10,'liz',2,23,1);

然后新建PHP文件。pdo.php

<?php
 
$db = array(
    'host' => '127.0.0.1',         //设置服务器地址
    'port' => '3306',              //设端口 
    'dbname' => 'test',             //设置数据库名      
    'username' => 'root',           //设置账号
    'password' => 'yangji0321',      //设置密码
    'charset' => 'utf8',             //设置编码格式
    'dsn' => 'mysql:host=127.0.0.1;dbname=test;port=3306;charset=utf8',   //这里不知道为什么，也需要这样再写一遍。
);
 
//连接
$options = array(
    PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, //默认是PDO::ERRMODE_SILENT, 0, (忽略错误模式)
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认是PDO::FETCH_BOTH, 4
);
 
try{
    $pdo = new PDO($db['dsn'], $db['username'], $db['password'], $options);
}catch(PDOException $e){
    die('数据库连接失败:' . $e->getMessage());
}
 
//或者更通用的设置属性方式:
//$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);    //设置异常处理方式
//$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);   //设置默认关联索引遍历
 
echo '<pre/>';
 
//1 查询
 
//1)使用query
$stmt = $pdo->query('select * from user limit 2'); //返回一个PDOStatement对象
 
//$row = $stmt->fetch(); //从结果集中获取下一行，用于while循环
$rows = $stmt->fetchAll(); //获取所有
 
$row_count = $stmt->rowCount(); //记录数，2
print_r($rows);
 
 
 
 
 
 
 
echo '<br>';
 
//2)使用prepare 推荐!
$stmt = $pdo->prepare("select * from user where name = ? and age = ? ");
$stmt->bindValue(1,'allen');
$stmt->bindValue(2,20);
$stmt->execute();  //执行一条预处理语句 .成功时返回 TRUE, 失败时返回 FALSE 
$rows = $stmt->fetchAll();
$row_count = $stmt->rowCount(); //记录数，2
print_r($rows);
print_r($row_count);
 
 
 
echo '<br>';
 
 
 
 
//2 新增、更新、删除
//A.1)普通操作
//$count  =  $pdo->exec("insert into user(name,gender,age)values('test',2,23)"); //返回受影响的行数 
//echo $pdo->lastInsertId();
 
//$count  =  $pdo->exec("update user set name='test2' where id = 15"); //返回受影响的行数
//$count  =  $pdo->exec("delete from  user where id = 15"); //返回受影响的行数
 
 
//A.2)使用prepare 推荐!
 
$stmt = $pdo->prepare("insert into user(name,gender,age)values(?,?,?)");
$stmt->bindValue(1, 'test');
$stmt->bindValue(2, 2);
$stmt->bindValue(3, 23);
$stmt->execute();
$count = $stmt->rowCount();//受影响行数
echo 'prepare方法影响行数：'.$count;  
echo '<br>';
 
 
//A.3)使用prepare 批量新增
 
$stmt = $pdo->prepare("insert into user(name,gender,age)values(?,?,?)");
$stmt->bindParam(1, $name);
$stmt->bindParam(2, $gender);
$stmt->bindParam(3, $age);
 
$data = array(
    array('t1', 1, 22),
    array('t2', 2, 23),
);
 
foreach ($data as $vo){
    list($name, $gender, $age) = $vo;
    $stmt->execute();
}
 
 
 
 
//B)更新操作
echo '<br>';
 
$stmt = $pdo->prepare("UPDATE `user` SET `age`=? WHERE (`name`= ? )");
$stmt->bindValue(1, '20');
$stmt->bindValue(2, 'allen');
$num = $stmt->execute();
$count = $stmt->rowCount();//受影响行数
echo '更新操作影响行数：'.$count;  
 
 
 
 
 
 
 
 
 
//删除操作
$stmt = $pdo->prepare("DELETE FROM `user` WHERE (`name`= ? )");
$stmt->bindValue(1, 't1');
$num = $stmt->execute();
$count = $stmt->rowCount();//受影响行数
echo '删除操作影响行数：'.$count;  
 
 
 
 
# 【示例5：统计数据】：统计company表有多少条数据
echo '<br>';
 
$num = $pdo->query("select count(*) from user");
$count = $num->fetchColumn();
echo '共有数据：【'.$count.'】条';
 
 
 
 
?>
 
 
pdo::query()方法
当执行返回结果集的select查询时,或者所影响的行数无关紧要时,应当使用pdo对象中的query()方法.
如果该方法成功执行指定的查询,则返回一个PDOStatement对象.
如果使用了query()方法,并想了解获取数据行总数,可以使用PDOStatement对象中的rowCount()方法获取.
 
pdo::exec()方法
当执行insert,update,delete没有结果集的查询时,使用pdo对象中的exec()方法去执行.
该方法成功执行时,将返回受影响的行数.注意,该方法不能用于select查询.
 
 
 
 
PDO事务：
 
$pdo->beginTransaction();//开启事务处理
 
try{
    //PDO预处理以及执行语句...
    
    $pdo->commit();//提交事务
}catch(PDOException $e){
    $pdo->rollBack();//事务回滚
    
    //相关错误处理
    throw $e;
}

程序能很好的运行，结果如下：

Array

(

    [0] => Array

        (

            [id] => 1

            [name] => allen

            [gender] => 1

            [age] => 20

            [flag] => 1

        )

    [1] => Array

        (

            [id] => 2

            [name] => alice

            [gender] => 2

            [age] => 18

            [flag] => 1

        )

)

Array

(

    [0] => Array

        (

            [id] => 1

            [name] => allen

            [gender] => 1

            [age] => 20

            [flag] => 1

        )

)

1prepare方法影响行数：1

更新操作影响行数：0删除操作影响行数：1

共有数据：【25】条

pdo::query()方法

当执行返回结果集的select查询时,或者所影响的行数无关紧要时,应当使用pdo对象中的query()方法.

如果该方法成功执行指定的查询,则返回一个PDOStatement对象.

如果使用了query()方法,并想了解获取数据行总数,可以使用PDOStatement对象中的rowCount()方法获取.

pdo::exec()方法

当执行insert,update,delete没有结果集的查询时,使用pdo对象中的exec()方法去执行.

该方法成功执行时,将返回受影响的行数.注意,该方法不能用于select查询.

PDO事务：

$pdo->beginTransaction();//开启事务处理

try{

    //PDO预处理以及执行语句...

    

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

}catch(PDOException $e){

    $pdo->rollBack();//事务回滚

    

    //相关错误处理

    throw $e;

}

 

顶一下
(0)
100%
订阅 回复
踩一下
(0)
100%
» 郑重声明：本文由mpxq168发布，所有内容仅代表个人观点。版权归恒富网和mpxq168共有，欢迎转载， 但未经作者同意必须保留此段声明，并给出文章连接，否则保留追究法律责任的权利! 如果本文侵犯了您的权益，请留言。

目前有 0 条留言 其中：访客:0 条, 博主:0 条

给我留言

您必须 [ 登录 ] 才能发表留言！