PHP系列（十一）PHP操作mysql(i)資料庫

                   【Php操作Mysql資料庫】

在PHP腳本中操作MySQL資料庫的的六個步驟如下：

1.連接配接MySQL資料庫伺服器并判斷是否連接配接正确

2.選擇資料庫

3.設定字元集

4.準備SQL語句并發送SQL語句到MySQL伺服器并擷取記錄集

5.處理結果集

6.釋放結果集資源，關閉資料庫連接配接

一．PHP連接配接到MySQL

<?php

//我們全面采用UTF-8 編碼。

header('Content-Type:text/html;charset=utf-8');

//連接配接MySQL

$conn = @mysql_connect(DB_HOST,DB_USER,DB_PASSWORD)or die('資料庫連接配接失敗！錯誤資訊：'.mysql_error());

//資料庫連接配接參數，可以用常量存儲，這樣就不能修改，更加安全。

define('DB_USER','root');

define('DB_PASSWORD','yangfan');

define('DB_HOST','localhost');

define('DB_NAME' ,'school');

//選擇你所需要的資料庫

@mysql_select_db(DB_NAME) or die('資料庫找不到！錯誤資訊：'.mysql_error());

//設定字元集，如果是GBK，直接設定SET NAMES GBK 即可

@mysql_query('SET NAMES UTF8') or die('字元集設定錯誤');

//擷取記錄集

$query = "SELECT * FROM grade";

$result = @mysql_query($query) or die('SQL 語句有誤！錯誤資訊：'.mysql_error());

//輸出一條記錄

print_r(mysql_fetch_array($result,MYSQL_ASSOC));

//釋放結果集資源

mysql_free_result($result);

//關閉資料庫

mysql_close($conn);

?>

二．增删改查

1、新增資料

$query = "INSERT INTO grade (name,email,point,regdate)VALUE ('王五','[email protected]',,NOW())";

@mysql_query($query) or die('添加資料出錯：'.mysql_error());

2、修改資料

$query = "UPDATE grade SET name='小可愛' WHERE id=6";

@mysql_query($query) or die('修改出錯：'.mysql_error());

3、删除資料

$query = "DELETE FROM grade WHEREid=6";

@mysql_query($query) or die('删除錯誤：'.mysql_error());

4、顯示資料

$query = "SELECT id,name,email,pointFROM grade";

$result = @mysql_query($query) or die('查詢語句出錯：'.mysql_error());

while (!!$row = mysql_fetch_array($result)) {

echo$row['id'].'----'.$row['name'].'----'.$row['email'].'----'.$row['point'];

echo '<br />';

}

三．其他常用函數

結果集取出來的函數：

mysql_fetch_assoc() 函數從結果集中取得一行作為關聯數組。

mysql_fetch_row() 函數從結果集中取得一行作為索引數組。

mysql_fetch_array() 函數從結果集中取得一行作為關聯數組，或數字數組，或二者兼有

mysql_num_rows()函數傳回結果集中行的數目。

mysql_fetch_row()：從結果集中取得一行作為枚舉數組

mysql_fetch_array()： 從結果集中取得一行作為關聯數組，或數字數組，或二者兼有

mysql_fetch_lengths ()： 取得結果集中每個輸出的長度

mysql_field_name()： 取得結果中指定字段的字段名

mysql_num_rows()： 取得結果集中行的數目

mysql_num_fields()：取得結果集中字段的數目

mysql_get_client_info()： 取得MySQL 用戶端資訊

mysql_get_host_info()： 取得MySQL 主機資訊

mysql_get_proto_info()： 取得MySQL 協定資訊

mysql_get_server_info()： 取得MySQL 伺服器資訊

【php連接配接 mysqli】

PHP的mysqli擴充提供了其先行版本的所有功能，此外，由于MySQL已經是一個

具有完整特性的資料庫伺服器，這為PHP又添加了一些新特性。而mysqli恰恰也支援了

這些新特性。

一．建立和斷開連接配接

與MySQL資料庫互動時，首先要建立連接配接，最後要斷開連接配接，這包括與伺服器連接配接并選擇一個資料庫，以及最後關閉連接配接。與mysqli幾乎所有的特性一樣，這一點可以使用面向對象的方法來完成，也可以采用過程化的方式完成。

1.建立一個mysqli的對象

$_mysqli = new mysqli();

2.連接配接MySQL的主機、使用者、密碼、資料庫

$_mysqli->connect('localhost','root','yangfan','guest');

3.建立帶連接配接參數的mysqli對象

$_mysqli = new mysqli('localhost','root','yangfan','guest');

4.單獨選擇資料庫

$_mysqli->select_db('testguest');

5.斷開MySQL

$_mysqli->close();

二．處理連接配接錯誤

如果無法連接配接MySQL資料庫，那麼這個頁面不太可能繼續完成預期的工作。是以，一定要注意監視連接配接錯誤并相應地做出反應。Mysqli擴充包含有很多特性可以用來捕獲錯誤資訊，例如：mysqli_connect_errno()和mysqli_connect_error()方法。

mysqli_connect_errno()函數傳回連接配接資料庫傳回的錯誤号。

Mysqli_connect_error()函數傳回連接配接資料庫傳回的錯誤代碼。

if (mysqli_connect_errno()) {

echo '資料庫連接配接錯誤，錯誤資訊：'.mysqli_connect_error();

exit();

errno屬性傳回資料庫操作時的錯誤号。

error屬性傳回資料庫操作時的錯誤代碼。

if ($_mysqli->errno) {

echo '資料庫操作時發生錯誤，錯誤代碼是：'.$_mysqli->error;

三．與資料庫進行互動

絕大多數查詢都與建立(Creation)、擷取(Retrieval)、更新(Update)和删除(Deletion)任務有關，這些任務統稱為CRUD。

1.擷取資料

網頁程式大多數工作都是在擷取和格式化所請求的資料。為此，要向資料庫發送

SELECT查詢，再對結果進行疊代處理，将各行輸出給浏覽器，并按照自己的要求輸出。

//設定一下編碼utf8

$_mysqli->set_charset("utf8");

//建立一句SQL語句

$_sql = "SELECT * FROM tg_user";

//執行sql語句把結果集賦給$_result

$_result = $_mysqli->query($_sql);

//将結果集的第一行輸出

print_r($_result->fetch_row());

//釋放查詢記憶體(銷毀)

$_result->free();

2.解析查詢結果

一旦執行了查詢并準備好結果集，下面就可以解析擷取到的結果行了。你可以使用多個

方法來擷取各行中的字段，具體選擇哪一個方法主要取決于個人喜好，因為隻是引用字段的方法有所不同。

将結果集放到對象中

由于你可能會使用mysqli的面向對象的文法，是以完全可以采用面向對象的方式管理結果集。可以使用fetch_object()方法來完成。

//将結果集包裝成對象

$_row = $_reslut->fetch_object();

//輸出對象中的一個字段（屬性）

echo $_row->tg_username;

//周遊所有的使用者名稱

while (!!$_row = $_reslut->fetch_object()) {

echo $_row->tg_username.' <br /> ';

使用索引數組和關聯數組

//将結果集包裝成數組(索引+關聯)

$_row = $_reslut->fetch_array();

//輸出下标是3的字段（屬性）

echo $_row[3];

//将結果集包裝成索引數組

$_row = $_reslut->fetch_row();

//将結果集包裝成關聯數組

$_row = $_reslut->fetch_assoc();

echo $_row['tg_username'];

3.确定所選擇的行和受影響的行

通常希望能夠确定SELECT查詢傳回的行數，或者受INSERT、UPDATE或DELET查詢影響的行數。我們可以使用num_rows和affected_rows兩個屬性

//當使用查詢時，想了解SELECT查詢了多少行，可以使用num_rows。

echo $_reslut->num_rows;

//當使用查詢時，想了解SELECT、INSERT、UPDATE、DELETE查詢時影響的行數，可以使用affected_rows;注意，它是$_mysqli下的屬性

echo $_mysqli->affected_rows;

4.移動指針的操作和擷取字段

當你并不想從第一條資料開始擷取，或者并不想從第一個字段擷取，你可以使用資料指針移動或者字段指針移動的方式調整到恰當的位置。當然，你還可以擷取字段的名稱及其相

關的屬性。

//計算有多少條字段

echo $_reslut->field_count;

//擷取字段的名稱

$_field = $_reslut->fetch_field();

echo $_field->name;

//周遊字段

while (!!$_field = $_reslut->fetch_field()) {

echo $_field->name.'<br />';

//一次性取得字段數組

print_r($_reslut->fetch_fields());

//移動資料指針

$_reslut->data_seek(5);

//移動字段指針

$_reslut->field_seek(2);

5.執行多條SQL語句

有的時候，我們需要在一張頁面上同時執行多條SQL語句，之前的方法就是分别建立多個結果集然後使用。但這樣資源消耗很大，也不利于管理。PHP提供了執行多條SQL語句

的方法$_mysqli->multi_query();

//建立多條SQL語句

$_sql .= "SELECT * FROM tg_user;";

$_sql .= "SELECT * FROM tg_photo;";

$_sql .= "SELECT * FROM tg_article";

//開始執行多條SQL語句

if ($_mysqli->multi_query($_sql)) {

//開始擷取第一條SQL語句的結果集

$_result = $_mysqli->store_result();

print_r($_result->fetch_array());

//将結果集指針移到下一個

$_mysqli->next_result();

} else {

echo 'sql語句有誤！';

6.執行資料庫事務

事務(transaction)是作為整個一個單元的一組有序的資料庫操作。如果一組中的所有操作都成功，則認為事務成功，即使隻有一個失敗操作，事務也不成功。如果所有操作成功完成，事務則送出(commit)，其修改将作用于所有其他資料庫程序。如果一個操作失敗，則事務将復原(rollback)，該事務所有操作的影響都将取消。首先，您的MySQL是InnoDB或BDB引擎的一種，一般來說，你安裝了AppServ的內建

包，你選擇InnoDB的引擎的資料庫即可。如果你建立的表不是InnoDB，可以在phpmyadmin

裡修改。

//首先你必須關閉自動送出資料

$_mysqli->autocommit(false);

//建立一個SQL語句，必須同時運作成功，不能出現一個成功，一個失敗

$_sql .= "UPDATE tg_friend SETtg_state=tg_state+5 WHERE tg_id=1;";

$_sql .= "UPDATE tg_flower SETtg_flower=tg_flower-5 WHERE tg_id=1;";

//執行兩條SQL語句

//擷取第一條SQL一影響的行數

$_success = $_mysqli->affected_rows == 1 ? true : false;

//下移，第二條SQL

//擷取第二條SQL影響的行數

$_success2 = $_mysqli->affected_rows == 1 ? true : false;

//判斷是否都正常通過了，兩個SQL

if ($_success &&$_success2) {

$_mysqli->commit();

echo '完美送出！';

} else {

$_mysqli->rollback();

echo '程式出現異常！';

echo "SQL語句有誤：".$_mysqli->errno.$_mysqli->error;

//最後還必須開啟自動送出

$_mysqli->autocommit(true);

本文轉自 sswqzx 51CTO部落格，原文連結:http://blog.51cto.com/sswqzx/1969832