时时商务社区

标题: ZendFramework框架实现连接两个或多个数据库的方法 [打印本页]

作者: 阿情 时间: 2018-2-14 05:29

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

PDO_MSSQL

   localhost
   1433
   sa
   123456
   edudb
   sqlsrv




PDO_MSSQL

   localhost
   1433
   sa
   123456
   test
   sqlsrv


入口文件
//配置数据库连接
$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
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[0], $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, $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程序设计有所帮助。


您可能感兴趣的文章:

zend framework多模块多布局配置

windows下zendframework项目环境搭建(通过命令行配置)

zend framework配置操作数据库实例分析

解析如何使用Zend Framework 连接数据库

Zend Framework 2.0事件管理器（The EventManager）入门教程

Zend Framework连接Mysql数据库实例分析

Zend Framework教程之连接数据库并执行增删查的方法(附demo源码下载)

Zend Framework开发入门经典教程

Zend Framework入门教程之Zend_Db数据库操作详解

Zend Framework数据库操作方法实例总结

Zend Framework数据库操作技巧总结

ZendFramework2连接数据库操作实例

欢迎光临时时商务社区 (http://bbs.4435.cn/)