国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 語言 > PHP > 正文

ZendFramework框架實現連接兩個或多個數據庫的方法

2024-05-04 23:53:24
字體:
來源:轉載
供稿:網友

本文實例講述了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

<?phpclass 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 Framework框架的PHP程序設計有所幫助。


注:相關教程知識閱讀請移步到PHP教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表

圖片精選

主站蜘蛛池模板: 清丰县| 井研县| 磐安县| 宁阳县| 临海市| 莆田市| 连州市| 丰宁| 甘孜县| 常德市| 南宫市| 岳西县| 宁强县| 运城市| 宣城市| 兴隆县| 永年县| 巴林右旗| 景宁| 孝义市| 额敏县| 无极县| 家居| 博乐市| 綦江县| 株洲市| 五大连池市| 泽普县| 马龙县| 鸡泽县| 莒南县| 泗阳县| 桃源县| 焦作市| 分宜县| 柘荣县| 白朗县| 孟津县| 花莲市| 得荣县| 乌拉特后旗|