相关关键词
关于我们
最新文章
php mysql数据库操作类(实例讲解)
发布日期:2017-08-06 00:00:00
66
接着稍微说说整体的思路。整个类的封装,包含一个连接数据库的私有属性$conn和若干操作函数。$conn在对象实例化的时候,由构造函数处理传入的参数后返回一个资源型的连接句柄。而后即可通过调用该实例化的对象的相应方法对数据库进行增删查改的操作。
talk less and show code:
<?php /** *以下代码用于数据库操作类的封装 * * @author rex<rex.sp.li@aliyun.com> * @version 1.0 * @since 2015 */ class Mysql{ //数据库连接返回值 private $conn; /** * [构造函数,返回值给$conn] * @param [string] $hostname [主机名] * @param [string] $username[用户名] * @param [string] $password[密码] * @param [string] $dbname[数据库名] * @param [string] $charset[字符集] * @return [null] */ function __construct($hostname,$username,$password,$dbname,$charset='utf8'){ $conn = @mysql_connect($hostname,$username,$password); if(!$conn){ echo '连接失败,请联系管理员'; exit; } $this->conn = $conn; $res = mysql_select_db($dbname); if(!$res){ echo '连接失败,请联系管理员'; exit; } mysql_set_charset($charset); } function __destruct(){ mysql_close(); } /** * [getAll 获取所有信息] * @param [string] $sql [sql语句] * @return [array] [返回二维数组] */ function getAll($sql){ $result = mysql_query($sql,$this->conn); $data = array(); if($result && mysql_num_rows($result)>0){ while($row = mysql_fetch_assoc($result)){ $data[] = $row; } } return $data; } /** * [getOne 获取单条数据] * @param [string] $sql [sql语句] * @return [array] [返回一维数组] */ function getOne($sql){ $result = mysql_query($sql,$this->conn); $data = array(); if($result && mysql_num_rows($result)>0){ $data = mysql_fetch_assoc($result); } return $data; } /** * [getOne 获取单条数据] * @param [string] $table [表名] * @param [string] $data [由字段名当键,属性当键值的一维数组] * @return [type] [返回false或者插入数据的id] */ function insert($table,$data){ $str = ''; $str .="INSERT INTO `$table` "; $str .="(`".implode("`,`",array_keys($data))."`) "; $str .=" VALUES "; $str .= "('".implode("','",$data)."')"; $res = mysql_query($str,$this->conn); if($res && mysql_affected_rows()>0){ return mysql_insert_id(); }else{ return false; } } /** * [update 更新数据库] * @param [string] $table [表名] * @param [array] $data [更新的数据,由字段名当键,属性当键值的一维数组] * @param [string] $where [条件,‘字段名'=‘字段属性'] * @return [type] [更新成功返回影响的行数,更新失败返回false] */ function update($table,$data,$where){ $sql = 'UPDATE '.$table.' SET '; foreach($data as $key => $value){ $sql .= "`{$key}`='{$value}',"; } $sql = rtrim($sql,','); $sql .= " WHERE $where"; $res = mysql_query($sql,$this->conn); if($res && mysql_affected_rows()){ return mysql_affected_rows(); }else{ return false; } } /** * [delete 删除数据] * @param [string] $table [表名] * @param [string] $where [条件,‘字段名'=‘字段属性'] * @return [type] [成功返回影响的行数,失败返回false] */ function del($table,$where){ $sql = "DELETE FROM `{$table}` WHERE {$where}"; $res = mysql_query($sql,$this->conn); if($res && mysql_affected_rows()){ return mysql_affected_rows(); }else{ return false; } } }