PHP - Mysql 类

<?php
/**
 * 数据库对外接口方法
 */
class Core_Mysql
{
    /**
     * 连接MYSQL函数
     * @param string $host
     * @param string $username
     * @param string $password
     * @param string $dbName
     * @param string $charset
     * @return resource
     */
    function connect($host,$username,$password,$dbName,$charset){
        //连接mysql
        $link=@mysql_connect($host,$username,$password) or die ('数据库连接失败<br/>ERROR '.mysql_errno().':'.mysql_error());
        //设置字符集
        mysql_set_charset($charset);
        //打开指定的数据库
        mysql_select_db($dbName)or die('指定的数据库打开失败');
        return $link;
    }
    /**
     * 连接MYSQL函数,需要在连接的时候传递一个数组
     * @param array $config
     * @return resource
     */
    function connect1 ($config){
        //连接mysql
        $link=@mysql_connect($config['dbHost'],$config['dbUser'],$config['dbPwd']) or die ('数据库连接失败<br/>ERROR '.mysql_errno().':'.mysql_error());
        //设置字符集
        mysql_set_charset($config['dbCharset']);
        //打开指定的数据库
        mysql_select_db($config['dbName']) or die('指定的数据库打开失败');
        return $link;
    }
    /**建议使用该函数
     * 连接MYSQL函数,通过常量的形式来连接数据库
     * 自定义配置文件,配置文件中自定义常量,包含需要使用的信息
     * @return resource
     */
    function connect2 (){
        //连接mysql
        $link=@mysql_connect(DB_HOST,DB_USER,DB_PWD) or die ('数据库连接失败<br/>ERROR '.mysql_errno().':'.mysql_error());
        //设置字符集
        mysql_set_charset(DB_CHARSET);
        //打开指定的数据库
        mysql_select_db(DB_DBNAME) or die('指定的数据库打开失败');
        return $link;
    }
    /* array(
    'username'=>'king',
    'password'=>'123123',
    'email'=>'dh@qq.com'
    ) */
    /**
     * 插入记录的操作
     * @param array $array
     * @param string $table
     * @return boolean
     */
    function insert($array,$table,$conn){
        $keys=join(',',array_keys($array));
        $values="'".join("','", array_values($array))."'";
        $sql="insert into {$table}({$keys}) VALUES ({$values})";
        $res=mysql_query($sql,$conn);
        if($res){
            return mysql_insert_id();
        }else{
            return false;
        }
    }
    /**
     * MYSQL更新操作
     * @param array $array
     * @param string $table
     * @param string $where
     * @return number|boolean
     */
    function update($array,$table,$where=null,$conn){
        foreach ($array as $key=>$val){
            $sets.=$key."='".$val."',";
        }
        $sets=rtrim($sets,','); //去掉SQL里的最后一个逗号
        $where=$where==null?'':' WHERE '.$where;
        $sql="UPDATE {$table} SET {$sets} {$where}";
        $res=mysql_query($sql,$conn);
        if ($res){
            return mysql_affected_rows();
        }else {
            return false;
        }
    }
    /**
     * 删除记录的操作
     * @param string $table
     * @param string $where
     * @return number|boolean
     */
    function delete($table,$where=null,$conn){
        $where=$where==null?'':' WHERE '.$where;
        $sql="DELETE FROM {$table}{$where}";
        $res=mysql_query($sql,$conn);
        if ($res){
            return mysql_affected_rows();
        }else {
            return false;
        }
    }
    /**
     * 查询一条记录
     * @param string $sql
     * @param string $result_type
     * @return boolean
     */
    function fetchOne($sql,$conn,$result_type=MYSQL_ASSOC){
        $result=mysql_query($sql,$conn);
        if ($result && mysql_num_rows($result)>0){
            $list =  mysql_fetch_array($result,$result_type);
            $this->freeResult($result);
            return $list;
        }else {
            return false;
        }
    }
    /**
     * 得到表中的所有记录
     * @param string $sql
     * @param string $result_type
     * @return boolean
     */
    function fetchAll($sql,$conn,$result_type=MYSQL_ASSOC){
        $result=mysql_query($sql,$conn);
        if ($result && mysql_num_rows($result)>0){
            while ($row=mysql_fetch_array($result,$result_type)){
                $rows[]=$row;
            }
            $this->freeResult($result);
            return $rows;
        }else {
            return false;
        }
    }
    /**释放结果集
     * @param resource $result
     * @return boolean
     */
    function  freeResult($result){
        return  mysql_free_result($result);
    }
    /**断开MYSQL
     * @param resource $link
     * @return boolean
     */
    function close($link=null){
        return mysql_close($link);
    }
    /**得到客户端的信息
     * @return string
     */
    function getClintInfo(){
        return mysql_get_client_info();
    }
    /**得到MYSQL服务器端的信息
     * @return string
     */
    function getServerInfo($link=null){
        return mysql_get_server_info($link);
    }
    /**得到主机的信息
     * @return string
     */
    function getHostInfo($link=null){
        return mysql_get_host_info($link);
    }
    /**得到协议信息
     * @return string
     */
    function getProtoInfo($link=null){
        return mysql_get_proto_info($link);
    }
}
返回文章列表 文章二维码 打赏
本页链接的二维码
打赏二维码
期待你的评论