PHP封裝PDO實(shí)現(xiàn)操作MySql數(shù)據(jù)庫(kù)
更新時(shí)間：2023年10月23日 09:43:34 作者：TANKING
數(shù)據(jù)庫(kù)操作類(lèi)可以封裝數(shù)據(jù)庫(kù)連接和操作,使代碼更易于維護(hù)和擴(kuò)展,這篇文章主要為大家詳細(xì)介紹了PHP如何封裝操作類(lèi)PDO從而實(shí)現(xiàn)操作MySql數(shù)據(jù)庫(kù)的功能,需要的可以了解下
摘要
數(shù)據(jù)庫(kù)操作類(lèi)可以封裝數(shù)據(jù)庫(kù)連接和操作，使代碼更易于維護(hù)和擴(kuò)展。它們提供了一種組織代碼的方法，將數(shù)據(jù)庫(kù)相關(guān)的功能放在一個(gè)類(lèi)中，以便于復(fù)用。
良好的數(shù)據(jù)庫(kù)操作類(lèi)可以提供一定程度的安全性，通過(guò)參數(shù)化查詢(xún)或準(zhǔn)備語(yǔ)句來(lái)防止SQL注入攻擊。這有助于保護(hù)數(shù)據(jù)庫(kù)免受惡意輸入的影響。
良好的數(shù)據(jù)庫(kù)操作類(lèi)可以提供一定程度的安全性，通過(guò)參數(shù)化查詢(xún)或準(zhǔn)備語(yǔ)句來(lái)防止SQL注入攻擊。這有助于保護(hù)數(shù)據(jù)庫(kù)免受惡意輸入的影響。
數(shù)據(jù)庫(kù)操作類(lèi)有助于提高PHP應(yīng)用程序的可維護(hù)性、安全性和性能，同時(shí)促進(jìn)代碼的重用和更好的代碼組織。然而，選擇適合項(xiàng)目需求的數(shù)據(jù)庫(kù)操作類(lèi)以及正確使用它們非常重要。
Database.php
<?php
/**
* PHP PDO MySQL數(shù)據(jù)庫(kù)操作類(lèi)
* 作者：TANKING
* 時(shí)間：2023-10-12
* 博客：https://segmentfault.com/u/tanking
*/
class DB_API {
private $pdo;
private $error;
// 連接數(shù)據(jù)庫(kù)
public function __construct($config) {
$dsn = "mysql:host={$config['db_host']};port={$config['db_port']};dbname={$config['db_name']}";
try {
$this->pdo = new PDO($dsn, $config['db_user'], $config['db_pass']);
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
$this->error = $e->getMessage();
}
}
// 插入
public function add($table, $data) {
try {
$columns = implode(', ', array_keys($data));
$values = implode(', :', array_keys($data));
$query = "INSERT INTO $table ($columns) VALUES (:$values)";
$stmt = $this->pdo->prepare($query);
$stmt->execute($data);
return $this->pdo->lastInsertId();
} catch (PDOException $e) {
$this->error = $e->getMessage();
return false;
}
}
// 更新
public function update($table, $where, $data) {
try {
// 構(gòu)建SET子句
$set = '';
foreach ($data as $key => $value) {
$set .= "$key = :$key, ";
}
$set = rtrim($set, ', ');
// 構(gòu)建WHERE子句
$whereClause = '';
foreach ($where as $key => $value) {
$whereClause .= "$key = :where_$key AND ";
}
$whereClause = rtrim($whereClause, 'AND ');
// 構(gòu)建SQL查詢(xún)
$query = "UPDATE $table SET $set WHERE $whereClause";
// 創(chuàng)建預(yù)處理語(yǔ)句
$stmt = $this->pdo->prepare($query);
// 綁定更新數(shù)據(jù)的參數(shù)
foreach ($data as $key => $value) {
$stmt->bindValue(":$key", $value);
}
// 綁定WHERE條件的參數(shù)
foreach ($where as $key => $value) {
$stmt->bindValue(":where_$key", $value);
}
// 執(zhí)行預(yù)處理語(yǔ)句
$stmt->execute();
// 操作成功
return true;
} catch (PDOException $e) {
$this->error = $e->getMessage();
// 操作失敗
return false;
}
}
// 刪除
public function delete($table, $where, $params = array()) {
try {
// 構(gòu)建WHERE子句
$whereClause = '';
foreach ($where as $key => $value) {
$whereClause .= "$key = :$key AND ";
}
$whereClause = rtrim($whereClause, 'AND ');
// 構(gòu)建SQL查詢(xún)
$query = "DELETE FROM $table WHERE $whereClause";
// 創(chuàng)建預(yù)處理語(yǔ)句
$stmt = $this->pdo->prepare($query);
// 綁定WHERE條件的參數(shù)
foreach ($where as $key => $value) {
$stmt->bindValue(":$key", $value);
}
// 執(zhí)行預(yù)處理語(yǔ)句
$stmt->execute();
// 操作成功
return true;
} catch (PDOException $e) {
$this->error = $e->getMessage();
// 操作失敗
return false;
}
}
// 查詢(xún)
public function select($table, $fields = "*", $conditions = null, $likeConditions = null, $orderBy = null, $limit = null, $params = array()) {
try {
// 構(gòu)建SELECT子句
if (is_array($fields)) {
$fields = implode(', ', $fields);
} elseif ($fields === "*") {
$fields = "*";
} else {
$fields = "";
}
// 構(gòu)建WHERE子句
$whereClause = '';
if (!is_null($conditions) && is_array($conditions)) {
foreach ($conditions as $key => $value) {
$whereClause .= "$key = :$key AND ";
}
$whereClause = rtrim($whereClause, 'AND ');
}
// 合并LIKE條件
if (!is_null($likeConditions) && is_array($likeConditions)) {
if (!empty($whereClause)) {
$whereClause .= ' AND ';
}
foreach ($likeConditions as $key => $value) {
$whereClause .= "$key LIKE :like_$key AND ";
$params[":like_$key"] = $value;
}
$whereClause = rtrim($whereClause, 'AND ');
}
// 構(gòu)建ORDER BY子句
$orderByClause = '';
if (!is_null($orderBy) && is_array($orderBy)) {
$orderByClause = "ORDER BY " . implode(', ', $orderBy);
}
// 構(gòu)建LIMIT子句
$limitClause = '';
if (!is_null($limit)) {
$limitClause = "LIMIT $limit";
}
// 構(gòu)建SQL查詢(xún)
$query = "SELECT $fields FROM $table";
if (!empty($whereClause)) {
$query .= " WHERE $whereClause";
}
if (!empty($orderByClause)) {
$query .= " $orderByClause";
}
if (!empty($limitClause)) {
$query .= " $limitClause";
}
// 創(chuàng)建預(yù)處理語(yǔ)句
$stmt = $this->pdo->prepare($query);
// 綁定參數(shù)
if (!is_null($conditions) && is_array($conditions)) {
foreach ($conditions as $key => $value) {
$stmt->bindValue(":$key", $value);
}
}
if (!is_null($likeConditions) && is_array($likeConditions)) {
foreach ($likeConditions as $key => $value) {
$stmt->bindValue(":like_$key", $value);
}
}
// 執(zhí)行預(yù)處理語(yǔ)句
$stmt->execute();
// 獲取查詢(xún)結(jié)果
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
return $result; // 返回查詢(xún)結(jié)果數(shù)組
} catch (PDOException $e) {
$this->error = $e->getMessage();
return false; // 操作失敗
}
}
// 執(zhí)行原生SQL語(yǔ)句
public function execQuery($query, $params = array()) {
try {
// 創(chuàng)建預(yù)處理語(yǔ)句
$stmt = $this->pdo->prepare($query);
// 綁定參數(shù)
foreach ($params as $key => $value) {
$stmt->bindValue($key, $value);
}
// 執(zhí)行預(yù)處理語(yǔ)句
$stmt->execute();
// 操作成功
return true;
} catch (PDOException $e) {
$this->error = $e->getMessage();
// 操作失敗
return false;
}
}
// 錯(cuò)誤信息
public function errorMsg() {
return $this->error;
}
}Db.php
<?php
// 引入操作類(lèi)
include 'Database.php';
// 配置文件
$config = array(
'db_host' => 'localhost',
'db_port' => 3306,
'db_name' => 'xxx',
'db_user' => 'xxx',
'db_pass' => 'xxx'
);
?>使用示例
以表名為 test_table 為示例作為示例代碼。
創(chuàng)建表SQL:
CREATE TABLE `test_table` ( `id` int(10) PRIMARY KEY AUTO_INCREMENT NOT NULL, `title` varchar(32) NOT NULL, `content` varchar(255) NOT NULL ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
insert示例
<?php
// 引入配置
include 'Db.php';
// 實(shí)例化
$db = new DB_API($config);
// 數(shù)據(jù)
$insertData = array(
'title' => 'this is title',
'content' => 'this is content',
);
// 執(zhí)行
$insertSQL = $db->add('test_table', $insertData);
// 結(jié)果
if ($insertSQL) {
// 成功
echo '插入成功，ID是：' . $insertSQL;
} else {
// 失敗
echo '插入失敗，原因：' . $db->errorMsg();
}
?>update示例
<?php
// 引入配置
include 'Db.php';
// 實(shí)例化
$db = new DB_API($config);
// 條件
// 只支持=，不支持>，<，>=，<=之類(lèi)的
// 如需更復(fù)雜的條件請(qǐng)使用執(zhí)行原生語(yǔ)句的方法
$where = array(
'id' => '1'
);
// 數(shù)據(jù)
$updateData = array(
'content' => 'content is updated'
);
// 執(zhí)行
$updatedSQL = $db->update('test_table', $where, $updateData);
// 結(jié)果
if ($updatedSQL) {
// 成功
echo '更新成功';
} else {
// 失敗
echo '更新失敗，原因：' . $db->errorMsg();
}
?>delete示例
<?php
// 引入配置
include 'Db.php';
// 實(shí)例化
$db = new DB_API($config);
// 條件
$where = array(
'id' => 4,
);
// 執(zhí)行
$deleteSQL = $db->delete('test_table', $where);
// 結(jié)果
if ($deleteSQL) {
// 成功
echo '刪除成功';
} else {
// 失敗
echo '刪除失敗，原因：' . $db->errorMsg();
}
?>select示例
<?php
// 引入配置
include 'Db.php';
// 實(shí)例化
$db = new DB_API($config);
// 使用方法
// $db->select('表名', ['字段1','字段2',...], where條件, LIKE條件, ORDER條件, LIKIT條件);
// 如果查詢(xún)所有字段，使用'*'代替數(shù)組
// $db->select('表名', '*', where條件, LIKE條件, ORDER條件, LIKIT條件);
// 無(wú)需使用的條件傳遞null
// $db->select('表名', '*', where條件, null, null, null);
// 查詢(xún)所有字段，沒(méi)有查詢(xún)條件
$selectSQL = $db->select('test_table', '*');
// 查詢(xún)指定字段，沒(méi)有查詢(xún)條件
// $selectSQL = $db->select('test_table', ['id', 'title']);
// 根據(jù)以下條件
// 查詢(xún)所有字段
// $where = array(
// 'id' => 3
// );
// $selectSQL = $db->select('test_table', '*', $where);
// 根據(jù)以下條件
// 查詢(xún)指定字段
// $where = array(
// 'id' => 3
// );
// $selectSQL = $db->select('test_table', ['title'], $where);
// 使用LIKE條件
// 如果沒(méi)有where條件就直接傳入null
// '*'是查詢(xún)所有字段，如需查詢(xún)指定字段傳入['字段1','字段2',....]
// $likeWhere = array(
// 'title' => '%一帶一路%'
// );
// $selectSQL = $db->select('test_table', '*', null, $likeWhere);
// 使用where條件和LIKE條件
// '*'是查詢(xún)所有字段，如需查詢(xún)指定字段傳入['字段1','字段2',....]
// $where = array(
// 'id' => 3
// );
// $likeWhere = array(
// 'title' => '%一帶一路%'
// );
// $selectSQL = $db->select('test_table', '*', $where, $likeWhere);
// 使用排序條件
// $orderBy = array('id DESC');
// $selectSQL = $db->select('test_table', '*', null, null, $orderBy);
// 使用限制條件
// $limit = 2; // 取2條
// $limit = '0,3'; // 第1條開(kāi)始，取3條
// $limit = '5,2'; // 第5條開(kāi)始，取2條
// $selectSQL = $db->select('test_table', '*', null, null, null, $limit);
// 結(jié)果
if ($selectSQL) {
// 成功
echo json_encode($selectSQL, JSON_UNESCAPED_UNICODE);
} else {
// 失敗
echo '查詢(xún)失敗，原因：' . $db->errorMsg();
}
?>執(zhí)行原生語(yǔ)句示例
<?php
// 引入配置
include 'Db.php';
// 實(shí)例化
$db = new DB_API($config);
// SQL語(yǔ)句
$query = "INSERT INTO test_table (title, content) VALUES (:title, :content)";
// 數(shù)據(jù)綁定
$params = array(
':title' => 'New Title By execQuery',
':content' => 'New Content By execQuery',
);
// 執(zhí)行
$querySQL = $db->execQuery($query, $params);
// 結(jié)果
if ($querySQL) {
// 成功
echo 'SQL執(zhí)行成功！';
} else {
// 失敗
echo 'SQL執(zhí)行失敗，原因：' . $db->errorMsg();
}
?>以上就是PHP封裝PDO實(shí)現(xiàn)操作MySql數(shù)據(jù)庫(kù)的詳細(xì)內(nèi)容，更多關(guān)于PHP操作MySql的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了圖解找出PHP配置文件php.ini的路徑的方法,其實(shí)就是使用phpinfo()函數(shù)輸出PHP信息,然后找到Configuration File (php.ini) Path這節(jié)就可以了,需要的朋友可以參考下2014-08-08
PHP多維數(shù)組遍歷方法(2種實(shí)現(xiàn)方法)
這篇文章主要介紹了PHP多維數(shù)組遍歷方法,實(shí)例分析了2種多維數(shù)組的遍歷技巧,包括簡(jiǎn)單的foreach遍歷與遞歸操作遍歷實(shí)現(xiàn)方法,需要的朋友可以參考下2015-12-12
PHP中調(diào)用C/C++制作的動(dòng)態(tài)鏈接庫(kù)的教程
這篇文章主要介紹了PHP中調(diào)用C/C++制作的動(dòng)態(tài)鏈接庫(kù)的教程,文中還簡(jiǎn)單地提到了gcc編譯器下動(dòng)態(tài)鏈接庫(kù)的制作方法,需要的朋友可以參考下2016-03-03
這篇文章主要介紹了php多重接口的實(shí)現(xiàn)方法,實(shí)例分析了php多重接口的定義與使用技巧,需要的朋友可以參考下2015-06-06
這篇文章主要介紹了PHP中返回引用類(lèi)型的方法,這是個(gè)比較容易混淆的概念,如果不是出于某些特殊的原因,建議還是不要使用,需要的朋友可以參考下2015-04-04
php簡(jiǎn)單圖像創(chuàng)建入門(mén)實(shí)例
這篇文章主要介紹了php簡(jiǎn)單圖像創(chuàng)建方法,實(shí)例分析了php圖像創(chuàng)建的基本技巧,需要的朋友可以參考下2015-06-06
PDO是一個(gè)“數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)抽象層”，作用是統(tǒng)一各種數(shù)據(jù)庫(kù)的訪(fǎng)問(wèn)接口，與mysql和mysqli的函數(shù)庫(kù)相比，PDO讓跨數(shù)據(jù)庫(kù)的使用更具有親和力；與ADODB和MDB2相比，PDO更高效。2010-04-04
這篇文章主要介紹了php查詢(xún)相似度最高的字符串的方法,涉及php操作字符串及數(shù)組實(shí)現(xiàn)相似度算法的技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-03-03
PHP中使用jQuery+Ajax實(shí)現(xiàn)分頁(yè)查詢(xún)多功能操作(示例講解)
下面小編就為大家?guī)?lái)一篇PHP中使用jQuery+Ajax實(shí)現(xiàn)分頁(yè)查詢(xún)多功能操作(示例講解)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-09-09
這篇文章主要介紹了php禁止瀏覽器使用緩存頁(yè)面的方法,以實(shí)例形式較為詳細(xì)的講述了PHP禁用緩存的方法及用途,需要的朋友可以參考下2014-11-11