论坛首页 → 编程语言技术论坛 →

1.MYSQL操作类, 连贯操作, 缓存

浏览 8065 次
锁定老帖子 主题：1.MYSQL操作类, 连贯操作, 缓存
精华帖 (0) :: 良好帖 (0) :: 新手帖 (0) :: 隐藏帖 (0)
作者 正文
  • hudeyong926
  • 等级: 一星会员
  • 文章: 16
  • 积分: 150
  • 来自: 武汉
   发表时间：2011-01-20   最后修改：2011-07-01
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;
  • PDO.zip (2.8 KB)
  • 下载次数: 25
返回顶楼
         
  • 天梯梦
  • 等级: 初级会员
  • 性别:
  • 文章: 16
  • 积分: 30
  • 来自: 洛杉矶
   发表时间：2011-02-08  
wow~  Good job !
返回顶楼
          回帖地址
0 请登录后投票
  • hateeyes
  • 等级: 初级会员
  • 性别:
  • 文章: 26
  • 积分: 30
  • 来自: 长沙
   发表时间：2011-02-11  
PHP写成这样，不就是java了吗？？？
返回顶楼
          回帖地址
0 请登录后投票
  • giginet
  • 等级: 四星会员
  • 性别:
  • 文章: 222
  • 积分: 429
  • 来自: 南京
   发表时间：2011-02-11  
这个类不错，收下了。
返回顶楼
          回帖地址
0 请登录后投票
  • hxangel
  • 等级: 初级会员
  • 性别:
  • 文章: 11
  • 积分: 30
  • 来自: 苏州
   发表时间：2011-03-01  
hateeyes 写道
PHP写成这样，不就是java了吗？？？

我也是这样认为的
返回顶楼
          回帖地址
0 请登录后投票
论坛首页 → 编程语言技术版

跳转论坛:
Global site tag (gtag.js) - Google Analytics