PHP数据库操作:从MySQL原生API到PDO

本文涉及的产品
云数据库 RDS MySQL,集群版 2核4GB 100GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 本文将举详细例子向大家展示PHP是如何使用`MySQL原生API`、`MySQLi面向过程`、`MySQLi面向对象`、`PDO`操作MySQL数据库的。

本文将举详细例子向大家展示PHP是如何使用MySQL原生APIMySQLi面向过程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 = ? and age = ? ");
$stmt->bindValue(1,'test');
$stmt->bindValue(2,22);
$stmt->execute();  //执行一条预处理语句 .成功时返回 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(?,?,?)");
$stmt->bindValue(1, 'test');
$stmt->bindValue(2, 2);
$stmt->bindValue(3, 23);
$stmt->execute();
*/

//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();
}

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;
}

了解PDO更多内容:http://www.cnblogs.com/52fhy/p/3969340.html

参考:

1、PHP: MySQL - Manual
http://php.net/manual/zh/set.mysqlinfo.php
2、原生 MySQL API - Manual
http://php.net/manual/zh/book.mysql.php
3、Mysqli — MySQL增强版扩展 - Manual
http://php.net/manual/zh/book.mysqli.php
4、PHP: PDO - Manual
http://php.net/manual/zh/book.pdo.php
5、MySQL笔记汇总 - 飞鸿影~ - 博客园
http://www.cnblogs.com/52fhy/p/4930719.html
6、PHP面向对象07_PDO - 飞鸿影~ - 博客园
http://www.cnblogs.com/52fhy/p/3969340.html

相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
20天前
|
存储 关系型数据库 MySQL
探索MySQL:关系型数据库的基石
MySQL,作为全球最流行的开源关系型数据库管理系统(RDBMS)之一,广泛应用于各种Web应用、企业级应用和数据仓库中
|
18天前
|
缓存 运维 关系型数据库
数据库容灾 | MySQL MGR与阿里云PolarDB-X Paxos的深度对比
经过深入的技术剖析与性能对比,PolarDB-X DN凭借其自研的X-Paxos协议和一系列优化设计,在性能、正确性、可用性及资源开销等方面展现出对MySQL MGR的多项优势,但MGR在MySQL生态体系内也占据重要地位,但需要考虑备库宕机抖动、跨机房容灾性能波动、稳定性等各种情况,因此如果想用好MGR,必须配备专业的技术和运维团队的支持。 在面对大规模、高并发、高可用性需求时,PolarDB-X存储引擎以其独特的技术优势和优异的性能表现,相比于MGR在开箱即用的场景下,PolarDB-X基于DN的集中式(标准版)在功能和性能都做到了很好的平衡,成为了极具竞争力的数据库解决方案。
|
18天前
|
关系型数据库 MySQL 网络安全
Mysql 数据库主从复制
在MySQL主从复制环境中,配置了两台虚拟机:主VM拥有IP1,从VM有IP2。主VM的`my.cnf`设置server-id为1,启用二进制日志;从VM设置server-id为2,开启GTID模式。通过`find`命令查找配置文件,编辑`my.cnf`,在主服务器上创建复制用户,记录二进制日志信息,然后锁定表并备份数据。备份文件通过SCP传输到从服务器,恢复数据并配置复制源,启动复制。检查复制状态确认运行正常。最后解锁表,完成主从同步,新用户在从库中自动更新。
993 7
Mysql 数据库主从复制
|
2天前
|
存储 关系型数据库 MySQL
MySQL数据库开发进阶:精通数据库表的创建与管理22
【7月更文挑战第22天】数据库的创建与删除,数据表的创建与管理
11 1
|
8天前
|
分布式计算 大数据 关系型数据库
MaxCompute产品使用合集之如何实现类似mysql实例中的数据库功能
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
9天前
|
消息中间件 DataWorks 关系型数据库
DataWorks产品使用合集之遇到无法连接到本地 MySQL 数据库的问题,该如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
11天前
|
SQL Oracle 关系型数据库
MySQL、SQL Server和Oracle数据库安装部署教程
数据库的安装部署教程因不同的数据库管理系统(DBMS)而异,以下将以MySQL、SQL Server和Oracle为例,分别概述其安装部署的基本步骤。请注意,由于软件版本和操作系统的不同,具体步骤可能会有所变化。
42 3
|
10天前
|
DataWorks 关系型数据库 MySQL
DataWorks操作报错合集之从OceanBase(OB)数据库调度数据到MySQL数据库时遇到连接报错,该怎么办
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
17天前
|
关系型数据库 数据库 RDS
利用DTS将自建mysql5.7版本数据库迁移至对应rds报错
利用DTS将自建mysql5.7版本数据库迁移至对应rds报错
58 0
|
21天前
|
XML 关系型数据库 MySQL
支付系统----微信支付19---集成MyBatis-plus,数据库驱动对应的依赖版本设置问题,5没版本没有cj这个依赖,mysql驱动默认的是版本8,这里是一个父类,数据库都有,写个父类,继承就行
支付系统----微信支付19---集成MyBatis-plus,数据库驱动对应的依赖版本设置问题,5没版本没有cj这个依赖,mysql驱动默认的是版本8,这里是一个父类,数据库都有,写个父类,继承就行