本帖最后由 andy1219111 于 2010-10-29 23:21:08 编辑

解决方案 »

  1.   

    你想添加功能的话 还有很多.
    比如说 把 mysql_num_rows()   update delete   等等..
      

  2.   

     楼主不必这么费劲,找个框架看看就可以了,比如ThinkPHP
      

  3.   

    thinkPHP我用过,就是想写一个类,以后用得着的地方很多
      

  4.   

    discuz ecshop的mysql类觉得不错 楼主可看看
      

  5.   

    经过了一些改进,增加了实时根据需要切换数据库,对多数据库进行操作
    <?php
    class dbo{
        private $conn;
        private $host;
        private $username;
        private $password;
        private $dbname;
        
        function __construct($host,$username,$password,$dbname)
        {
            
            
            $this->host=$host;
            $this->username=$username;
            $this->password=$password;
            $this->conn=mysql_connect($username,$username,$password) or die ('Not connected : ' . mysql_error());
            $this->select_db($dbname,$this->conn) or die('选择数据库失败:'.mysql_error());
            
        }
    function __get($name)
    {
    return $this->$name;
    }
    function __set($name,$value)
    {
    $this->$name = $value;
    }
    function connectDb($host,$username,$password)
    {
    $this->conn = mysql_connect($host,$username,$password) or die('Not connected : ' . mysql_error());
    }
        function select_db($dbname)
        {
          mysql_select_db($dbname,$conn) or die('选择数据库失败:'.mysql_errno());   
        }
        //执行select语句,批量查询
        function queryAll($sql)
        {
            $result = mysql_query($sql,$this->$conn);
            if(!$result)
            {
                return false;
            }
            return $this->result2Array($result);
            
            
        }
        function result2Array($result)
        {
            if(!$result)
            {
               die('结果集不正确');
            }
            $resultArray = array();
            while ($row = mysql_fetch_array($result)) {
                array_push($resultArray,$row);
            }
            return $resultArray;
            
        }
        function queryOne($sql)
        {
            $result=mysql_query($sql,$this->conn);
            if(!$result)
            {
                return array();
            }
            return mysql_fetch_assoc($result);
        }
        function query($sql)
        {
            $result=mysql_query($sql,$this->conn);
            if(!$result)
            {
                return false;
            }
            return mysql_affected_rows();
        }
        //关闭数据库连接
        function closeDb()
        {
            mysql_close($this->conn);
        }
        function __destruct()
        {
            $this->closeDb();
        }
        
    }