#1 $php
/////////////////////////////////////////////////////////////////
// SpeedPHP中文PHP框架, Copyright (C) 2008 - 2010 SpeedPHP.com //
/////////////////////////////////////////////////////////////////
/**
* db_oracle Oracle数据库的驱动支持
*/
class db_oracle {
/**
* 数据库链接句柄
*/
public $conn;
/**
* 执行的SQL语句记录
*/
public $arrSql;
/**
* exec执行影响行数
*/
private $num_rows;
/**
* 需要转换小写的地方
*/
public $RESULT_FIELD_NAME_LOWER = true;
/**
* 按SQL语句获取记录结果，返回数组
*
* @param sql 执行的SQL语句
*/
public function getArray($sql)
{
$result = &$this->exec($sql);
$res = array();
while($row = $this->fetch($result)){
$res[] = $row;
}
return $res;
}
/**
* 返回当前插入记录的主键ID
*/
public function newinsertid(){
$sql = "SELECT ";
}
/**
* 格式化带limit的SQL语句
*/
public function setlimit($sql, $limit)
{
$limitarr = explode(',',str_replace(' ','',$limit));
$total = (isset($limitarr[1])) ? ($limitarr[1] + $limitarr[0]) : $limitarr[0];
$start = (isset($limitarr[1])) ? $limitarr[0] : 0;
return "SELECT * FROM ( SELECT SPTMP_LIMIT_TBLNAME.*, ROWNUM SPTMP_LIMIT_ROWNUM FROM ({$sql}) SPTMP_LIMIT_TBLNAME WHERE ROWNUM <= {$total} )WHERE SPTMP_LIMIT_ROWNUM > {$start}";
}
/**
* 执行一个SQL语句
*
* @param sql 需要执行的SQL语句
*/
public function &exec($sql,&$row=null)
{
$this->arrSql[] = $sql;
$stmt = oci_parse($this->conn,$sql);
//bind 数据
if(is_array($row)){
foreach($row as $k=>$v){
oci_bind_by_name($stmt, ":{$k}", $row[$k]);
}
}
$rs = @oci_execute($stmt);
if(!$rs){
$e = oci_error($stmt);
spError("{$sql}
执行错误: " . strip_tags($e['message']));
return false;
}
$this->num_rows = oci_num_rows($stmt);
return $stmt;
}
/**
* 返回影响行数
*/
public function affected_rows()
{
return $this->num_rows;
}
/**
* 获取数据表结构
*
* @param tbl_name 表名称
*/
public function getTable($tbl_name)
{
$tbl_name = strtoupper($tbl_name);
$upcaseres = $this->getArray("SELECT COLUMN_NAME AS FIELD FROM USER_TAB_COLUMNS WHERE TABLE_NAME = '{$tbl_name}'");
foreach( $upcaseres as $k => $v ){
$v = $this->RESULT_FIELD_NAME_LOWER?strtolower($v['field']):$v['field'];
$upcaseres[$k] = array('Field'=>$v);
}
return $upcaseres;
}
/**
* 构造函数
*
* @param dbConfig 数据库配置
*/
public function __construct($dbConfig)
{
if(!function_exists('oci_connect'))spError('PHP环境未安装ORACLE函数库！');
$linkfunction = ( TRUE == $dbConfig['persistent'] ) ? 'oci_pconnect' : 'oci_connect';
$this->conn = ocilogon($dbConfig['login'], $dbConfig['password'], $dbConfig['host'],'utf8');
if(!$this->conn){
$e = oci_error();spError('数据库链接错误 : ' . strip_tags($e['message']));
return false;
}
$this->exec('ALTER SESSION SET NLS_DATE_FORMAT = \'yyyy-mm-dd hh24:mi:ss\'');
}
/*取下一行数据
返回:成功，返回结果数组
*/
function fetch(&$stmt){
$row = array();
ocifetchinto($stmt, $row, OCI_ASSOC | OCI_RETURN_LOBS | OCI_RETURN_NULLS);
if ($this->RESULT_FIELD_NAME_LOWER) {
$row = array_change_key_case($row, CASE_LOWER);
}
return $row;
}
/**
* 对特殊字符进行过滤
*
* @param value 值
*/
public function __val_escape($value, $quotes = FALSE) {
if(is_null($value))return 'NULL';
if(is_bool($value))return $value ? 1 : 0;
if(is_int($value))return (int)$value;
if(is_float($value))return (float)$value;
if(@get_magic_quotes_gpc())$value = stripslashes($value);
$value = str_replace("_","\_",$value);
$value = str_replace("%","\%",$value);
if($quotes)$value = "'{$value}'";
return $value;
}
/**
* 析构函数
*/
public function __destruct()
{
if( TRUE != $dbConfig['persistent'] )@oci_close($this->conn);
}
}
2011-06-05 00:31:14