PHP数据操作类
<?php
/**
+----------------------
* Mysql操作类
+----------------------
* 文件名称 Db.class.php
+----------------------
* 文件描述 mysql操作类
+----------------------
*/
class Db{
//数据库连接标识
protected $link = null;
//当前操作的表
public $table = '';
//查询参数
protected $options = array();
//当前执行的SQL语句
protected $sql = '';
//用什么编码传递数据
protected $dbCharset = 'utf8';
//缓存路径
protected $cachePath = './cache/';
//缓存扩展名
protected $cacheFileExt = "php";
//缓存文件名
protected $cacheFileName;
//是否缓存
protected $cache = false;
//缓存更新时间秒数
protected $cacheLimitTime = 60;
//数据返回类型, 1代表数组, 2代表对象
protected $returnType = 1;
/*
* 根据当前动态文件生成缓存文件名
*/
function setCacheFileName($fileName) {
$cacheFileName = $this->cachePath . strtoupper(md5($fileName)).".".$this->cacheFileExt;
$this->cacheFileName=$cacheFileName;
}
/*
* 根据当前动态文件生成缓存文件名
*/
function getCacheFileName() {
return $this->cacheFileName;
}
/**
* 连接数据库
*
* @access public
* @param array $db 数据库配置
* @return resource 数据库连接标识
*/
public function connect($db){
//根据配置使用不同函数连接数据库
$db['host'] = isset($db['port']) ? $db['host'].':'.$db['port']: $db['host'];
$db['char'] = isset($db['char']) ? $db['char']: $this->dbCharset;
$func = $db['pconnect'] ? 'mysql_pconnect' : 'mysql_connect';
$this->link = $func($db['host'], $db['user'], $db['pwd']);
mysql_select_db($db['database'], $this->link);
mysql_query("SET NAMES '{$db['char']}'");
$this->cachePath = isset($db['cachepath']) ? $db['cachepath']: $this->cachePath;
return $this->link;
}
/**
* 查询符合条件的一条记录
*
* @access public
* @param string $where 查询条件
* @param string $field 查询字段
* @param string $table 表
* @return mixed 符合条件的记录
*/
public function find($where = NULL, $field = '*', $table = ''){
return $this->findAll($where = NULL, $field = '*', $table = '', FALSE);
}
/**
* 查询符合条件的所有记录
*
* @access public
* @param string $where 查询条件
* @param string $field 查询字段
* @param string $table 表
* @return mixed 符合条件的记录
*/
public function findAll($where = NULL, $field = '*', $table = '', $all = TRUE){
$this->options['where'] = is_null($where) ? @$this->options['where']: $where;
$this->options['field'] = isset($this->options['field']) ? $this->options['field']: $field;
$this->options['table'] = $table == '' ? $this->table: $table;
$sql = "SELECT {$this->options['field']} FROM `{$this->options['table']}` ";
$sql .= isset($this->options['join']) ? ' LEFT JOIN '.$this->options['join']: '';
$sql .= isset($this->options['where']) ? ' WHERE '.$this->options['where']: '';
$sql .= isset($this->options['group']) ? ' GROUP BY '.$this->options['group']: '';
$sql .= isset($this->options['having']) ? ' HAVING '.$this->options['having']: '';
$sql .= isset($this->options['order']) ? ' ORDER BY '.$this->options['order']: '';
$sql .= isset($this->options['limit']) ? ' LIMIT '.$this->options['limit']: '';
$this->sql = $sql;
$row = NULL;
//如果开启了缓存, 那么重缓存中获取数据
if ($this->cache === TRUE){
$this->setCacheFileName($this->sql);
$row = $this->readCache();
}
//如果读取失败, 或则没有开启缓存
if (is_null($row)){
$result = $this->query();
$row = $all === TRUE ? $this->fetchAll($result): $this->fetch($result);
//如果开启了缓存, 那么就写入
if ($this->cache === TRUE){
$this->writeCache($row);
}
$this->options = array();
}
return $row;
}
/**
* 读取结果集中的所有记录到数组中
*
* @access public
* @param resource $result 结果集
* @return array
*/
public function fetchAll($result = NULL){
$rows = array();
while ($row = $this->fetch($result)){
$rows[] = $row;
}
return $rows;
}
/**
* 读取结果集中的一行记录到数组中
*
* @access public
* @param resource $result 结果集
* @param int $type 返回类型, 1为数组, 2为对象
* @return mixed 根据返回类型返回
*/
public function fetch($result = NULL, $type = NULL){
$result = is_null($result) ? $this->result: $result;
$type = is_null($type) ? $this->returnType: $type;
$func = $type === 1 ? 'mysql_fetch_assoc' : 'mysql_fetch_object';
return $func($result);
}
/**
* 执行SQL命令
*
* @access public
* @param string $sql SQL命令
* @param resource $link 数据库连接标识
* @return mixed 数据库结果集
*/
public function query($sql = '', $link = NULL){
$sql = empty($sql) ? $this->sql: $sql;
$link = is_null($link) ? $this->link: $link;
$this->result = mysql_query($sql, $link);
if (is_resource($this->result)){
return $this->result;
}
//如果执行SQL出现错误, 那么抛出异常
exit('<strong>Mysql error:</strong>'.$this->getError());
}
/**
* 执行SQL命令
*
* @access public
* @param string $sql SQL命令
* @param resource $link 数据库连接标识
* @return bool 是否执行成功
*/
public function execute($sql = '', $link = NULL){
$sql = empty($sql) ? $this->sql: $sql;
$link = is_null($link) ? $this->link: $link;
if (mysql_query($sql, $link)){
return TRUE;
}
return FALSE;
}
/**
* 插入记录
*
* @access public
* @param array $data 插入的记录, 格式:array('字段名'=>'值', '字段名'=>'值');
* @param string $table 表名
* @return bool 当前记录id
*/
public function add($data, $table = NULL){
$table = is_null($table) ? $this->table: $table;
$sql = "INSERT INTO `{$table}`";
$fields = $values = array();
$field = $value = '';
//遍历记录, 格式化字段名称与值
foreach($data as $key => $val){
$fields[] = "`{$table}`.`{$key}`";
$values[] = is_numeric($val) ? $val : "'{$val}'";
}
$field = join(',', $fields);
$value = join(',', $values);
unset($fields, $values);
$sql .= "({$field}) VALUES({$value})";
$this->sql = $sql;
$this->execute();
return $this->insertId();
}
/**
* 删除记录
*
* @access public
* @param string $where 条件
* @param string $table 表名
* @return bool 影响行数
*/
public function delete($where = NULL, $table = NULL){
$table = is_null($table) ? $this->table: $table;
$where = is_null($where) ? @$this->options['where']: $where;
$sql = "DELETE FROM `{$table}` WHERE {$where}";
$this->sql = $sql;
$this->execute();
return $this->affectedRows();
}
/**
* 更新记录
*
* @access public
* @param array $data 更新的数据 格式:array('字段名' => 值);
* @param string $where 更新条件
* @param string $table 表名
* @return bool 影响多少条信息
*/
public function update($data, $where = NULL, $table = NULL){
$table = is_null($table) ? $this->table: $table;
$where = is_null($where) ? @$this->options['where']: $where;
$sql = "UPDATE `{$table}` SET ";
$values = array();
foreach($data as $key => $val){
$val = is_numeric($val) ? $val : "'{$val}'";
$values[] = "`{$table}`.`{$key}` = {$val}";
}
$value = join(',', $values);
$this->sql = $sql.$value." WHERE {$where}";
$this->execute();
return $this->affectedRows();
}
/**
* 读取缓存
*
* @access public
* @return mixed 如果读取成功返回缓存内容, 否则返回NULL
*/
protected function readCache(){
$file = $this->getCacheFileName();
if (file_exists($file)){
//缓存过期
if ((filemtime($file) + $this->cacheLimitTime) < time()){
@unlink($file);
return NULL;
}
if (1 === $this->returnType){
$row = include $file;
}
else{
$data = file_get_contents($file);
$row = unserialize($data);
}
return $row;
}
return NULL;
}
/**
* 写入缓存
*
* @access public
* @param mixed $data 缓存内容
* @return bool 是否写入成功
*/
public function writeCache($data){
$file = $this->getCacheFileName();
if ($this->makeDir(dirname($file))){
if (1 === $this->returnType){
$data = '<?php return '.var_export($data, TRUE).';?>';
}else{
$data = serialize($data);
}
}
return file_put_contents($file, $data);
}
/*
* 清除缓存文件
* string $fileName 指定文件名(含函数)或者all（全部）
* 返回：清除成功返回true，反之返回false
*/
function clearCache( $fileName = "all" ) {
if( $fileName != "all" ) {
if( file_exists( $fileName ) ) {
return @unlink( $fileName );
}else return false;
}
if ( is_dir( $this->cachePath ) ) {
if ( $dir = @opendir( $this->cachePath ) ) {
while ( $file = @readdir( $dir ) ) {
$check = is_dir( $file );
if ( !$check )
@unlink( $this->cachePath . $file );
}
@closedir( $dir );
return true;
}else{
return false;
}
}else{
return false;
}
}
/*
* 连续建目录
* string $dir 目录字符串
* int $mode 权限数字
* 返回：顺利创建或者全部已建返回true，其它方式返回false
*/
function makeDir( $dir, $mode = "0777" ) {
if( ! $dir ) return 0;
$dir = str_replace( "\\", "/", $dir );
$mdir = "";
foreach( explode( "/", $dir ) as $val ) {
$mdir .= $val."/";
if( $val == ".." || $val == "." || trim( $val ) == "" ) continue;
if( ! file_exists( $mdir ) ) {
if(!@mkdir( $mdir, $mode )){
return false;
}
}
}
return true;
}
//自动加载函数, 实现特殊操作
public function __call($func, $args)
{
if(in_array($func, array('field', 'join', 'where', 'order', 'group', 'limit', 'having')))
{
$this->options[$func] = array_shift($args);
return $this;
} elseif($func === 'table'){
$this->options['table'] = array_shift($args);
$this->table = $this->options['table'];
return $this;
}
//如果函数不存在, 则抛出异常
exit('Call to undefined method Db::' . $func . '()');
}
//-------------------------------------------
//返回上一次操作所影响的行数
public function affectedRows($link = null){
$link = is_null($link) ? $this->link : $link;
return mysql_affected_rows($link);
}
//返回上一次操作记录的id
public function insertId($link = null){
$link = is_null($link) ? $this->link : $link;
return mysql_insert_id($link);
}
//清空结果集
public function free($result = null){
$result = is_null($result) ? $this->result : $result;
return mysql_free_result($result);
}
//返回错误信息
public function getError($link = NULL){
$link = is_null($link) ? $this->link : $link;
return mysql_error($link);
}
//返回错误编号
public function getErrno($link = NULL){
$link = is_null($link) ? $this->link : $link;
return mysql_errno($link);
}
}
?>
?调用方法：
<?php
include ('DB.php'); //引入类文件
$db = new Db(); //实例化mysql操作类
//数据库配置信息数组
$config['host'] = 'localhost'; //mysql主机
$config['user'] = 'root'; //用户
$config['pwd'] = ''; //密码
$config['port'] = '3306'; //端口
$config['database'] = 'message'; //数据库
$config['char'] = 'utf8'; //字符集
$config['pconnect'] = FALSE; //是否使用持久性连接
$link = $db->connect($config); //传入配置, 连接数据库, $link为连接标识
$rows = $db->table('test')->field('*')->order('id DESC')->limit(0, 10)->findAll();
//上面的操作, 相当于执行SQL命令: SELECT * FROM test ORDER BY id DESC LIMIT 0, 10;
print_r($db->getCacheFileName());
//$db->clearCache($db->getCacheFileName());
//$db->clearCache();
// 执行的效果和上面相同, 但是多了一个cache方法,也就缓存了这次查询 cache()有三个参数, cache(缓存名称, 有效时间, 缓存路径); 缓存名称默认是使用md5(SQL命令)为名称, 有效时间默认为1分钟, 缓存路径可以在连接数据库时进行配置
//下面来插入一条记录
$data = array(
'name' => 'xiaokai',
'pass' => '123456',
);
$db->add($data);
// 这样就插入了一条记录 注意这里$data的格式为 array('字段名称1' => '值1', '字段名称2' => '值2', .....);
//相当于执行SQL命令: INSERT INTO test(`name`, `pass`) VALUES('xiaokai', '123456');
//朋友们可能奇怪了, add 函数并没有传入表名称啊, 为什么会执行这样的SQL命令呢?
//其实在上面查询的时候就已经使用$db->table('test')方法了, 这里已经传入了表名称, 所以在操作就不需要指定表名称了.
//有插入就有删除, 下面来删除
$db->delete('id = 10');
//这样就删除了test表中 id为10的记录
//相当于执行SQL命令: DELETE FROM test WHERE id = 10;
//这里也是一样没有传入表名称
//下面构造数组, 然后更新一条记录
$data = array(
'name' => '123456',
'pass' => 'xiaokai',
);
$db->update($data, 'id = 10');
//这样就将id为10的记录给更新了
//相当于执行SQL命令: UPDATE test set name = '123456', pass = 'xiaokai' WHERE id = 10;
?
陳述
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
使用數據庫存儲會話的優點是什麼？Apr 24, 2025 am 12:16 AM使用數據庫存儲會話的主要優勢包括持久性、可擴展性和安全性。 1.持久性：即使服務器重啟，會話數據也能保持不變。 2.可擴展性：適用於分佈式系統，確保會話數據在多服務器間同步。 3.安全性：數據庫提供加密存儲，保護敏感信息。
您如何在PHP中實現自定義會話處理？Apr 24, 2025 am 12:16 AM在PHP中實現自定義會話處理可以通過實現SessionHandlerInterface接口來完成。具體步驟包括：1)創建實現SessionHandlerInterface的類，如CustomSessionHandler；2)重寫接口中的方法（如open,close,read,write,destroy,gc）來定義會話數據的生命週期和存儲方式；3)在PHP腳本中註冊自定義會話處理器並啟動會話。這樣可以將數據存儲在MySQL、Redis等介質中，提升性能、安全性和可擴展性。
什麼是會話ID？Apr 24, 2025 am 12:13 AMSessionID是網絡應用程序中用來跟踪用戶會話狀態的機制。 1.它是一個隨機生成的字符串，用於在用戶與服務器之間的多次交互中保持用戶的身份信息。 2.服務器生成並通過cookie或URL參數發送給客戶端，幫助在用戶的多次請求中識別和關聯這些請求。 3.生成通常使用隨機算法保證唯一性和不可預測性。 4.在實際開發中，可以使用內存數據庫如Redis來存儲session數據，提升性能和安全性。
您如何在無狀態環境（例如API）中處理會議？Apr 24, 2025 am 12:12 AM在無狀態環境如API中管理會話可以通過使用JWT或cookies來實現。 1.JWT適合無狀態和可擴展性，但大數據時體積大。 2.Cookies更傳統且易實現，但需謹慎配置以確保安全性。
您如何防止與會議有關的跨站點腳本（XSS）攻擊？Apr 23, 2025 am 12:16 AM要保護應用免受與會話相關的XSS攻擊，需採取以下措施：1.設置HttpOnly和Secure標誌保護會話cookie。 2.對所有用戶輸入進行輸出編碼。 3.實施內容安全策略(CSP)限制腳本來源。通過這些策略，可以有效防護會話相關的XSS攻擊，確保用戶數據安全。
您如何優化PHP會話性能？Apr 23, 2025 am 12:13 AM优化PHP会话性能的方法包括：1.延迟会话启动，2.使用数据库存储会话，3.压缩会话数据，4.管理会话生命周期，5.实现会话共享。这些策略能显著提升应用在高并发环境下的效率。
什麼是session.gc_maxlifetime配置設置？Apr 23, 2025 am 12:10 AMtheSession.gc_maxlifetimesettinginphpdeterminesthelifespanofsessiondata，setInSeconds.1）它'sconfiguredinphp.iniorviaini_set（）.2）abalanceisesneededeededeedeedeededto toavoidperformance andunununununexpectedLogOgouts.3）
您如何在PHP中配置會話名？Apr 23, 2025 am 12:08 AM在PHP中，可以使用session_name()函數配置會話名稱。具體步驟如下：1.使用session_name()函數設置會話名稱，例如session_name("my_session")。 2.在設置會話名稱後，調用session_start()啟動會話。配置會話名稱可以避免多應用間的會話數據衝突，並增強安全性，但需注意會話名稱的唯一性、安全性、長度和設置時機。
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
刺客信條陰影：貝殼謎語解決方案
3 週前ByDDD
Windows 11 KB5054979中的新功能以及如何解決更新問題
2 週前ByDDD
在哪裡可以找到原子中的起重機控制鑰匙卡
3 週前ByDDD
<🎜>：死鐵路 - 如何完成所有挑戰
4 週前ByDDD
Atomfall指南：項目位置，任務指南和技巧
1 個月前ByDDD
熱工具
VSCode Windows 64位元 下載
微軟推出的免費、功能強大的一款IDE編輯器
ZendStudio 13.5.1 Mac
強大的PHP整合開發環境
MantisBT
Mantis是一個易於部署的基於Web的缺陷追蹤工具，用於幫助產品缺陷追蹤。它需要PHP、MySQL和一個Web伺服器。請查看我們的演示和託管服務。
記事本++7.3.1
好用且免費的程式碼編輯器
mPDF
mPDF是一個PHP庫，可以從UTF-8編碼的HTML產生PDF檔案。原作者Ian Back編寫mPDF以從他的網站上「即時」輸出PDF文件，並處理不同的語言。與原始腳本如HTML2FPDF相比，它的速度較慢，並且在使用Unicode字體時產生的檔案較大，但支援CSS樣式等，並進行了大量增強。支援幾乎所有語言，包括RTL（阿拉伯語和希伯來語）和CJK（中日韓）。支援嵌套的區塊級元素（如P、DIV），
