php多數(shù)據(jù)庫支持的應用程序設計第2/2頁

更新時間：2008年08月12日 12:26:47 作者：

以前做PHP應用，多數(shù)是單數(shù)據(jù)庫數(shù)據(jù)查詢和更新，頂多也是主從數(shù)據(jù)庫的支持，實現(xiàn)起來相對簡單。主從數(shù)據(jù)庫的問題在于，當會話存儲在數(shù)據(jù)庫的時候，同步將可能出現(xiàn)問題，也就是說有可能出現(xiàn)會話的中斷。

首先以單例摸式創(chuàng)建DB類：

復制代碼代碼如下:

 
<?php 
if (!defined("DB_FETCH_ASSOC")) { 
    define("DB_FETCH_ASSOC", 1); 
} 

if (!defined("DB_FETCH_ROW")) { 
    define("DB_FETCH_ROW", 2); 
} 

if (!defined("DB_FETCH_ARRAY")) { 
    define("DB_FETCH_ARRAY", 3); 
} 

if (!defined("DB_FETCH_DEFAULT")) { 
    define("DB_FETCH_DEFAULT", DB_FETCH_ASSOC); 
} 
class DB { 
    function DB($dsn, $db_key, $p_conn, $fetch_mode) { 
        $this->dsn        = $dsn; 
        $this->db_key     = $db_key; 
        $this->sql        = ''; 
        $this->sqls       = array(); 
        $this->u_sqls     = array(); 
        $this->q_sqls     = array(); 
        $this->u_conn     = null; 
        $this->q_conn     = null; 
        $this->p_conn     = $p_conn; 
        $this->fecth_mode = $fetch_mode; 
        $this->query_num  = 0; 
        $this->update_num = 0; 
    } 

    function &init(& $dsn, $db_key, $p_conn = false, $fetch_mode = DB_FETCH_DEFAULT) { 
        static $db; 
        $db_key = explode('.', $db_key); 
        $db_key = "['" . implode("']['" , $db_key) . "']"; 
        eval('$flag = isset($db' . $db_key . ');'); 
        eval("\$db_info = \$dsn['db_info']" . $db_key . ";"); 
        if (!$flag) { 
            $obj = new DB($db_info, $db_key, $p_conn, $fetch_mode); 
            eval('$db' . $db_key . ' = $obj;'); 
            unset($obj); 
        } 
        return $db; 
    } 
} 
$db = &DB::init($configs, 'blog.0'); 
print_r($db); 
?> 

　　從上面打印結果可以看出，blog數(shù)據(jù)庫集群的第一組數(shù)據(jù)庫服務器被載入到$this->dsn中了。這個下面就是簡單的數(shù)據(jù)COPY的主從服務器，所以可以使用隨機數(shù)來指定到某一臺服務器。以下是一個簡單的隨機數(shù)實現(xiàn)：

復制代碼代碼如下:

 
class DB { 
    //.... 

    function connectDB($type = "master") { 
        if ($type == "master") { 
            $db_host = $this->dsn["master"]["db_host"]; 
            $db_name = $this->dsn["master"]["db_name"]; 
            $db_user = $this->dsn["master"]["db_user"]; 
            $db_pass = $this->dsn["master"]["db_pass"]; 
            $this->u_conn = mysqli_connect($db_host, $db_user, $db_pass); 
            $this->selectDB($db_name, $this->conn); 
            if (!$this->u_conn) { 
                $message = "Update DataBase Connect False : ($db_host, $db_user, ******) !"; 
                $this->error($message, 0); 
            } 
        } else { 
            if (empty($_COOKIE[$_configs['cookie_prefix'] . 'db_no'])) { 
                $db_no = array_rand($this->dsn["db_info"]["slave"]); 
            } else { 
                $db_no = $_COOKIE[$_configs['cookie_prefix'] . 'db_no']; 
            } 
            $db_info = $this->dsn["slave"][$db_no]; 
            $db_host = $db_info["db_host"]; 
            $db_name = $db_info["db_name"]; 
            $db_user = $db_info["db_user"]; 
            $db_pass = $db_info["db_pass"]; 
            $this->q_conn = mysqli_connect($db_host, $db_user, $db_pass); 

            if (!$this->q_conn) { 
                if (!$this->u_conn) { 
                    $this->connectDB(); 
                } 
                $this->q_conn = $this->u_conn; 
                if (!$this->q_conn) { 
                    $message = "Query DataBase Connect False : ($db_host, $db_user, ******) !"; 
                    $this->error($message, 0); 
                } 
            } else { 
                $this->selectDB($db_name, $this->q_conn); 
            } 
        } 
    } 

    function selectDB($db_name, $conn) { 
        if ($db_name != null) { 
            if(! mysqli_select_db($conn, $db_name)) { 
                $code = mysqli_errno($conn); 
                $message = mysqli_error($conn); 
                $this->error($message, $code); 
            } 
            return true; 
        } 
        return false; 
    } 

    function query($sql, $limit = 1, $quick = false) { 
        if ($limit != null) { 
            $sql = $sql . " LIMIT " . $limit; 
        } 
        $this->sqls[] = $sql; 
        $this->q_sqls[] = $sql; 
        $this->sql = $sql; 

        if (empty($this->q_conn)) { 
            $this->connectDB("slave"); 
        } 
        $this->qrs = mysqli_query($this->q_conn, $sql, $quick ? MYSQLI_USE_RESULT : MYSQLI_STORE_RESULT); 
        if (!$this->qrs) { 
            $code = mysqli_errno($this->q_conn); 
            $message = mysqli_error($this->q_conn); 
            $this->error($message, $code); 
        } 
        $this->query_num++; 
        return $this->qrs; 
    } 

    function update($sql) { 
        $this->sql = $sql; 
        $this->sqls[] = $this->sql; 
        $this->u_sqls[] = $this->sql; 
        if ($this->u_conn == null) { 
            $this->connectDB("master"); 
        } 

        $this->urs = mysqli_query($this->u_conn, $sql, MYSQLI_USE_RESULT); 
        $this->update_num++; 

        if (!$this->urs) { 
            return false; 
        } else { 
            return true; 
        } 
    } 
} 

　　至此，基本框架已經出來了，來看看調用方法： <?php
//　連接到第一組會話服務器
$db = &DB::init($configs, 'session.0');
//  執(zhí)行一次查詢
$db['session'][0]->query('SELECT ...');

//  再次連接BLOG服務器
$db = &DB::init($configs, 'blog.1');
//  執(zhí)行一次更新
$db['blog'][1]->update('UPDATE ...');

//  再次調用會話更新
$db['session'][0]->update('INSERT ...');
?>

上一頁 12閱讀全文

您可能感興趣的文章: