最新消息: 新版网站上线了!!!

MYSQL数据操作类的PHP实例

最近复习一下OOP,听说现在流行使用MVC来做PHP程序了,我还停留在OOP的阶段的。弄点小实例来搞搞罗,要不技术也忘记了,连SEO也忘记了。。
Cls_mysql.php
<?php
class mysql {
    private $db_host; //数据库主机
    private $db_user; //数据库用户名
    private $db_pwd; //数据库用户名密码
    private $db_database; //数据库名
    private $conn; //数据库连接标识;
    private $result; //执行query命令的结果资源标识
    private $sql; //sql执行语句
    private $row; //返回的条目数
    private $coding; //数据库编码,GBK,UTF8,gb2312
    private $show_error = true; // true 测试阶段,显示所有错误,具有安全隐患,默认关闭false

    /*构造函数*/
    public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) {
        $this->db_host = $db_host;
        $this->db_user = $db_user;
        $this->db_pwd = $db_pwd;
        $this->db_database = $db_database;
        $this->conn = $conn;
        $this->coding = $coding;
        $this->connect();
    }
    /*数据库连接*/
    public function connect() {
        //$this->conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd);//永久链接            
        $this->conn = mysql_connect($this->db_host, $this->db_user, $this->db_pwd);//即使链接
        if (!mysql_select_db($this->db_database, $this->conn)) {
            if ($this->show_error) {
                $this->show_error("数据库不可用:", $this->db_database);exit;
            }
        }
        mysql_query("SET NAMES $this->coding");
    }
    
    /*数据库执行语句,可执行查询添加修改删除等任何sql语句*/
    public function query($sql) {
        if ($sql == "") {
            $this->show_error("SQL语句错误:", "SQL查询语句为空");
        }
        $this->sql = $sql;

        $result = mysql_query($this->sql, $this->conn);

        if (!$result) {
            //调试中使用,sql语句出错时会自动打印出来
            if ($this->show_error) {
                $this->show_error("错误SQL语句:", $this->sql);
            }
        } else {
            $this->result = $result;
        }
        return $this->result;
    }
    
    /*取得记录集,获取数组-索引和关联,使用$row['content'] */
    public function fetch_array() {
        return mysql_fetch_array($this->result);
    }

    //获取关联数组,使用$row['字段名']
    public function fetch_assoc() {
        return mysql_fetch_assoc($this->result);
    }

    //获取数字索引数组,使用$row[0],$row[1],$row[2]
    public function fetch_row() {
        return mysql_fetch_row($this->result);
    }

    
    //返回记录集
    public function get_data_array($sql) {
    $rs = $this->query($sql);
    $data_array = array();
    while($data =$this->fetch_array()) {
    $data_array[] = $data;
    }
    mysql_free_result($rs);
    return $data_array;
    }
    
    //简化查询select
    public function select($table, $columnName = "*", $condition = '', $debug = '') {
        $condition = $condition ? ' Where ' . $condition : NULL;
        if ($debug) {
            echo "SELECT $columnName FROM $table $condition";
        } else {
            $this->query("SELECT $columnName FROM $table $condition");
        }
    }

    //简化删除del
    public function delete($table, $condition, $url = '') {
        if ($this->query("DELETE FROM $table WHERE $condition")) {

            if (!empty ($url))
                $this->Get_admin_msg($url, '删除成功!');
        }
    }

    //简化插入insert
    public function insert($table, $columnName, $value, $url = '') {
        if ($this->query("INSERT INTO $table ($columnName) VALUES ($value)")) {
            if (!empty ($url))
                show_msg($url, '添加成功!');
        }
    }

    //简化修改update
    public function update($table, $mod_content, $condition, $url = '') {
        
        if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {
            if (!empty ($url))
                show_msg($url);
        }
    }

    /*取得上一步 INSERT 操作产生的 ID*/
    public function insert_id() {
        return mysql_insert_id();
    }

    //指向确定的一条数据记录
    public function db_data_seek($id) {
        if ($id > 0) {
            $id = $id -1;
        }
        if (!@ mysql_data_seek($this->result, $id)) {
            $this->show_error("SQL语句有误:", "指定的数据为空");
        }
        return $this->result;
    }

    // 根据select查询结果计算结果集条数
    public function db_num_rows() {
        if ($this->result == null) {
            if ($this->show_error) {
                $this->show_error("SQL语句错误", "暂时为空,没有任何内容!");
            }
        } else {
            return mysql_num_rows($this->result);
        }
    }

    // 根据insert,update,delete执行结果取得影响行数
    public function db_affected_rows() {
        return mysql_affected_rows();
    }
    
    //释放结果集
    public function free() {
        @ mysql_free_result($this->result);
    }
    
    //析构函数,自动关闭数据库,垃圾回收机制
    public function __destruct() {
        if (!empty ($this->result)) {
            $this->free();
        }
        mysql_close($this->conn);
    }
    
    //输出显示错误提示信息及SQL语句
    public function show_error($message = "", $sql = "") {
        if (!$sql) {
            echo "<font color='red'>" . $message . "</font>";
            echo "<br />";
        } else {
            echo "<meta http-equiv=\"Content-Type\" content=\"text/html; charset=gb2312\" /><fieldset>";
            echo "<legend>错误信息提示:</legend><br />";
            echo "<div style='font-size:14px; clear:both; font-family:Verdana, Arial, Helvetica, sans-serif;'>";
            echo "<div style='height:20px; background:#000000; border:1px #000000 solid'>";
            echo "<font color='white'>错误号:12142</font>";
            echo "</div><br />";
            echo "错误原因:" . mysql_error() . "<br /><br />";
            echo "<div style='height:20px; background:#FF0000; border:1px #FF0000 solid'>";
            echo "<font color='white'>" . $message . "</font>";
            echo "</div>";
            echo "<font color='red'><pre>" . $sql . "</pre></font>";
            if ($this->is_error) {
                exit;
            }
        }
        echo "</div>";
        echo "</fieldset>";
        echo "<br />";
    }
}
?>


调用实例:
Conn.php
<?php
    require_once("cls_mysql.php");
    $cls_db = new mysql("localhost", "root", "", "ucenter", "conn", "GBK");
////查询记录集并循环显示 
$cls_db->select('article_cat','*','parent_id=0');    
    while($datass =$cls_db->fetch_array()) {
        echo $datass['cat_name']."<br />";
    }
//查询记录集并循环显示 
    $data = $cls_db->get_data_array("select * from article_cat order by sort_order asc");
    foreach($data as $cat) {
        echo $cat['cat_name']."<br />";
    }
//单独一条记录,有条件的
$cls_db->select('article_cat','*','cat_id=13');    
    $datass =$cls_db->fetch_array();
    echo $datass['cat_name'].$datass['url_key']."<br />";

//查询记录集数目
    $cls_db->query("select * from article_cat");
    echo $cls_db->db_num_rows();
?>
 

转载请注明:谷谷点程序 » MYSQL数据操作类的PHP实例