PHP封装的PDO操作MySql数据库操作类！简单易用！
导读：摘要数据库操作类可以封装数据库连接和操作，使代码更易于维护和扩展。它们提供了一种组织代码的方法，将数据库相关的功能放在一个类中，以便于复用。良好的数据库操作类可以提供一定程度的安全性，通过参数化查询或准备语句来防止SQL注入攻击。这有助于保...
摘要
数据库操作类可以封装数据库连接和操作，使代码更易于维护和扩展。它们提供了一种组织代码的方法，将数据库相关的功能放在一个类中，以便于复用。
良好的数据库操作类可以提供一定程度的安全性，通过参数化查询或准备语句来防止SQL注入攻击。这有助于保护数据库免受恶意输入的影响。
良好的数据库操作类可以提供一定程度的安全性，通过参数化查询或准备语句来防止SQL注入攻击。这有助于保护数据库免受恶意输入的影响。
数据库操作类有助于提高PHP应用程序的可维护性、安全性和性能，同时促进代码的重用和更好的代码组织。然而，选择适合项目需求的数据库操作类以及正确使用它们非常重要。
Database.php
?php
/**
* PHP PDO MySQL数据库操作类
* 作者：TANKING
* 时间：2023-10-12
* 博客：https://segmentfault.com/u/tanking
*/
class DB_API {
private $pdo;
private $error;
// 连接数据库
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 {
// 构建SET子句
$set = '';
foreach ($data as $key =>
$value) {
$set .= "$key = :$key, ";
}
$set = rtrim($set, ', ');
// 构建WHERE子句
$whereClause = '';
foreach ($where as $key =>
$value) {
$whereClause .= "$key = :where_$key AND ";
}
$whereClause = rtrim($whereClause, 'AND ');
// 构建SQL查询
$query = "UPDATE $table SET $set WHERE $whereClause";
// 创建预处理语句
$stmt = $this->
pdo->
prepare($query);
// 绑定更新数据的参数
foreach ($data as $key =>
$value) {
$stmt->
bindValue(":$key", $value);
}
// 绑定WHERE条件的参数
foreach ($where as $key =>
$value) {
$stmt->
bindValue(":where_$key", $value);
}
// 执行预处理语句
$stmt->
execute();
// 操作成功
return true;
}
catch (PDOException $e) {
$this->
error = $e->
getMessage();
// 操作失败
return false;
}
}
// 删除
public function delete($table, $where, $params = array()) {
try {
// 构建WHERE子句
$whereClause = '';
foreach ($where as $key =>
$value) {
$whereClause .= "$key = :$key AND ";
}
$whereClause = rtrim($whereClause, 'AND ');
// 构建SQL查询
$query = "DELETE FROM $table WHERE $whereClause";
// 创建预处理语句
$stmt = $this->
pdo->
prepare($query);
// 绑定WHERE条件的参数
foreach ($where as $key =>
$value) {
$stmt->
bindValue(":$key", $value);
}
// 执行预处理语句
$stmt->
execute();
// 操作成功
return true;
}
catch (PDOException $e) {
$this->
error = $e->
getMessage();
// 操作失败
return false;
}
}
// 查询
public function select($table, $fields = "*", $conditions = null, $likeConditions = null, $orderBy = null, $limit = null, $params = array()) {
try {
// 构建SELECT子句
if (is_array($fields)) {
$fields = implode(', ', $fields);
}
elseif ($fields === "*") {
$fields = "*";
}
else {
$fields = "";
}
// 构建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 ');
}
// 构建ORDER BY子句
$orderByClause = '';
if (!is_null($orderBy) &
&
is_array($orderBy)) {
$orderByClause = "ORDER BY " . implode(', ', $orderBy);
}
// 构建LIMIT子句
$limitClause = '';
if (!is_null($limit)) {
$limitClause = "LIMIT $limit";
}
// 构建SQL查询
$query = "SELECT $fields FROM $table";
if (!empty($whereClause)) {
$query .= " WHERE $whereClause";
}
if (!empty($orderByClause)) {
$query .= " $orderByClause";
}
if (!empty($limitClause)) {
$query .= " $limitClause";
}
// 创建预处理语句
$stmt = $this->
pdo->
prepare($query);
// 绑定参数
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);
}
}
// 执行预处理语句
$stmt->
execute();
// 获取查询结果
$result = $stmt->
fetchAll(PDO::FETCH_ASSOC);
return $result;
// 返回查询结果数组
}
catch (PDOException $e) {
$this->
error = $e->
getMessage();
return false;
// 操作失败
}
}
// 执行原生SQL语句
public function execQuery($query, $params = array()) {
try {
// 创建预处理语句
$stmt = $this->
pdo->
prepare($query);
// 绑定参数
foreach ($params as $key =>
$value) {
$stmt->
bindValue($key, $value);
}
// 执行预处理语句
$stmt->
execute();
// 操作成功
return true;
}
catch (PDOException $e) {
$this->
error = $e->
getMessage();
// 操作失败
return false;
}
}
// 错误信息
public function errorMsg() {
return $this->
error;
}
}
Db.php
?php
// 引入操作类
include 'Database.php';
// 配置文件
$config = array(
'db_host' =>
'localhost',
'db_port' =>
3306,
'db_name' =>
'xxx',
'db_user' =>
'xxx',
'db_pass' =>
'xxx'
);
?>
使用示例
以表名为 test_table 为示例作为示例代码。
创建表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';
// 实例化
$db = new DB_API($config);
// 数据
$insertData = array(
'title' =>
'this is title',
'content' =>
'this is content',
);
// 执行
$insertSQL = $db->
add('test_table', $insertData);
// 结果
if ($insertSQL) {
// 成功
echo '插入成功，ID是：' . $insertSQL;
}
else {
// 失败
echo '插入失败，原因：' . $db->
errorMsg();
}
?>
update示例
?php
// 引入配置
include 'Db.php';
// 实例化
$db = new DB_API($config);
// 条件
// 只支持=，不支持>
，，>
=，=之类的
// 如需更复杂的条件请使用执行原生语句的方法
$where = array(
'id' =>
'1'
);
// 数据
$updateData = array(
'content' =>
'content is updated'
);
// 执行
$updatedSQL = $db->
update('test_table', $where, $updateData);
// 结果
if ($updatedSQL) {
// 成功
echo '更新成功';
}
else {
// 失败
echo '更新失败，原因：' . $db->
errorMsg();
}
?>
delete示例
?php
// 引入配置
include 'Db.php';
// 实例化
$db = new DB_API($config);
// 条件
$where = array(
'id' =>
4,
);
// 执行
$deleteSQL = $db->
delete('test_table', $where);
// 结果
if ($deleteSQL) {
// 成功
echo '删除成功';
}
else {
// 失败
echo '删除失败，原因：' . $db->
errorMsg();
}
?>
select示例
?php
// 引入配置
include 'Db.php';
// 实例化
$db = new DB_API($config);
// 使用方法
// $db->
select('表名', ['字段1','字段2',...], where条件, LIKE条件, ORDER条件, LIKIT条件);
// 如果查询所有字段，使用'*'代替数组
// $db->
select('表名', '*', where条件, LIKE条件, ORDER条件, LIKIT条件);
// 无需使用的条件传递null
// $db->
select('表名', '*', where条件, null, null, null);
// 查询所有字段，没有查询条件
$selectSQL = $db->
select('test_table', '*');
// 查询指定字段，没有查询条件
// $selectSQL = $db->
select('test_table', ['id', 'title']);
// 根据以下条件
// 查询所有字段
// $where = array(
// 'id' =>
3
// );
// $selectSQL = $db->
select('test_table', '*', $where);
// 根据以下条件
// 查询指定字段
// $where = array(
// 'id' =>
3
// );
// $selectSQL = $db->
select('test_table', ['title'], $where);
// 使用LIKE条件
// 如果没有where条件就直接传入null
// '*'是查询所有字段，如需查询指定字段传入['字段1','字段2',....]
// $likeWhere = array(
// 'title' =>
'%一带一路%'
// );
// $selectSQL = $db->
select('test_table', '*', null, $likeWhere);
// 使用where条件和LIKE条件
// '*'是查询所有字段，如需查询指定字段传入['字段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条开始，取3条
// $limit = '5,2';
// 第5条开始，取2条
// $selectSQL = $db->
select('test_table', '*', null, null, null, $limit);
// 结果
if ($selectSQL) {
// 成功
echo json_encode($selectSQL, JSON_UNESCAPED_UNICODE);
}
else {
// 失败
echo '查询失败，原因：' . $db->
errorMsg();
}
?>
执行原生语句示例
?php
// 引入配置
include 'Db.php';
// 实例化
$db = new DB_API($config);
// SQL语句
$query = "INSERT INTO test_table (title, content) VALUES (:title, :content)";
// 数据绑定
$params = array(
':title' =>
'New Title By execQuery',
':content' =>
'New Content By execQuery',
);
// 执行
$querySQL = $db->
execQuery($query, $params);
// 结果
if ($querySQL) {
// 成功
echo 'SQL执行成功！';
}
else {
// 失败
echo 'SQL执行失败，原因：' . $db->
errorMsg();
}
?>
作者
TANKING
声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！
若转载请注明出处： PHP封装的PDO操作MySql数据库操作类！简单易用！
本文地址： https://pptw.com/jishu/569667.html