Zendframework连接两个或多个数据库的实现
2023-09-27 14:24:31 时间
配置文件
<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_; } }
相关文章
- 实践案例丨Pt-osc工具连接rds for mysql 数据库失败
- 数据库技术丨GaussDB(DWS)数据同步状态查看方法
- 【数据库开发】Redis消息通知
- Java连接PostgreSQL数据库
- C语言连接MySQL数据库(转)
- Codeigniter开发技巧:连接多个数据库(可实现DB读写分离)
- **mysql数据库中实现内连接、左连接、右连接
- Python3出现"No module named 'MySQLdb'"问题-以及使用PyMySQL连接数据库
- DBeaver连接国产信创数据库的步骤
- 不同数据库连接字符串的网站
- 性能库 Oracle数据库 连接不上问题的解决
- Go 连接 mysql 数据库的简单测试.
- Ubuntu-12.04.5 安装 oracle 12.2.0.1 数据库database软件
- Java 连接 Access数据库方式
- 主流图数据库Neo4J、ArangoDB、OrientDB综合对比:架构分析
- 学会4种备份MySQL数据库(基本备份方面没问题了)
- 让你提前认识软件开发(29):数据库脚本文件的布局
- plsql 通过修改配置文件的方式实现数据库的连接
- JDBC连接数据库
- Navicat的安装与mysql数据库的连接保姆级教程
- 【数据库】AlwaysOn 可用性群组(AOAG)
- PHP 数据库驱动、连接数据不同方式学习笔记
- oracle 数据库字符集研究 下篇
- asp.net 可视化操作(二)——Sql数据库连接及简单查询功能的实现
- c++ 连接MySql数据库并执行插入,查询数据测试代码