MySQL原生API、MySQLi面向过程、MySQLi面向对象、PDO操做MySQL

【转载】http://www.cnblogs.com/52fhy/p/5352304.html

本文将举详细例子向你们展现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，都仍是有缺陷的。
一、不支持事务机制；
二、仅支持MySQL，不能使用其它数据库。
三、不安全，可能有注入风险
四、不支持异常处理

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