PHP数据库操作对象，让你在使用php操作数据库的时候更方便、更得心应手。本位为你提供一个完善的PHP数据库操作类，它提供了新建数据库、链接数据库、新建表、读取、插入、更新和删除等功能。且代码的设计注重安全性、稳定性、高效性和易用性。
一、PHP操作Mysql的对象
<?php
/**
* 数据库操作类
* 提供安全、稳定、高效的数据库操作功能
*/
classDatabase{
private$host;
private$username;
private$password;
private$database;
private$charset;
private$pdo;
private$error;
private$isConnected=false;
/**
* 构造函数
* @param string $host 数据库主机
* @param string $username 用户名
* @param string $password 密码
* @param string $database 数据库名
* @param string $charset 字符集，默认utf8mb4
*/
publicfunction__construct($host,$username,$password,$database='',$charset='utf8mb4'){
$this->host=$host;
$this->username=$username;
$this->password=$password;
$this->database=$database;
$this->charset=$charset;
}
/**
* 连接到数据库
* @return bool 连接成功返回true，否则返回false
*/
publicfunctionconnect(){
try{
$dsn="mysql:host={$this->host};charset={$this->charset}";
if(!empty($this->database)){
$dsn.=";dbname={$this->database}";
}
$options=[
PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES=>false,
PDO::ATTR_PERSISTENT=>false,
PDO::MYSQL_ATTR_INIT_COMMAND=>"SET NAMES {$this->charset}"
];
$this->pdo=newPDO($dsn,$this->username,$this->password,$options);
$this->isConnected=true;
returntrue;
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 关闭数据库连接
*/
publicfunctiondisconnect(){
$this->pdo=null;
$this->isConnected=false;
}
/**
* 创建数据库
* @param string $database 数据库名
* @return bool 成功返回true，否则返回false
*/
publicfunctioncreateDatabase($database){
if(!$this->isConnected){
$this->connect();
}
try{
$sql="CREATE DATABASE IF NOT EXISTS `{$database}` CHARACTER SET {$this->charset} COLLATE utf8mb4_unicode_ci";
$this->pdo->exec($sql);
returntrue;
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 选择数据库
* @param string $database 数据库名
* @return bool 成功返回true，否则返回false
*/
publicfunctionselectDatabase($database){
if(!$this->isConnected){
$this->connect();
}
try{
$this->pdo->exec("USE `{$database}`");
$this->database=$database;
returntrue;
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 创建数据表
* @param string $table 表名
* @param array $columns 列定义数组
* @return bool 成功返回true，否则返回false
*
* 示例：
* $columns = [
* "id INT(11) AUTO_INCREMENT PRIMARY KEY",
* "name VARCHAR(255) NOT NULL",
* "email VARCHAR(255) NOT NULL UNIQUE",
* "created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP"
* ];
*/
publicfunctioncreateTable($table,$columns){
if(!$this->isConnected){
$this->connect();
}
if(empty($columns)){
$this->error="必须至少定义一个列";
returnfalse;
}
try{
$columnsSql=implode(", ",$columns);
$sql="CREATE TABLE IF NOT EXISTS `{$table}` ({$columnsSql}) ENGINE=InnoDB DEFAULT CHARSET={$this->charset}";
$this->pdo->exec($sql);
returntrue;
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 插入数据
* @param string $table 表名
* @param array $data 要插入的数据关联数组
* @return int|bool 成功返回插入的ID，失败返回false
*/
publicfunctioninsert($table,$data){
if(!$this->isConnected){
$this->connect();
}
if(empty($data)){
$this->error="插入数据不能为空";
returnfalse;
}
try{
$columns=implode("`, `",array_keys($data));
$placeholders=":".implode(", :",array_keys($data));
$sql="INSERT INTO `{$table}` (`{$columns}`) VALUES ({$placeholders})";
$stmt=$this->pdo->prepare($sql);
$stmt->execute($data);
return$this->pdo->lastInsertId();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 查询数据
* @param string $table 表名
* @param array $conditions 查询条件关联数组
* @param string $fields 要查询的字段，默认为*
* @param string $order 排序条件
* @param int $limit 限制返回数量
* @param int $offset 偏移量
* @return array|bool 成功返回结果数组，失败返回false
*/
publicfunctionselect($table,$conditions=[],$fields="*",$order="",$limit=0,$offset=0){
if(!$this->isConnected){
$this->connect();
}
try{
$whereClause="";
$params=[];
if(!empty($conditions)){
$whereParts=[];
foreach($conditionsas$key=>$value){
$whereParts[]="`{$key}` = :{$key}";
$params[":{$key}"]=$value;
}
$whereClause="WHERE ".implode(" AND ",$whereParts);
}
$sql="SELECT {$fields} FROM `{$table}` {$whereClause}";
if(!empty($order)){
$sql.=" ORDER BY {$order}";
}
if($limit>0){
$sql.=" LIMIT {$limit}";
if($offset>0){
$sql.=" OFFSET {$offset}";
}
}
$stmt=$this->pdo->prepare($sql);
$stmt->execute($params);
return$stmt->fetchAll();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 更新数据
* @param string $table 表名
* @param array $data 要更新的数据关联数组
* @param array $conditions 更新条件关联数组
* @return int|bool 成功返回受影响的行数，失败返回false
*/
publicfunctionupdate($table,$data,$conditions){
if(!$this->isConnected){
$this->connect();
}
if(empty($data)){
$this->error="更新数据不能为空";
returnfalse;
}
if(empty($conditions)){
$this->error="更新条件不能为空";
returnfalse;
}
try{
$setParts=[];
$setParams=[];
foreach($dataas$key=>$value){
$setParts[]="`{$key}` = :set_{$key}";
$setParams[":set_{$key}"]=$value;
}
$whereParts=[];
$whereParams=[];
foreach($conditionsas$key=>$value){
$whereParts[]="`{$key}` = :cond_{$key}";
$whereParams[":cond_{$key}"]=$value;
}
$sql="UPDATE `{$table}` SET ".implode(", ",$setParts).
" WHERE ".implode(" AND ",$whereParts);
$stmt=$this->pdo->prepare($sql);
$stmt->execute(array_merge($setParams,$whereParams));
return$stmt->rowCount();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 删除数据
* @param string $table 表名
* @param array $conditions 删除条件关联数组
* @return int|bool 成功返回受影响的行数，失败返回false
*/
publicfunctiondelete($table,$conditions){
if(!$this->isConnected){
$this->connect();
}
if(empty($conditions)){
$this->error="删除条件不能为空";
returnfalse;
}
try{
$whereParts=[];
$params=[];
foreach($conditionsas$key=>$value){
$whereParts[]="`{$key}` = :{$key}";
$params[":{$key}"]=$value;
}
$sql="DELETE FROM `{$table}` WHERE ".implode(" AND ",$whereParts);
$stmt=$this->pdo->prepare($sql);
$stmt->execute($params);
return$stmt->rowCount();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 执行原始SQL查询
* @param string $sql SQL语句
* @param array $params 参数数组
* @return array|int|bool 对于SELECT返回结果数组，对于INSERT/UPDATE/DELETE返回受影响行数，失败返回false
*/
publicfunctionquery($sql,$params=[]){
if(!$this->isConnected){
$this->connect();
}
try{
$stmt=$this->pdo->prepare($sql);
$stmt->execute($params);
// 判断查询类型
$firstWord=strtoupper(strtok(trim($sql)," "));
if($firstWord==='SELECT'||$firstWord==='SHOW'||$firstWord==='DESCRIBE'){
return$stmt->fetchAll();
}else{
return$stmt->rowCount();
}
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 开始事务
* @return bool 成功返回true，否则返回false
*/
publicfunctionbeginTransaction(){
if(!$this->isConnected){
$this->connect();
}
try{
return$this->pdo->beginTransaction();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 提交事务
* @return bool 成功返回true，否则返回false
*/
publicfunctioncommit(){
try{
return$this->pdo->commit();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 回滚事务
* @return bool 成功返回true，否则返回false
*/
publicfunctionrollBack(){
try{
return$this->pdo->rollBack();
}catch(PDOException$e){
$this->error=$e->getMessage();
returnfalse;
}
}
/**
* 获取错误信息
* @return string 错误信息
*/
publicfunctiongetError(){
return$this->error;
}
/**
* 检查是否已连接
* @return bool 已连接返回true，否则返回false
*/
publicfunctionisConnected(){
return$this->isConnected;
}
/**
* 防止对象被克隆
*/
privatefunction__clone(){}
}
// 使用示例
/*
// 创建数据库实例
$db=newDatabase('localhost','root','password');
// 连接数据库
if(!$db->connect()){
die("连接失败: ".$db->getError());
}
// 创建数据库
if(!$db->createDatabase('my_app')){
die("创建数据库失败: ".$db->getError());
}
// 选择数据库
if(!$db->selectDatabase('my_app')){
die("选择数据库失败: ".$db->getError());
}
// 创建表
$columns=[
"id INT(11) AUTO_INCREMENT PRIMARY KEY",
"name VARCHAR(255) NOT NULL",
"email VARCHAR(255) NOT NULL UNIQUE",
"password VARCHAR(255) NOT NULL",
"created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP"
];
if(!$db->createTable('users',$columns)){
die("创建表失败: ".$db->getError());
}
// 插入数据
$userId=$db->insert('users',[
'name'=>'张三',
'email'=>'zhangsan@example.com',
'password'=>password_hash('123456',PASSWORD_DEFAULT)
]);
if($userId===false){
die("插入数据失败: ".$db->getError());
}
echo"插入成功，用户ID: ".$userId. "<br>";
// 查询数据
$users=$db->select('users',['name'=>'张三'],'*','id DESC',10);
if($users===false){
die("查询数据失败: ".$db->getError());
}
echo "查询结果:<pre>";
print_r($users);
echo "</pre>";
// 更新数据
$affectedRows=$db->update('users',['name'=>'李四'],['id'=>$userId]);
if($affectedRows===false){
die("更新数据失败: ".$db->getError());
}
echo "更新了 {$affectedRows} 条记录<br>";
// 删除数据
$affectedRows=$db->delete('users',['id'=>$userId]);
if($affectedRows===false){
die("删除数据失败: ".$db->getError());
}
echo "删除了 {$affectedRows} 条记录<br>";
// 关闭连接
$db->disconnect();
*/
?>二、该代码的设计特点
1. 安全性：
· 使用PDO预处理语句防止SQL注入
· 参数化查询确保数据安全
· 输入验证和错误处理
2. 稳定性：
· 完善的异常处理机制
· 连接状态管理
· 事务支持保证数据一致性
3. 高效性：
· 使用PDO扩展，性能优异
· 连接复用
· 灵活的查询方法
4. 易用性：
· 简洁的API设计
· 详细的文档注释
· 丰富的使用示例
三、该代码使用说明
1. 实例化数据库对象：
$db=newDatabase('localhost','username','password');2. 连接数据库：
if(!$db->connect()){
die("连接失败: ".$db->getError());
}3. 创建数据库：
$db->createDatabase('database_name');4. 选择数据库：
$db->selectDatabase('database_name');5. 创建表：
$columns=[
"id INT(11) AUTO_INCREMENT PRIMARY KEY",
"name VARCHAR(255) NOT NULL",
// 更多列定义...
];
$db->createTable('table_name',$columns);6. 插入数据：
$id=$db->insert('table_name',[
'column1'=>'value1',
'column2'=>'value2'
]);7. 查询数据：
$results=$db->select('table_name',
['condition_column'=>'value'],
'*',
'id DESC',
10,
0);8. 更新数据：
$affected=$db->update('table_name',
['column1'=>'new_value'],
['id'=>1]);9. 删除数据：
$affected=$db->delete('table_name',['id'=>1]);10. 使用事务：
$db->beginTransaction();
// 执行多个操作...
if($everythingOk){
$db->commit();
}else{
$db->rollBack();
}四、该代码使用注意事项
1. 在生产环境中，请确保数据库凭据的安全存储
2. 对于高并发应用，考虑使用连接池技术
3. 定期备份重要数据
4. 根据实际需求调整PDO选项和MySQL配置
这个数据库操作类提供了基本但完整的数据库操作功能，您可以很容易根据实际项目需求进行扩展和优化，十分容易上手！