首页 > 代码库 > 数据库操作类,链式操作
数据库操作类,链式操作
<?phpdefine(‘MY_DBHOST‘, ‘localhost‘);define(‘MY_PORT‘, ‘3306‘);define(‘MY_DBUSER‘, ‘root‘);define(‘MY_DBPW‘, ‘123456‘);define(‘MY_DBNAME‘, ‘test‘);define(‘MY_DBCHARSET‘, ‘utf8‘);define(‘MY_DBTABLEPRE‘, ‘pre_‘);function M($table,$database=‘‘,$pre=‘‘){ if(empty($database)){ $db=new MYSQL(MY_DBHOST,MY_PORT,MY_DBUSER,MY_DBPW,MY_DBNAME,MY_DBTABLEPRE,MY_DBCHARSET); } else{ $db=new MYSQL(MY_DBHOST,MY_PORT,MY_DBUSER,MY_DBPW,$database,$pre,MY_DBCHARSET); } return $db->table($table);}/** * MySQL 数据库操作工具类, 方便数据库操作. */class MYSQL{ private $conn; private $pre; private $where; private $limit; private $order; private $field; public function __construct($host,$port,$user,$pw,$db,$pre,$charset){ if(!$this->conn){ $server = $host.‘:‘.$port; $this->conn = mysql_connect($server, $user, $pw, true) or die(‘connect db error‘); $this->pre=$pre; mysql_select_db($db,$this->conn) or die(‘select db error‘); if($charset){ mysql_query("set names " . $charset, $this->conn); } } } public function __destruct(){ if($this->conn){ mysql_close($this->conn); } } /* 快捷找到一行记录 */ public function find(){ $result=$this->query($this->sql()); if(!$result){ return false; } else{ return $result[0]; } } /* 选择所有的资源 */ public function select(){ return $this->query($this->sql()); } /* 获取某行记录的某个字段 */ public function getField($field){ $this->field=$field; $result=$this->query($this->sql()); if(!$result){ return false; } return $result[0][$field]; } /* 设置某行记录的某个字段 */ public function setField($field,$value){ $sql=‘update ‘.$this->table.‘ set `‘.$field.‘`=‘.‘\‘‘.$value.‘\‘ ‘.$this->where; $this->execute($sql); } /* 统计 */ public function count(){ $sql=‘select count(*) as ask_count from ‘.$this->table.‘ ‘.$this->where.‘ limit 0,1‘; $result=$this->query($sql); return $result[0][‘ask_count‘]; } public function sum($field){ $sql=‘select sum(‘.$field.‘) as ask_sum from ‘.$this->table.‘ ‘.$this->where; $result=$this->query($sql); return $result[0][‘ask_sum‘]; } /* 添加记录 */ public function add($data){ $fields=array(); $values=array(); foreach($data as $k=>$v){ $fields[]=‘`‘.$k.‘`‘; $values[]=‘\‘‘.$v.‘\‘‘; } $sql="insert ".$this->table.‘ (‘.implode(‘,‘,$fields).‘) values (‘.implode(‘,‘,$values).‘)‘; $this->execute($sql); return mysql_insert_id($this->conn); } /* 更新添加记录 */ public function readd($data){ $fields=array(); $values=array(); foreach($data as $k=>$v){ $fields[]=‘`‘.$k.‘`‘; $values[]=‘\‘‘.$v.‘\‘‘; } $sql="replace into ".$this->table.‘ (‘.implode(‘,‘,$fields).‘) values (‘.implode(‘,‘,$values).‘)‘; $this->execute($sql); return mysql_insert_id($this->conn); } /* 更新记录 */ public function save($data){ $new=array(); foreach($data as $k=>$v){ $new[]=‘`‘.$k.‘`=\‘‘.$v.‘\‘‘; } $sql=‘update ‘.$this->table.‘ set ‘.implode(‘,‘,$new).‘ ‘.$this->where; $this->execute($sql); } /* 删除记录 */ public function delete(){ $sql=‘delete from ‘.$this->table.‘ ‘.$this->where; $this->execute($sql); } /* 执行原生的SQL */ public function query($sql){ $result=mysql_query($sql,$this->conn); if($result === false){ return false; } if(mysql_num_rows($result)==0){ return false; } $data=array(); while($row=mysql_fetch_assoc($result)){ $data[]=$row; } $this->resetsql(); return $data; } /* 生成SQL并执行返回结果资源 */ public function execute($sql){ mysql_query($sql,$this->conn); $this->resetsql(); } /* 设置where */ public function where($map){ $this->where=‘where ‘.$map; return $this; } public function error(){ return mysql_error($this->conn); } /* 设置order */ public function order($order){ $this->order=‘order by ‘.$order; return $this; } /* 设置limit */ public function limit($limit){ if(is_numeric($limit)){ $this->limit=‘limit 0,‘.$limit; } else{ $this->limit=‘limit ‘.$limit; } return $this; } /* 设置field */ public function field($field){ $this->field=$field; return $this; } /* 设置table */ public function table($table){ $this->table=$this->pre.$table; return $this; } /* 生成查询sql */ public function sql(){ $sql=‘select‘; if($this->field){ $sql.=‘ ‘.$this->field.‘ from‘; } else{ $sql.=‘ * from‘; } $sql.=‘ ‘.$this->table; if($this->where){ $sql.=‘ ‘.$this->where; } if($this->order){ $sql.=‘ ‘.$this->order; } if($this->limit){ $sql.=‘ ‘.$this->limit; } //echo $sql.‘<br>‘; return $sql; } /* 查询完毕以后清空 */ Public function resetsql(){ $this->field=‘‘; $this->order=‘‘; $this->limit=‘‘; $this->where=‘‘; } /* 解析MYSQL的返回结果 */ private function parseResult($result,$find=false,$reset=true){ if(mysql_num_rows($result)==0){ return false; } if($find){ return mysql_fetch_assoc($result); } $data=array(); while($row=mysql_fetch_assoc($result)){ $data[]=$row; } if($reset){ $this->resetsql(); } return $data; }}?>
数据库操作类,链式操作
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。