程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> PHP綜合 >> PHP數據庫操作：從MySQL原生API到PDO

PHP數據庫操作：從MySQL原生API到PDO

編輯：PHP綜合

本文將舉詳細例子向大家展示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 = ? 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