PHP8PDOMYSQL示例资源-CSDN文库

共3个文件

php：3个

14 浏览量 2024-05-18 09:26:40 上传评论收藏 4KB ZIP 举报

在本文中，我们将深入探讨如何在PHP8中使用PDO（PHP Data Objects）扩展与MySQL数据库进行交互。PHP8是PHP的最新版本，提供了许多性能优化和新特性，而PDO则是一个用于数据库访问的抽象层，它支持多种数据库系统，包括MySQL。我们将通过描述中的关键点来构建一个基础的CRUD（创建、读取、更新和删除）操作框架，并讨论如何实现这些功能。 `db.func.php`可能是包含数据库操作函数的文件，如连接、执行SQL语句和处理结果。这些函数通常被设计为封装数据库交互，使其更易于管理和维护。在PHP8中，我们需要注意的是，错误处理方式已经发生了变化，从之前的E_STRICT级别错误提升到了致命错误。因此，编写代码时需要确保对可能的错误进行捕获和处理。 `database.php`可能包含了数据库连接的配置信息，如数据库主机名、用户名、密码和数据库名。例如： ```php <?php $host = 'localhost'; $dbname = 'your_database_name'; $username = 'your_username'; $password = 'your_password'; try { $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { echo "Connection failed: " . $e->getMessage(); } ?> ``` 这里的`PDO::ATTR_ERRMODE`设置为`PDO::ERRMODE_EXCEPTION`，意味着任何数据库错误都将抛出异常，便于我们捕获并处理。接下来是`demo.php`，这个文件可能是展示如何使用这些函数的示例代码。以下是一些常见操作的示例： 1. **创建（Create）**: 插入新数据到表中。 ```php function createRecord($pdo, $data) { $columns = implode(', ', array_keys($data)); $values = ':' . implode(', :', array_keys($data)); $stmt = $pdo->prepare("INSERT INTO your_table ($columns) VALUES ($values)"); foreach ($data as $key => $value) { $stmt->bindParam(':' . $key, $value); } return $stmt->execute(); } ``` 2. **读取（Read）**: 根据主键值查询单条记录。 ```php function readRecordById($pdo, $id) { $stmt = $pdo->prepare("SELECT * FROM your_table WHERE id = ?"); $stmt->bindParam(1, $id); $stmt->execute(); return $stmt->fetch(PDO::FETCH_ASSOC); } ``` 3. **更新（Update）**: 根据主键值更新记录，自动匹配存在的字段。 ```php function updateRecord($pdo, $id, $data) { $setClause = ''; foreach ($data as $key => $value) { $setClause .= "$key = :$key, "; } $setClause = rtrim($setClause, ', '); $stmt = $pdo->prepare("UPDATE your_table SET $setClause WHERE id = ?"); foreach ($data as $key => $value) { $stmt->bindParam(":$key", $value); } $stmt->bindParam(1, $id); return $stmt->execute(); } ``` 4. **删除（Delete）**: 删除特定主键值的记录。 ```php function deleteRecordById($pdo, $id) { $stmt = $pdo->prepare("DELETE FROM your_table WHERE id = ?"); $stmt->bindParam(1, $id); return $stmt->execute(); } // 分页查询 function paginateRecords($pdo, $limit, $offset) { $stmt = $pdo->prepare("SELECT * FROM your_table LIMIT ?, ?"); $stmt->bindParam(1, $offset); $stmt->bindParam(2, $limit); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } // 统计SUM或COUNT function aggregateQuery($pdo, $column, $aggFunction) { $stmt = $pdo->prepare("SELECT $aggFunction($column) FROM your_table"); $stmt->execute(); return $stmt->fetchColumn(); } // 返回多条记录中某个字段并组成数组 function getFieldArray($pdo, $column) { $stmt = $pdo->prepare("SELECT $column FROM your_table"); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_COLUMN); } ``` 以上代码展示了如何使用PHP8的PDO功能与MySQL进行交互，实现基本的数据库操作。通过封装这些函数，我们可以轻松地在项目中复用和管理数据库交互逻辑。在实际应用中，你可能还需要添加额外的错误检查、事务处理、数据验证等功能，以提高代码的健壮性和安全性。

资源推荐

资源详情

资源评论

收起资源包目录

mysql.zip （3个子文件）

demo.php 71B

database.php 231B

db.func.php 11KB

<?php function db_backup($table){ global $DB; $connection=$DB; $tableName=$table; try{ $connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 备份表结构 $structureQuery = "SHOW CREATE TABLE `{$tableName}`"; $structureResult = $connection->query($structureQuery); $structureRow = $structureResult->fetch(PDO::FETCH_NUM); $structure = $structureRow[1]; // 备份表数据 $dataQuery = "SELECT * FROM `{$tableName}`"; $dataResult = $connection->query($dataQuery); $data = ''; while ($row = $dataResult->fetch(PDO::FETCH_ASSOC)) { $rowValues = []; foreach ($row as $value) { $rowValues[] = $connection->quote($value); } $data .= 'INSERT INTO `' . $tableName . '` VALUES (' . implode(', ', $rowValues) . ');' . PHP_EOL; } $backupPath = ROOT_PATH."/#bak#/mysql/{$table}.sql"; // echo $backupPath; // 保存备份到文件 $rs=file_put_contents($backupPath, $structure . ';' . PHP_EOL . $data); // var_dump($rs); // 备份成功提示 // echo "表 '{$tableName}' 备份成功！"; return true; } catch (PDOException $e) { return false; // die('备份失败: ' . $e->getMessage()); } } function db_insert($table, $data) { global $DB; $columns=db_columns($table); foreach ($data as $k => $v) { if(in_array($k,$columns)){ $fields[] = $v; $keys[] = $k; } } $values = "('" . implode("','", $fields) . "')"; $column = "(`" . implode("`,`", $keys) . "`)"; $sql = "REPLACE INTO {$table} {$column} values {$values}"; //exit(htmlentities($sql)); $cid = $DB->exec($sql); return $DB->lastInsertId(); } //适用于字段=字段+val等修改 function db_exec($sql){ global $DB; $cid = $DB->exec($sql); return $cid; } //获取主键字段字符串 function db_get_primary_key($table){ global $redis; $rkey="$table:PRI"; if ($redis->exists($rkey)) { return $redis->get($rkey); } $columns=db_columns2($table); $key=""; $columns2=[]; foreach($columns as $k=>$v){ if($v['Key']=="PRI"){ $key=$v["Field"]; } $columns2[]=$v["Field"]; } if(in_array("id_str",$columns2)){//特殊处理，阮工的数据库表id为无意义主键，实际id_str才是真正的主键，但是数据库中没有标识为主键 $key="id_str"; } if($key){ $redis->setex($rkey, 60, $key); return $key; } return false; } function db_columns2($table){//比较占CPU，如果在db_value中调用db_columns的话服务器CPU就会增加 $columns=db_get_list("SHOW FULL COLUMNS FROM $table"); // $rs=[]; // foreach($columns as $item){ // $rs[]=$item['Field']; // } return $columns; } function db_columns($table){//比较占CPU，如果在db_value中调用db_columns的话服务器CPU就会增加 $dbconfig = include DB_DIR."database.php"; $columns=db_get_list("select COLUMN_NAME from information_schema.COLUMNS where `table_schema`='{$dbconfig['dbname']}' AND `table_name` = '$table'"); $rs=[]; foreach($columns as $item){ $rs[]=$item['COLUMN_NAME']; } return $rs; } //好像没啥用 function db_tables(){ $dbconfig = include DB_DIR."database.php"; $tables=db_get_list("select TABLE_NAME as name,TABLE_COMMENT as remark from information_schema.tables where table_schema='{$dbconfig['dbname']}' and table_type='base table'"); return $tables; } function db_count($table,$where=" 1=1 ",$group=""){ if($group){ $rs=db_query_list($table,"COUNT(*) AS count",$where,group:$group); return $rs?count($rs):0; }else{ $rs=db_query_one($table,"COUNT(*) AS count",$where,group:$group); return $rs['count']; } // var_dump($rs);exit; } function db_sum($table,$where=" 1=1 "){ $rs=db_query_one($table,"sum(*) AS sum",$where); return $rs['sum']; } //单独返回某条记录的指定列名的值，where中如果为“主键=某个值”，调用函数的时候直接填入“某个值”即可。 function db_value($table,$field,$where=" 1=1 ",$default=0){ //db_columns速度会变慢 // $columns=db_columns($table); // $field2=(!strstr($field,"`")&&in_array($field,$columns))?("`".$field."`"):$field;//schema为mysql的关键字，不加`则会报错 $field2=(!strstr($field,"`")&&!strstr($field,"("))?("`".$field."`"):$field; if(!strstr($where,"=")){//自动匹配主键 $where="`".db_get_primary_key($table)."`='{$where}'"; } $rs=db_query_one($table,$field2,$where); return $rs[$field]?$rs[$field]:$default; } function db_get_one($sql,$group='',$order=''){ global $DB; if($group){ $sql.=" GROUP BY ".$group." "; } if($order){ $sql.=" ORDER BY ".$order." "; } if(LOG_FLAG){ file_put_contents("./log/sql/".date("Y-m-d").".log", date("Y-m-d H:i:s",time())." ".$sql."\r\n",FILE_APPEND);//20191115 } $row = $DB->query($sql)->fetch(PDO::FETCH_ASSOC); if($row){ foreach($row as $k=>$v){ if($v==null){ $row[$k]=""; } } } return $row; } //private内部，一般不使用 function db_query_one($table,$fields="*",$where=" 1=1 ",$group="",$order=""){ return db_get_one(get_sql($table,$fields,$where),$group,$order); } function db_query_list($table,$fields="*",$where=" 1=1 ",$group='',$order='',$limit=''){ return db_get_list(get_sql($table,$fields,$where),$group,$order,$limit); } //private内部，一般不使用 function get_sql($table,$fields="*",$where=" 1=1 "){ return "SELECT $fields FROM $table WHERE $where"; } //private内部，一般不使用 function db_get_list($sql,$group='',$order='',$limit=''){ global $DB; if($group){ $sql.=" GROUP BY ".$group." "; } if($order){ $sql.=" ORDER BY ".$order." "; } if($limit){ $sql.=" LIMIT ".$limit." "; } if(LOG_FLAG){ file_put_contents("./log/sql/".date("Y-m-d").".log", date("Y-m-d H:i:s",time())." ".$sql."\r\n",FILE_APPEND);//20191115 } $rs=$DB->query($sql); $list=array(); while ($row = $rs->fetch(PDO::FETCH_ASSOC)) { foreach($row as $k=>$v){ if($v==null){ $row[$k]=""; } } $list[]=$row; } return $list; } function db_delete($table, $where="") { global $DB; $sql = "DELETE FROM `{$table}` WHERE 1=1 ".($where==""?"":" AND {$where}"); $cid = $DB->exec($sql); return $cid; } function db_update($table, $data, $where="") { global $DB; $data_arr=array(); $columns=db_columns($table); // var_dump($columns); // var_dump($data);exit; foreach ($data as $k => $v) { if(in_array($k,$columns)){ if(strstr($v,"'")){//处理a=concat(a,'b')的情况，字段追加 $data_arr[]=" `$k`=$v "; }else{ $data_arr[]=" `$k`='$v' "; } } } $sql = "UPDATE `{$table}` SET ".implode(",", $data_arr). " WHERE 1=1 ".($where==""?"":" AND {$where}"); // var_dump($data_arr);exit; // ini_set("display_errors", 1); // error_reporting(E_ALL); // file_put_contents("./log/sql/".date("Y-m-d").".log", date("Y-m-d H:i:s",time())." ".$sql."\r\n",FILE_APPEND);//20220924 // echo $sql;exit; $cid = $DB->exec($sql); return $cid; } //返回某个字段的数组，方便后续in条件的输入，仅支持单列返回 function db_pluck($table,$field,$where=" 1=1 ",$group=''){ $rs=db_get_list(get_sql($table,$field,$where),$group); $pluck_rs=array(); foreach ($rs as $item){ $pluck_rs[]=$item[$field]; } //去重处理 $pluck_rs = array_unique($pluck_rs);

评论收藏

内容反馈