Firebird数据库的 PDO驱动-php手册-php.cn

Firebird数据库的 PDO驱动

WBOY

Lepaskan： 2016-06-07 11:41:08

asal

1307 orang telah melayarinya

适用于：ThinkPHP3.2.3+

<?php // +---------------------------------------------------------------------- // | ThinkPHP [ WE CAN DO IT JUST THINK IT ] // +---------------------------------------------------------------------- // | Copyright (c) 2006-2014 http://thinkphp.cn All rights reserved. // +---------------------------------------------------------------------- // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 ) // +---------------------------------------------------------------------- // | Author: liu21st <liu21st> // +---------------------------------------------------------------------- namespace Think\Db\Driver; use Think\Db\Driver; use PDO; /** * Firebird数据库驱动 */ class Firebird extends Driver{ protected $selectSql = 'SELECT %LIMIT% %DISTINCT% %FIELD% FROM %TABLE%%JOIN%%WHERE%%GROUP%%HAVING%%ORDER%'; /** * 解析pdo连接的dsn信息 * @access public * @param array $config 连接信息 * @return string */ protected function parseDsn($config){ $dsn = 'firebird:dbname='.$config['hostname'].'/'.($config['hostport']?:3050).':'.$config['database']; return $dsn; } /** * 连接数据库方法 * @access public */ public function connect($config='',$linkNum=0) { if ( !isset($this->linkID[$linkNum]) ) { if(empty($config)) $config = $this->config; try{ if(empty($config['dsn'])) { $config['dsn'] = $this->parseDsn($config); } $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password']); }catch (\PDOException $e) { E($e->getMessage()); } } return $this->linkID[$linkNum]; } /** * 执行语句 * @access public * @param string $str sql指令 * @param boolean $fetchSql 不执行只是获取SQL * @return mixed */ public function execute($str,$fetchSql=false) { $this->initConnect(true); if ( !$this->_linkID ) return false; $this->queryStr = $str; if(!empty($this->bind)){ $that = $this; $this->queryStr = strtr($this->queryStr,array_map(function($val) use($that){ return '\''.$that->escapeString($val).'\''; },$this->bind)); } if($fetchSql){ return $this->queryStr; } //释放前次的查询结果 if ( !empty($this->PDOStatement) ) $this->free(); $this->executeTimes++; N('db_write',1); // 兼容代码 // 记录开始执行时间 $this->debug(true); $this->PDOStatement = $this->_linkID->prepare($str); if(false === $this->PDOStatement) { E($this->error()); } foreach ($this->bind as $key => $val) { if(is_array($val)){ $this->PDOStatement->bindValue($key, $val[0], $val[1]); }else{ $this->PDOStatement->bindValue($key, $val); } } $this->bind = array(); $result = $this->PDOStatement->execute(); $this->debug(false); if ( false === $result) { $this->error(); return false; } else { $this->numRows = $this->PDOStatement->rowCount(); return $this->numRows; } } /** * 取得数据表的字段信息 * @access public */ public function getFields($tableName) { $this->initConnect(true); list($tableName) = explode(' ', $tableName); $sql='SELECT RF.RDB$FIELD_NAME AS FIELD,RF.RDB$DEFAULT_VALUE AS DEFAULT1,RF.RDB$NULL_FLAG AS NULL1,TRIM(T.RDB$TYPE_NAME) || \'(\' || F.RDB$FIELD_LENGTH || \')\' as TYPE FROM RDB$RELATION_FIELDS RF LEFT JOIN RDB$FIELDS F ON (F.RDB$FIELD_NAME = RF.RDB$FIELD_SOURCE) LEFT JOIN RDB$TYPES T ON (T.RDB$TYPE = F.RDB$FIELD_TYPE) WHERE RDB$RELATION_NAME=UPPER(\''.$tableName.'\') AND T.RDB$FIELD_NAME = \'RDB$FIELD_TYPE\' ORDER By RDB$FIELD_POSITION'; $result = $this->query($sql); $info = array(); if($result){ foreach($result as $key => $val){ $info[trim($val['FIELD'])] = array( 'name' => trim($val['FIELD']), 'type' => $val['TYPE'], 'notnull' => (bool) ($val['NULL1'] ==1), // 1表示不为Null 'default' => $val['DEFAULT1'], 'primary' => false, 'autoinc' => false, ); } } //获取主键 $sql='select b.rdb$field_name as field_name from rdb$relation_constraints a join rdb$index_segments b on a.rdb$index_name=b.rdb$index_name where a.rdb$constraint_type=\'PRIMARY KEY\' and a.rdb$relation_name=UPPER(\''.$tableName.'\')'; $rs_temp = $this->query($sql); foreach($rs_temp as $row) { $info[trim($row['FIELD_NAME'])]['primary']=True; } return $info; } /** * 取得数据库的表信息 * @access public */ public function getTables($dbName='') { $sql='SELECT DISTINCT RDB$RELATION_NAME FROM RDB$RELATION_FIELDS WHERE RDB$SYSTEM_FLAG=0'; $result = $this->query($sql); $info = array(); foreach ($result as $key => $val) { $info[$key] = trim(current($val)); } return $info; } /** * SQL指令安全过滤 * @access public * @param string $str SQL指令 * @return string */ public function escapeString($str) { return str_replace("'", "''", $str); } /** * limit * @access public * @param $limit limit表达式 * @return string */ public function parseLimit($limit) { $limitStr = ''; if(!empty($limit)) { $limit = explode(',',$limit); if(count($limit)>1) { $limitStr = ' FIRST '.$limit[1].' SKIP '.$limit[0].' '; }else{ $limitStr = ' FIRST '.$limit[0].' '; } } return $limitStr; } }</liu21st>

AD：真正免费，域名+虚机+企业邮箱=0元