程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> 關於PHP編程 >> 封裝自己的DB類(PHP),封裝db類php

封裝自己的DB類(PHP),封裝db類php

編輯:關於PHP編程

封裝自己的DB類(PHP),封裝db類php


封裝一個DB類,用來專門操作數據庫,以後凡是對數據庫的操作,都由DB類的對象來實現。這樣有了自己的DB類,寫項目時簡單的sql語句就不用每次寫了,直接調用就行,很方便!

1.封裝一個DB類。一個類文件應該只有一個類,其他的內容全部都沒有。類文件的命名規則:類名.class.php

下面是創建DB類的代碼:

<?php

    //封裝一個DB類,用來專門操作數據庫,以後凡是對數據庫的操作,都由DB類的對象來實現
    class DB{
        //屬性
        private $host;
        private $port;
        private $user;
        private $pass;
        private $dbname;
        private $charset;
        private $prefix;            //表前綴
        private $link;                //連接資源(連接數據庫,一般會返回一個資源,所以需要定義一個link屬性)

        //構造方法(作用:為了初始化對象的屬性),會被自動調用
        /*
         * @param1 array $arr,默認為空,裡面是一個關聯數組,裡面有7個元素
         * array('host' => 'localhost','port' => '3306');
         */
        public function __construct($arr = array()){
            //初始化
            $this->host = isset($arr['host']) ? $arr['host'] : 'localhost';//先判斷是否有自己的host,如果有就用自己的host,否則就使用默認的localhost
            $this->port = isset($arr['port']) ? $arr['port'] : '3306';
            $this->user = isset($arr['user']) ? $arr['user'] : 'root';
            $this->pass = isset($arr['pass']) ? $arr['pass'] : 'root';
            $this->dbname = isset($arr['dbname']) ? $arr['dbname'] : 'mydatabase';
            $this->charset = isset($arr['charset']) ? $arr['charset'] : 'utf8';
            $this->prefix = isset($arr['prefix']) ? $arr['prefix'] : '';

            //連接數據庫(類是要操作數據庫,因此要連接數據庫)
            $this->connect();

            //設置字符集
            $this->setCharset();

            //選擇數據庫
            $this->setDbname();
        }

        /*
         * 連接數據庫
        */
        private function connect(){
            //mysql擴展連接
            $this->link = mysql_connect($this->host . ':' . $this->port,$this->user,$this->pass);

            //判斷結果
            if(!$this->link){
                //結果出錯了
                //暴力處理,如果是真實線上項目(生產環境)必須寫入到日志文件
                echo '數據庫連接錯誤:<br/>';
                echo '錯誤編號' . mysql_errno() . '<br/>';
                echo '錯誤內容' . mysql_error() . '<br/>';
                exit;
            }
        }

        /*
         * 設置字符集
        */
        private function setCharset(){
            //設置
            $this->db_query("set names {$this->charset}");
        }

        /*
         * 選擇數據庫
        */
        private function setDbname(){
            $this->db_query("use {$this->dbname}");
        }

        /*
         * 增加數據
         * @param1 string $sql,要執行的插入語句
         * @return boolean,成功返回是自動增長的ID,失敗返回FALSE
        */
        public function db_insert($sql){
            //發送數據
            $this->db_query($sql);
            
            //成功返回自增ID
            return mysql_affected_rows() ? mysql_insert_id() : FALSE;
        }

        /*
         * 刪除數據
         * @param1 string $sql,要執行的刪除語句
         * @return Boolean,成功返回受影響的行數,失敗返回FALSE
        */
        public function db_delete($sql){
            //發送SQL
            $this->db_query($sql);

            //判斷結果
            return mysql_affected_rows() ? mysql_affected_rows() : FALSE;
        }

        /*
         * 更新數據
         * @param1 string $sql,要執行的更新語句
         * @return Boolean,成功返回受影響的行數,失敗返回FALSE
        */
        public function db_update($sql){
            //發送SQL
            $this->db_query($sql);

            //判斷結果
            return mysql_affected_rows() ? mysql_affected_rows() : FALSE;
        }

        /*
         * 查詢:查詢一條記錄
         * @param1 string $sql,要查詢的SQL語句
         * @return mixed,成功返回一個數組,失敗返回FALSE
        */
        public function db_getRow($sql){
            //發送SQL
            $res = $this->db_query($sql);

            //判斷返回
            return mysql_num_rows($res) ? mysql_fetch_assoc($res) : FALSE;
        }

        /*
         * 查詢:查詢多條記錄
         * @param1 string $sql,要查詢的SQL語句
         * @return mixed,成功返回一個二維數組,失敗返回FALSE
        */
        public function db_getAll($sql){
            //發送SQL
            $res = $this->db_query($sql);

            //判斷返回
            if(mysql_num_rows($res)){
                //循環遍歷
                $list = array();
                
                //遍歷
                while($row = mysql_fetch_assoc($res)){
                    $list[] = $row;
                }

                //返回
                return $list;
            }

            //返回FALSE
            return FALSE;
        }

        /*
         * mysql_query錯誤處理
         * @param1 string $sql,需要執行的SQL語句
         * @return mixed,只要語句不出錯,全部返回
        */
        private function db_query($sql){
            //發送SQL
            $res = mysql_query($sql);

            //判斷結果
            if(!$res){
                //結果出錯了
                //暴力處理,如果是真實線上項目(生產環境)必須寫入到日志文件
                echo '語句出現錯誤:<br/>';
                echo '錯誤編號' . mysql_errno() . '<br/>';
                echo '錯誤內容' . mysql_error() . '<br/>';
                exit;
            }
            //沒有錯誤
            return $res;
        }
            //__sleep方法
        public function __sleep(){
            //返回需要保存的屬性的數組
            return array('host','port','user','pass','dbname','charset','prefix');
        }

        //__wakeup方法
        public function __wakeup(){
            //連接資源
            $this->connect();
            //設置字符集和選中數據庫
            $this->setCharset();
            $this->setDbname();
        }    

        /*
         * 獲取完整的表名
        */
        protected function getTableName(){
            //完整表名:前綴+表名
            return $this->prefix . $this->table;
        }
    }
//這個DB類,一般不寫析構(不釋放資源)    

2.使用DB類,但是如果要使用某一個類來創建對象,必須要保證該類已經被加載到代碼區裡。可以使用一個魔術函數來實現對類的自動加載

自動加載:當一個腳本文件在執行某些語句的時候(實例化)需要去代碼區裡尋找對應的類,如果找不到會通過自動加載函數來將對應的類文件進行加載。

魔術函數:__autoload()

比如我們在index.php頁面中需要使用DB類,那麼我們就直接調用即可,具體代碼如下:

<?php
    //使用DB類的對象來訪問數據庫
    //先加載類文件
    //include_once 'DB.class.php';
        //如果想使用其他類,又需要加載(所以使用魔術函數__autoload來實現類的自動加載)
    //顯示的寫出魔術函數__autoload
    //參數:需要加載的類的名字
    function __autoload($a){
        //將對應的類文件加載進來
        if(is_file("$a.class.php")){
            include_once "$a.class.php";
        }
    }
    //實例化
    $db = new DB(array('dbname' => 'mydatabase'));

    
    

 

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved