ZendFramework框架实现连接两个或多个数据库的方法

本文实例讲述了ZendFramework框架实现连接两个或多个数据库的方法。分享给大家供大家参考，具体如下：

配置文件：

     <db>
        <adapter>PDO_MSSQL</adapter>
      <config>
          <host>localhost</host>
          <port>1433</port>
          <username>sa</username>
          <password>123456</password>
          <dbname>edudb</dbname>
          <pdoType>sqlsrv</pdoType>
        </config>
      </db>
      <!-- 测试多数据库 -->
      <db2>
        <adapter>PDO_MSSQL</adapter>
          <config>
          <host>localhost</host>
          <port>1433</port>
          <username>sa</username>
          <password>123456</password>
          <dbname>test</dbname>
          <pdoType>sqlsrv</pdoType>
        </config>
      </db2>

入口文件

    //配置数据库连接
    $db_config = $web_config->db->config->toArray(); 
    //var_dump($db_config);
    $db = Zend_Db::factory($web_config->db->adapter, $db_config); 
    //var_dump($db);
    //exit;
    //$db->query('set NAMES utf8');
    //$db->getProfiler()->setEnabled(false); 
    Zend_Db_Table::setDefaultAdapter($db); 

这里是默认的数据库

dao.php调用默认数据库

    $db = &$this->getAdapter();

dao2.php连接其他数据库

    function init() {
        $web_config = $this->getCfg();
        $this->db2_config = $web_config->db2->config->toArray(); 
        //var_dump($this->db_config);
        $this->db = Zend_Db::factory($web_config->db2->adapter, $this->db2_config); 
        Zend_Db_Table::setDefaultAdapter($this->db); 
    }
    public function returnDb(){
        return $this->db;
    }

调用

    $db = &$this->getAdapter();

还是会连接默认数据库。

直接使用

    $this->db

就可以了

来看一下完整的dao2.php

    <?php
    class dao_dao2 extends Zend_Db_Table {
      protected $cfg_; 
      function init() {
        $web_config = $this->getCfg();
        $this->db2_config = $web_config->db2->config->toArray(); 
        //var_dump($this->db_config);
        $this->db = Zend_Db::factory($web_config->db2->adapter, $this->db2_config); 
        Zend_Db_Table::setDefaultAdapter($this->db); 
      }
      public function returnDb(){
        return $this->db;
      }
      public function getData($table,$where = false, $order = 'id ASC', $pagesize = false, $offset = false, $count = false, $from = false, $join = false, $group = false) {
        //$this->db = &$this->getAdapter();
        $select = $this->db->select();
        if ($where && is_array($where)) {
          foreach ($where as $key => $val) {
            //print_r($where);
            if($val['type']==1){
              $select->where($key, $this->convert2gbk($val['val']));
            }else{
              $select->orwhere($key, $this->convert2gbk($val['val']));
            }
          } 
        }
        if (!$from)
          $from = '*';
        //echo $select."<br/>";
        if ($pagesize) {
          $select->limit($pagesize, $offset);
        }
        //echo $select."<br/>";
        if (is_array($order)) {
          foreach ($order as $value) {
            $select->order($value);
          }
        } else {
          $select->order($order);
        }
        //echo $select."<br/>";
        $select->from($table, $count ? "COUNT(".$table.".id)" : $from);
        if (is_array($group)) {
          foreach ($group as $key => $val) {
            $select->group($val);
          }
          if ($count) {
            $result = $this->db->fetchAll($select);
            //echo $select."<br/>";
            return $result;
          }
        } else {
          if ($count) {
            $result = $this->db->fetchOne($select);
            //echo $select."<br/>";
            return $result;
          }
        }
        if (is_array($join)) {
          foreach ($join as $key => $val) {
            //$select->join($key, $val[0], $val[1]);
            $select->joinleft($key, $val[0], $val[1]);
          }
        }
        //echo $select."<br/>";
        //echo $select;exit;
        $result = $this->db->fetchAll($select);
        foreach ($result as $key => $value) {
          foreach ($value as $key2 => $value2) {
            $result[$key][$key2] = $this->convert2utf8($value2);
          }
        }
        return $result;
      }
      /**
       * 向表中插入数据
       * array $adata 数据
       * string $table 表名
       * int $insterid 是否需要返回插入ID
       * @return true or false or int
       */
       // @bianding 2013.11.04 更改了pdo中mssql.php的lastInsertId()函数
       // @bianding 2013.11.04 经测试 mssql.php中的lastInsertId()函数中的SELECT两种方式都行
      function SaveData($adata, $table, $insterid = 0, $aLog = false) {
        //$this->db = &$this->getAdapter();
        foreach ($adata as $key => $value) {
          $adata[$key] = $this->convert2gbk($value);
        }
        if ($this->db->insert($table, $adata)) {
          //var_dump($this->db->getProfiler());
          $insertedID = $this->db->lastInsertId();      
          if ($insterid) {
            return $insertedID;
          } else {
            return TRUE;
          }
        } else {
          return false;
        }
      }
      /**
       * 删除表中数据
       * 
       * @param string $table 表名
       * @param string $where 'id ='.$id 条件
       * @return true or false
       */
      function DelData($table, $where, $aLog = false) {
        //$this->db = & $this->getAdapter();
        if ($this->db->delete($table, $where)) {
          return TRUE;
        } else {
          return FALSE;
        }
      }
      /**
       * 更新表中数据
       *
       * @param string $table
       * @param array $adata
       * @param string $where 'id ='.$id
       * @return true or false
       */
      function UpdateData($table, $adata, $cond, $aLog = false) {
        //$this->db = & $this->getAdapter();
        foreach ($adata as $key => $value) {
          $adata[$key] = $this->convert2gbk($value);
        }
        if ($this->db->update($table, $adata, $cond)) {
          return TRUE;
        } else {
          return false;
        }
      }
      public function clearTable($table) {
        //$this->db = &$this->getAdapter();
        $result = $this->db->query('TRUNCATE TABLE ' . $table);
      }
      public function executeSql($strSql) {
        //$this->db = &$this->getAdapter();
        $result = $this->db->query($strSql);
      }
      function convert2utf8($string)
      {
        $config = $this->getCfg();
        $pdoType = $config->db->config->pdoType;
        if($pdoType == 'dblib'){
          return iconv("gbk","utf-8",$string);
        }elseif($pdoType == 'sqlsrv'){
          //$encode = mb_detect_encoding($string, array('UTF-8',"GB2312",'GBK','BIG5')); 
          //echo $encode;
          return mb_convert_encoding($string,"UTF-8","UTF-8");
          //return $string;
        }
      }
      function convert2gbk($string)
      {
        $config = $this->getCfg();
        $pdoType = $config->db->config->pdoType;
        if($pdoType == 'dblib'){
          return iconv("utf-8","gbk",$string);
        }elseif($pdoType == 'sqlsrv'){
          //$encode = mb_detect_encoding($string, array('UTF-8',"GB2312",'GBK','BIG5')); 
          //echo $encode; 
          return mb_convert_encoding($string,"UTF-8","UTF-8");
          //return $string;
        }
      }
      protected function &getCfg;() {
        if ($this->cfg_ === null) {
          $registry = Zend_Registry::getInstance();
          $this->cfg_ = $registry->get('web_config');
        }
        return $this->cfg_;
      } 
    }

更多关于zend相关内容感兴趣的读者可查看本站专题：《Zend FrameWork框架入门教程》、《php优秀开发框架总结》、《Yii框架入门及常用技巧总结》、《ThinkPHP入门教程》、《php面向对象程序设计入门教程》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家基于Zend Framework框架的PHP程序设计有所帮助。