PHP简单封装MysqlHelper类

MysqlHelper.class.php

<?php

/**
 * Mysql数据帮助类
 */
class MysqlHelper
{
    function __construct()
    {
        if(isset($conn)){return;}
        //创建连接对象
        $this->conn=@mysql_connect($this->host,$this->uid,$this->pwd);
        if(!$this->conn){
            die('连接数据库失败：'.mysql_error());
        }

        //选择数据库和设置编码
        mysql_select_db($this->db,$this->conn);
        mysql_query('set names utf8');
    }

    private $conn;
    private $host='localhost';
    private $uid='root';
    private $pwd='1234';
    private $db='test2';

    /**
     * [execute_dql 执行查询语句]
     * @param [string] $sql [查询语句]
     */
    public function execute_dql($sql)
    {
        $result = mysql_query($sql,$this->conn) or die('执行DQL语句时出错：'.mysql_error());
        return $result;
    }

    /**
     * [execute_dml 执行增删改语句]
     * @param [string] $sql [查询语句]
     * @return [失败返回-1,无影响返回0,成功返回受影响的行数]
     */
    public function execute_dml($sql)
    {
        $result = mysql_query($sql,$this->conn) or die('执行DML语句时出错：'.mysql_error());
        if(!$result){
            return -1; //操作失败
        }else{
            return mysql_affected_rows($this->conn);
        }
    }

    /**
     * [show_table_data 显示表数据]
     * @param  [string] $tableName [表名]
     * @return [string]            [HTML表格]
     */
    public function show_table_data($tableName)
    {
        $result = $this->execute_dql("select * from $tableName");

        $this->show_table($result);

        mysql_free_result($result);
        mysql_close($this->conn);
    }

    /**
     * [show_table_info 显示表结构]
     * @param  [string] $tableName [表名]
     * @return [string]            [HTML表格]
     */
    public function show_table_info($tableName)
    {
        $result = $this->execute_dql("desc $tableName");

        $this->show_table($result);

        mysql_free_result($result);
        mysql_close($this->conn);
    }

    /**
     * [show_table 拼接表格]
     * @param  [resource] $result [结果集]
     * @return [string]         [HTML]
     */
    public function show_table($result)
    {
        //显示表头信息：
        echo "<br/>数据表：".mysql_field_table($result, 0)."  总行数：".mysql_num_rows($result);
        $tableData="<table border='1' cellpadding='5'><tr>";
        $fieldsCount = mysql_num_fields($result);
        for ($i=0; $i <$fieldsCount; $i++) {
            $tableData.= "<th>".mysql_field_name($result, $i)."</th>";
        }
        $tableData.="</tr>";

        //显示数据信息：
        while ($row = mysql_fetch_object($result)) {
            $tableData.="<tr>";
            foreach ($row as $value) {
                $tableData.="<td>$value</td>";
            }
            $tableData.="</tr>";
        }
        $tableData.="</table>";

        echo $tableData;
    }
}

?>

调用示例：

   1: <?php

   2: header("Content-Type:text/html; charset=utf8");

   3:  

   4: //自定义MysqlHelper的测试与使用

   5: //============================================

   6:  

   7: //引用自定义的MysqlHelper类

   8: require_once "MysqlHelper.class.php";

   9:  

  10: //实例化MysqlHelper对象

  11: $execute = new MysqlHelper();

  12:  

  13: // 增

  14: $sql = "insert into userinfo(uName,uAge,uPwd) values('测试04',18,MD5('1234'));";

  15: // 删

  16: // $sql = "delete from userinfo where id=20";

  17: // 改

  18: // $sql = "update userinfo set uAge=19 where Id=21";

  19:  

  20: //对数据执行DML操作

  21: $returnNum = $execute->execute_dml($sql);

  22: if ($returnNum ==-1) {

  23:     echo "操作失败 :(";

  24: } else {

  25:     echo "操作成功:) <b style='color:red;'>".$returnNum."</b>行受影响<br/>";

  26: }

  27:  

  28:  

  29: //显示表信息：

  30: $execute->show_table_info("userinfo");

  31:  

  32: //显示表数据：

  33: $execute->show_table_data("userinfo");

  34:  

  35:  

  36: ?>