trollolodn icon

#php #mysql_connect

trollolodn | PRO | 02/01/13 08:11:44 AM UTC | 0 ⭐ | 151 👁️ | Never ⏰ | []
PHP |

1.74 KB

|

None

|

0 👍

/

0 👎

/*
*@Author: quocvuongdn
*@Twitter: quocvuongdn
*@Site: quocvuongdn.com
*/
class MySQL{
    protected $db_name = '';
    protected $db_user = '';
    protected $db_pass = '';
    protected $db_host = '';
    protected $connection;
 
    function __construct(){
        $this->connect();
    }
 
    public function connect() {
        $this->connection = mysql_connect($this->db_host, $this->db_user, $this->db_pass);
        mysql_select_db($this->db_name);
 
        return true;
    }
 
    public function processRowSet($rowSet, $singleRow=false)
    {
        $resultArray = array();
        while($row = mysql_fetch_assoc($rowSet))
        {
            array_push($resultArray, $row);
        }
 
        if($singleRow === true)
            return $resultArray[0];
 
        return $resultArray;
    }
 
    public function select($table, $where) {
        $sql = "SELECT * FROM $table WHERE $where";
        //echo $sql;
        $result = mysql_query($sql);
        if(mysql_num_rows($result) == 1)
            return $this->processRowSet($result, true);
        return $this->processRowSet($result);
    }
 
    public function update($data, $table, $where) {
        foreach ($data as $column => $value) {
            $sql = "UPDATE $table SET $column = $value WHERE $where";
            //echo $sql;
            mysql_query($sql) or die(mysql_error());
        }
        return true;
    }
 
    public function insert($data, $table) {
 
        $columns = "";
        $values = "";
 
        foreach ($data as $column => $value) {
            $columns .= ($columns == "") ? "" : ", ";
            $columns .= $column;
            $values .= ($values == "") ? "" : ", ";
            $values .= $value;
        }
 
        $sql = "insert into $table ($columns) values ($values)";
        echo $sql;
        mysql_query($sql) or die(mysql_error());
 
        //return the ID of the user in the database.
        return mysql_insert_id();
 
    }
 
    public function close(){
        mysql_close($this->connection);
    }
}

Comments