[李景山php]thinkphp核心源码注释|Oracle.class.php
2016-07-21 09:14
405 查看
<?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@gmail.com> // +---------------------------------------------------------------------- namespace Think\Db\Driver; use Think\Db\Driver; /** * Oracle数据库驱动 */ class Oracle extends Driver{ private $table = ''; protected $selectSql = 'SELECT * FROM (SELECT thinkphp.*, rownum AS numrow FROM (SELECT %DISTINCT% %FIELD% FROM %TABLE%%JOIN%%WHERE%%GROUP%%HAVING%%ORDER%) thinkphp ) %LIMIT%%COMMENT%'; /** * 解析pdo连接的dsn信息 * @access public * @param array $config 连接信息 * @return string */ protected function parseDsn($config){ $dsn = 'oci:dbname=//'.$config['hostname'].($config['hostport']?':'.$config['hostport']:'').'/'.$config['database']; if(!empty($config['charset'])) { $dsn .= ';charset='.$config['charset']; } return $dsn; } // 飘过 /** * 执行语句 * @access public * @param string $str sql指令 * @param boolean $fetchSql 不执行只是获取SQL * @return integer */ 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; } $flag = false; if(preg_match("/^\s*(INSERT\s+INTO)\s+(\w+)\s+/i", $str, $match)) { $this->table = C("DB_SEQUENCE_PREFIX").str_ireplace(C("DB_PREFIX"), "", $match[2]); $flag = (boolean)$this->query("SELECT * FROM user_sequences WHERE sequence_name='" . strtoupper($this->table) . "'"); } //释放前次的查询结果 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) { $this->error(); return false; } 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(); if($flag || preg_match("/^\s*(INSERT\s+INTO|REPLACE\s+INTO)\s+/i", $str)) { $this->lastInsID = $this->_linkID->lastInsertId(); } return $this->numRows; } }// 飘过 /** * 取得数据表的字段信息 * @access public */ public function getFields($tableName) { list($tableName) = explode(' ', $tableName); $result = $this->query("select a.column_name,data_type,decode(nullable,'Y',0,1) notnull,data_default,decode(a.column_name,b.column_name,1,0) pk " ."from user_tab_columns a,(select column_name from user_constraints c,user_cons_columns col " ."where c.constraint_name=col.constraint_name and c.constraint_type='P'and c.table_name='".strtoupper($tableName) ."') b where table_name='".strtoupper($tableName)."' and a.column_name=b.column_name(+)"); $info = array(); if($result) { foreach ($result as $key => $val) { $info[strtolower($val['column_name'])] = array( 'name' => strtolower($val['column_name']), 'type' => strtolower($val['data_type']), 'notnull' => $val['notnull'], 'default' => $val['data_default'], 'primary' => $val['pk'], 'autoinc' => $val['pk'], ); } } return $info; }// 飘过 /** * 取得数据库的表信息(暂时实现取得用户表信息) * @access public */ public function getTables($dbName='') { $result = $this->query("select table_name from user_tables"); $info = array(); foreach ($result as $key => $val) { $info[$key] = current($val); } return $info; }// 飘过 /** * SQL指令安全过滤 * @access public * @param string $str SQL指令 * @return string */ public function escapeString($str) { return str_ireplace("'", "''", $str); }// 飘过 /** * limit * @access public * @return string */ public function parseLimit($limit) { $limitStr = ''; if(!empty($limit)) { $limit = explode(',',$limit); if(count($limit)>1) $limitStr = "(numrow>" . $limit[0] . ") AND (numrow<=" . ($limit[0]+$limit[1]) . ")"; else $limitStr = "(numrow>0 AND numrow<=".$limit[0].")"; } return $limitStr?' WHERE '.$limitStr:''; }// 飘过 /** * 设置锁机制 * @access protected * @return string */ protected function parseLock($lock=false) { if(!$lock) return ''; return ' FOR UPDATE NOWAIT '; }// 飘过 }
相关文章推荐
- 关于Oracle的事务
- ORACLE PL/SQL 实例精解之第七章 迭代控制之二
- ORACLE in-memory parameter
- Oracle特殊字符插入与查询
- ORACLE PL/SQL 实例精解之第六章 迭代控制之一
- ORACLE PL/SQL 实例精解之第五章 条件控制:CASE语句
- ubuntu16.04安装oracle11g
- Oracle批量导入数据库存储过程
- ORACLE PL/SQL 实例精解之第四章 条件控制:if 语句
- SQL Server和Oracle中case when then 的用法及when like 的使用
- ORACLE PL/SQL 实例精解之第三章 PL/SQL中的SQL
- Oracle判断字段是否为空
- 【转载】oracle大表添加字段default经验分享
- JDBC连接mysql、sqlserver、oracle数据库示例,含代码
- ORACLE配置,修改tnsnames.ora文件实例
- oracle 游标使用
- Oracle编码设置为UTF-8
- Oracle中如何更新一张大表记录
- oracle常用函数
- Oracle语句