搜尋
首頁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 Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您聽不到任何人,如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解鎖Myrise中的所有內容
3 週前By尊渡假赌尊渡假赌尊渡假赌

熱工具

WebStorm Mac版

WebStorm Mac版

好用的JavaScript開發工具

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

SublimeText3 英文版

SublimeText3 英文版

推薦:為Win版本,支援程式碼提示!

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

DVWA

DVWA

Damn Vulnerable Web App (DVWA) 是一個PHP/MySQL的Web應用程序,非常容易受到攻擊。它的主要目標是成為安全專業人員在合法環境中測試自己的技能和工具的輔助工具,幫助Web開發人員更好地理解保護網路應用程式的過程,並幫助教師/學生在課堂環境中教授/學習Web應用程式安全性。 DVWA的目標是透過簡單直接的介面練習一些最常見的Web漏洞,難度各不相同。請注意,該軟體中