`
icrwen
  • 浏览: 269567 次
  • 性别: Icon_minigender_2
  • 来自: 济南
社区版块
存档分类
最新评论

多数据库支持的应用程序设计

    博客分类:
  • php
阅读更多
http://hi.baidu.com/stylelive/blog
http://hi.baidu.com/stylelive/blog/item/4f2eeeb4f8e594778bd4b206.html
  查看文章   
多数据库支持的应用程序设计2008年03月09日 星期日 上午 00:03本站文章如未特殊注明,均为原创,严禁转载。

  以前做PHP应用,多数是单数据库数据查询和更新,顶多也是主从数据库的支持,实现起来相对简单。主从数据库的问题在于,当会话存储在数据库的时候,同步将可能出现问题,也就是说有可能出现会话的中断。所以我想在主从数据库设计上,应该将所有会话相关表进行特殊对待。即:所有的会话数据表都可以更新和查询,当一个用户访问站点的时候,即将此用户绑定到指定数据库,所有会话访问和查询操作都对此数据库进行。会话表不做同步,其他非会话类更新也从主数据库更新。这样做其实也逃脱不了会话更新时候的数据库切换,所以如果不想麻烦,还是将会话存放在文本中进行的好。
  分数据库设计,将可能从压力性能上会提升几个档次,当然单次执行效率不会比单数据库来的高的,毕竟存在着数据库切换的效率问题。分库以及主从数据库搭配是可以比较好改善数据库并发瓶颈的方案。原则:大数据量,分库;大访问量,主从。很多时候,都是这两者并行(本文不讨论cache)。
  我想,如果要实现分库以及主从关系,那么数据库服务器数量将是非常可观,在应用程序中随时切换到某一台服务器,将是非常头痛的问题,配置更换,变量名称,是不是会有一大堆呢?如何寻找更好的解决方案将是本文谈论的话题。
  首先是分库使得数据库颇多的问题。什么情况下分库?或许有些人还搞不明白为什么要分库,我就简要说一下自己的经验猜测。比如一个博客程序,一般设计是将日志存放在一张日志表中。假设是一个多用户博客,那么将会关联一个uid,如果数据量不大,这样设计是没有问题的,但是当日志量巨大,一天有几十万条日志记录录入的时候,而且访问量也比较可观的时候,我想不可能每个用户来访问日志列表,都去从这包含几千万条日志记录的数据表中去找那么几条,效率可见一斑。这个时候就该考虑到分库的问题。如何分?有一个很简单的分表方法,即,根据uid段,将日志记录在各个数据库中,当然,这个分布还是需要根据以往统计结果做出调整的,因为用户日志分布肯定不是均匀的。设置好uid段,然后根据uid索引到指定数据库配置,创建一个数据库对象即可。配置信息可能如下:

$configs['db_info']['blog'][0] = array(
    'db_host' => '192.168.0.1',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][1] = array(
    'db_host' => '192.168.0.2',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][2] = array(
    'db_host' => '192.168.0.2',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
//...还有很多
  至于选择哪一台服务器,只需要根据uid做一个简单的匹配就可以了。
  再谈到的就是主从数据库了。什么情况下使用主从数据库?比如某个名人博客,访问量相当的大,已经没有办法把他的数据再进行拆分了,这个时候就得考虑主从数据库服务器了,使用多台数据库来分流。这样要适用主从和分库,可能上面配置信息得稍微改动一下。

$configs['db_info']['blog'][0]['master'] = array(
    'db_host' => '192.168.0.1',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][0]['slave'][0] = array(
    'db_host' => '192.168.0.2',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][0]['slave'][1] = array(
    'db_host' => '192.168.0.3',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][1]['master'] = array(
    'db_host' => '192.168.0.4',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][1]['slave'][0] = array(
    'db_host' => '192.168.0.5',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['blog'][1]['slave'][1] = array(
    'db_host' => '192.168.0.6',
    'db_name' => 'blog',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['session'][0]['master'] = array(
    'db_host' => '192.168.0.7',
    'db_name' => 'session',
    'db_user' => 'root',
    'db_pass' => '',
);
$configs['db_info']['session'][1]['master'] = array(
    'db_host' => '192.168.0.8',
    'db_name' => 'session',
    'db_user' => 'root',
    'db_pass' => '',
);
  写到这里,我想都应该知道如何分表和分配你的数据库了吧,接下去我就来说一下如何轻松的读取这样的配置信息,如何将这些配置融入你的数据库驱动中。首先以单例摸式创建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数据库集群的第一组数据库服务器被载入到$this->dsn中了。这个下面就是简单的数据COPY的主从服务器,所以可以使用随机数来指定到某一台服务器。以下是一个简单的随机数实现:

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');
//  执行一次查询
$db['session'][0]->query('SELECT ...');

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

//  再次调用会话更新
$db[

分享到:
评论

相关推荐

    数据库应用程序设计教程

    数据库应用程序设计是IT领域中的核心技能之一,尤其是在数据管理和信息系统开发中扮演着至关重要的角色。本教程以Visual FoxPro为例,旨在提供一个基础的数据库应用程序设计学习路径。 Visual FoxPro,简称VFP,是...

    java数据库应用程序编程指南

    在Java编程领域,数据库应用程序开发是一项至关重要的技能。本指南将深入探讨如何使用Java与数据库进行交互,特别是针对Oracle数据库的编程。以下是基于标题、描述和标签所涉及的知识点的详细说明: 1. **Java...

    利用Eclipse创建数据库web应用程序.rar

    在IT行业中,开发数据库驱动的Web应用程序是一项常见的任务,而Eclipse作为一个强大的集成开发环境(IDE),提供了便捷的工具来支持这一过程。本教程将详细讲解如何利用Eclipse创建一个数据库Web应用程序,帮助...

    pocketpc数据库应用程序设计

    本文将深入探讨“pocketpc数据库应用程序设计”这一主题,涵盖移动编程的关键知识点。 首先,我们要了解Pocket PC的操作系统是基于Windows CE的,它支持多种编程语言,如C++, Visual Basic .NET,以及.NET Compact ...

    Access 2010数据库程序设计教程-数据库

    Access是微软Office套件中的一员,它提供了一个直观的图形用户界面,使得用户能够创建、管理和维护数据库,以及开发基于数据库的应用程序。 在Access 2010中,数据库设计的基础包括以下几个核心概念: 1. 数据库...

    Linux平台下运用Lazarus Firebird开发数据库应用程序.pdf

    使用Lazarus可以快速开发数据库应用程序,因为Lazarus支持视觉化设计和快速编译。使用Firebird可以存储和管理大量数据,因为Firebird支持高性能、安全和可靠的数据存储和管理。 在本文中,我们将使用Lazarus和...

    C++ Builder 5程序设计——数据库应用实务篇

    《C++ Builder 5程序设计——数据库应用实务篇》是一本深入探讨如何使用C++ Builder 5进行数据库应用程序开发的专业书籍。C++ Builder 5是 Borland 公司推出的一款集成开发环境(IDE),它结合了C++语言的高效性和...

    数据库应用程序设计PPT学习教案.pptx

    数据库应用程序设计是IT领域中的重要组成部分,涉及到数据的组织、管理和使用。本教程主要涵盖了数据库的基础知识,包括数据、数据库、数据库管理系统(DBMS)、数据库系统(DBS)以及关系数据库,同时也涉及到了...

    第一个数据库应用程序

    在这个“第一个数据库应用程序”中,我们将探讨如何利用Visual Basic 6.0(VB6.0)编程语言与Microsoft Access数据库进行集成开发,创建一个简单的数据库应用。 首先,VB6.0是微软公司推出的一种可视化编程环境,它...

    Delphi7 高效数据库程序设计

    《Delphi7 高效数据库程序设计》是针对Delphi编程环境和数据库应用开发的一份重要资料,旨在帮助开发者提高在Delphi7平台上的数据库应用程序的性能和效率。Delphi作为一个强大的面向对象的Windows应用程序开发工具,...

    (数据库系统基础、设计及应用)第6章数据库应用程序.ppt

    第 6 章主要探讨的是数据库应用程序的设计与应用,涵盖了多个关键概念和技术。首先,程序设计方法中提到了嵌入式SQL,这是一种将SQL语言(用于定义和操作数据库)与通用程序设计语言(如C++或Basic)相结合的技术。...

    数据库基础与Visual FoxPro9.0程序设计.zip

    数据库基础与Visual FoxPro 9.0程序设计是计算机科学领域的一个重要主题,尤其是在学习数据库管理和应用程序开发时。Visual FoxPro 9.0是一款由Microsoft公司推出的数据库管理系统,它结合了数据库管理、编程和用户...

    基于ORACLE数据库程序设计

    Oracle数据库支持多种编程语言,包括SQL和PL/SQL,是企业级应用开发的重要平台。01_Oracle简介.ppt将详细介绍Oracle的历史、特性以及在业界的应用。 **Oracle 10g安装过程** 03_Oracle 10g 安装过程.ppt详细阐述了...

    Visual Foxpro数据库程序设计

    学习者需要学会如何根据业务需求设计数据库结构,编写数据库应用程序,并确保系统的稳定性和性能。这通常涉及到数据库的优化、错误处理和安全性设置。 在准备二级考试的过程中,除了理论知识的学习,实践操作同样...

    SQL Server 2000数据库程序设计

    《SQL Server 2000数据库程序设计》是学习数据库技术的重要参考资料,尤其对SQL Server 2000这一经典版本的理解与应用提供了深入指导。SQL Server 2000作为微软公司推出的企业级数据库管理系统,它在数据存储、查询...

    ASP.NET与数据库程序设计

    综上所述,"ASP.NET与数据库程序设计"的学习涵盖了Web开发、数据库理论、ADO.NET、SQL查询、ORM技术、数据库设计、性能优化、数据绑定和安全性等多个方面。通过深入理解和实践这些知识点,开发者能够构建出强大且...

    delphi高效数据库程序设计

    《Delphi高效数据库程序设计》是由知名IT专家李维撰写的一本专著,该书深入探讨了如何在Delphi环境中高效地构建数据库应用程序。书中涵盖了从基础到高级的各种技巧和最佳实践,旨在帮助开发者提高开发效率,提升软件...

    Delphi7高效数据库程序设计

    《Delphi7高效数据库程序设计》是一本专为Delphi初学者和进阶开发者准备的实战指南,旨在帮助读者深入理解和掌握使用Delphi7进行数据库应用程序开发的技术与技巧。本书的核心内容围绕如何利用Delphi7的强大功能,...

Global site tag (gtag.js) - Google Analytics