本文实例讲述了ZendFramework框架实现连接两个或多个数据库的方法。分享给大家供大家参考，具体如下：
配置文件：
rush:xml;">
PDO_MSSQL
localhost
1433
sa
123456
edudb
sqlsrv
PDO_MSSQL
localhost
1433
sa
123456
test
sqlsrv
入口文件
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调用默认数据库
getAdapter();
dao2.php连接其他数据库
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;
}
调用
getAdapter();
还是会连接默认数据库。
直接使用
db
就可以了
来看一下完整的dao2.php
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."
"; if ($pagesize) { $select->limit($pagesize,$offset); } //echo $select."
"; if (is_array($order)) { foreach ($order as $value) { $select->order($value); } } else { $select->order($order); } //echo $select."
"; $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."
"; return $result; } } else { if ($count) { $result = $this->db->fetchOne($select); //echo $select."
"; return $result; } } if (is_array($join)) { foreach ($join as $key => $val) { //$select->join($key,$val[0],$val[1]); $select->joinleft($key,$val[1]); } } //echo $select."
"; //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,$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",'BIG5')); //echo $encode; return mb_convert_encoding($string,"UTF-8"); //return $string; } } protected function &getCfg() { if ($this->cfg_ === null) { $registry = Zend_Registry::getInstance(); $this->cfg_ = $registry->get('web_config'); } return $this->cfg_; } }
"; if ($pagesize) { $select->limit($pagesize,$offset); } //echo $select."
"; if (is_array($order)) { foreach ($order as $value) { $select->order($value); } } else { $select->order($order); } //echo $select."
"; $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."
"; return $result; } } else { if ($count) { $result = $this->db->fetchOne($select); //echo $select."
"; return $result; } } if (is_array($join)) { foreach ($join as $key => $val) { //$select->join($key,$val[0],$val[1]); $select->joinleft($key,$val[1]); } } //echo $select."
"; //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,$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",'BIG5')); //echo $encode; return mb_convert_encoding($string,"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程序设计有所帮助。
