<?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;
分享到：
相关推荐
通过直接的方法对sqlite数据库进行操作。但好像只是支持sqlite2.对sqlite3不支持。于是又看了看原来要使用PDO进行连接。讲自己写的一个封装的代码放出来。
数据库操作类 把添加,删除,修改,单独查看,分页查看表的所有操作都封装成类,操作非常简单 如分页类:$dbXX->showFenye($len),$len为分页长度, $dbXX->up是上一页,$dbXX->down是下一页,等等 跳转类,把history,location,...
综上所述，这个“强大的通用php数据库操作类”不仅封装了基本的数据库操作，还有可能集成数据验证功能，通过优化代码提高了开发效率和系统性能。配合相应的测试文件、实用工具和配置文件，形成了一个完整的数据库...
**PHP MySQL操作类详解** 在PHP开发中，与MySQL数据库进行交互是常见的需求。为了方便高效地处理数据库操作，开发者通常会封装一个MySQL操作类，如`PHP_DataSet`。这个类可以提供一系列的方法，包括连接数据库、...
了解这些基本概念后，开发者可以利用这个PHP Oracle 数据库操作类轻松地实现数据的增删改查操作，创建复杂的业务逻辑，同时确保代码的可读性和可维护性。使用面向对象的方式处理数据库操作，不仅使代码更整洁，也...
标题中的“PHP基于pdo的数据库操作类【可支持mysql、sqlserver及oracle】”指的是一个PHP编程中的数据库操作类，该类使用PDO（PHP Data Objects）扩展，允许开发者与MySQL、SQL Server和Oracle等多种数据库系统进行...
- 在用户操作类中，对用户输入的数据进行验证至关重要，防止SQL注入、XSS攻击等安全问题。可以使用PHP内置的过滤函数如filter_var()，或者使用更强大的库如 Respect\Validation。 3. **数据库交互** - 使用预处理...
"php文件操作类.zip"可能包含一个自定义的PHP类库，专为处理文件系统操作而设计。这个类库可以帮助开发者更方便、高效地进行读取、写入、创建、删除和移动文件等任务，而无需直接调用PHP的内置文件函数。下面，我们...
"实用的PHP文件操作类"就是这样一个工具，它旨在简化常见的文件处理任务。下面我们将深入探讨PHP文件操作类的关键概念和功能。 1. **类库介绍** 这个类库很可能包含了若干个PHP类，每个类都专注于一个特定的文件或...
这款PHP MySQL操作类提供了全面的功能，涵盖了数据的查询、更新、删除等操作，适用于初学者进行学习和实践，同时也为有经验的开发者提供了一个可自定义的基础框架。下面我们将详细讨论其中涉及的关键知识点。 1. **...
在这个“php中mysql数据库操作类.zip”压缩包中，很可能包含了一个基于MySQLi或PDO实现的自定义数据库操作类。 一个基础的PHP MySQL数据库操作类通常包括以下组件： 1. **连接函数**：用于建立与MySQL服务器的连接...
在PHP7中，MySQL数据库操作通常使用mysqli或PDO_MySQL扩展进行，但对于新手来说，创建一个封装好的数据库操作类可以简化很多工作。这个实例主要介绍如何构建一个PHP7中的MySQL数据库操作类，以实现连接、查询、插入...
在这个案例中，我们有一个名为"php的数组操作类"的压缩包，它提供了一些实用方法，帮助我们更有效地对数组进行操作。下面将详细介绍这些功能及其相关知识点。 首先，该类包含了一个方法，用于从数组中删除空白元素...
本篇文章将深入探讨如何使用PHP实现一个MySQL数据库操作类，包括连接、查询、插入、更新和删除数据等核心功能。 首先，我们需要创建一个名为`MySQLDB`的类，该类将封装所有的数据库交互逻辑。以下是一个基本的类...
首先，让我们了解一个基本的PHP MySQL数据库操作类的组成部分： 1. **连接配置**：在类的初始化阶段，通常会包含数据库的连接参数，如主机名（hostname）、用户名（username）、密码（password）和数据库名...
PHP版MySQL操作类是一种将常用的MySQL数据库操作封装成类的方法，这样可以提高代码的可读性、可维护性和复用性。这个"mysql.class.php"文件很可能是包含了这样一个类的实现。 在PHP中，我们通常使用MySQLi或PDO_...
这个"php Mongodb操作类"是专为在PHP环境中与MongoDB数据库进行交互而设计的工具，允许开发者轻松地执行创建（Create）、读取（Read）、更新（Update）和删除（Delete）等基本数据库操作。 1. **MongoDB简介** ...
本资源包含一个PHP PDO数据库操作类，旨在简化数据库交互，支持多种调试模式，以适应不同开发阶段的需求。下面我们将深入探讨PDO以及这个数据库操作类的核心概念、功能和使用方法。 首先，PDO扩展提供了面向对象的...
"好用的php操作excel类"通常指的是PHP中的第三方库，这些库使得与Excel文件交互变得简单而高效。在这个场景中，我们可以关注两个主要的文件：`excel_reader2.php`和`example.php`，它们很可能包含了实现这一功能的...
这个“php memcached缓存操作类”旨在简化开发者对Memcached的使用，提供一个方便、高效的接口来处理数据缓存。本文将详细讲解PHP与Memcached结合的原理、使用方法以及该操作类的特性。 1. PHP与Memcached的连接： ...