Home > Article > Backend Development > PHP数据操作种
PHP数据操作种
- WBOYOriginal
- 2016-06-13 13:11:34836browse
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;
?
Statement：
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Previous article： PHP下传文件 Next article： PHP幻术函数执行时间和顺序解析