찾다
php教程php手册Firebird数据库的 PDO驱动

适用于:ThinkPHP3.2.3+

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

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

성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

Video Face Swap

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

SecList

SecList

SecLists는 최고의 보안 테스터의 동반자입니다. 보안 평가 시 자주 사용되는 다양한 유형의 목록을 한 곳에 모아 놓은 것입니다. SecLists는 보안 테스터에게 필요할 수 있는 모든 목록을 편리하게 제공하여 보안 테스트를 더욱 효율적이고 생산적으로 만드는 데 도움이 됩니다. 목록 유형에는 사용자 이름, 비밀번호, URL, 퍼징 페이로드, 민감한 데이터 패턴, 웹 셸 등이 포함됩니다. 테스터는 이 저장소를 새로운 테스트 시스템으로 간단히 가져올 수 있으며 필요한 모든 유형의 목록에 액세스할 수 있습니다.

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

VSCode Windows 64비트 다운로드

VSCode Windows 64비트 다운로드

Microsoft에서 출시한 강력한 무료 IDE 편집기

맨티스BT

맨티스BT

Mantis는 제품 결함 추적을 돕기 위해 설계된 배포하기 쉬운 웹 기반 결함 추적 도구입니다. PHP, MySQL 및 웹 서버가 필요합니다. 데모 및 호스팅 서비스를 확인해 보세요.

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기