操作Oracle的php类

<?//【警告】:未经许可请勿随便修改//------------------------------------------------------------------------------------------//------------------------------------------------------------------------------------------//// 【文件名】:;;;;;c_ora_db.inc// 【作; 用】:;;;;;Oracle公用函数类// 【作; 者】:;;;;;天灰//; // 【最后修改日期】：;;;;;2001/05/11[cxx];;;// 【变量定义规则】：‘C_’=字符型,‘I_’=整型,‘N_’=数字型,‘L_’=布尔型,‘A_’=数组型//------------------------------------------------------------------------------------------//------------------------------------------------------------------------------------------//;※db_logon();开启数据库连接;;//;※db_query();通用select;;//;※db_change();数据库改变的通用函数（insert,delete,update）//;※db_insert();insert,直接调用db_change()//;※db_delete();delete,直接调用db_change()//;※db_update();update,直接调用db_change() //;※db_commit();事务递交//;※db_rollback();事务回退//;※db_logoff();断开数据库连接//------------------------------------------------------------------------------------------

Class c_ora_db{ //------------------------------------------------------------------------------------------//;;;;;变量定义//------------------------------------------------------------------------------------------ var $C_user; = '';;;;//数据库用户名 var $C_passwd;;;;;= '';;//数据库口令 var $C_db;= '';;//数据库名 var $I_linkID;;;;;= 0//连线句柄 var $I_stmtID;;;;;= 0//查询句柄 var $color;;='';;//全局颜色//------------------------------------------------------------------------------------------ //------------------------------------------------------------------------------------------//;;;;;函数名：db_logon()//;;;;;作; 用：开启数据库连接//;;;;;参; 数：无//;;;;;返回值：连线句柄（整型）//;;;;;备; 注：无//------------------------------------------------------------------------------------------ function; db_logon(); {; $this->I_linkID =; @OCILogon($this->C_user,$this->C_passwd,$this->C_db); if ($this->I_linkID == 0){AlertExit('数据库链接失败，请与DBA联系！');} return; $this->I_linkID;; }//------------------------------------------------------------------------------------------ //------------------------------------------------------------------------------------------//;;;;;函数名：db_query($C_sql,$A_define='',$I_start=-1,$I_end=-1)//;;;;;作; 用：select//;;;;;参; 数：$C_sql;sql语句//;;;;;$A_define;;;;;需绑定的字段。数组型 //;;;;;$I_start;;;;;开始取记录 -1则取出查询的所有记录//;;;;;$I_end;结束取纪录//;;;;;返回值：二维数组($A_rs)//;;;;;备; 注：通过数字0,1,2....可访问对应字段的值; 或通过查询字段名也可访问对应字段的值//;;;;;如通过$A_rs[0][0]或$A_rs[0]['NAME']或$A_rs[0]['name']都可访问首条记录NAME字段//;;;;;$I_start,$I_end是配合分页使用的参数。//------------------------------------------------------------------------------------------ function; db_query($C_sql,$A_define='',$I_start=-1,$I_end=-1) {; if (!$C_sql){AlertExit('参数不全！');}//检查参数 //连接检测 if ($this->I_linkID == 0){AlertExit('数据库链接失败，请与DBA联系！');} //格式检测 $this -> I_stmtID = OCIParse($this -> I_linkID,$C_sql);;; if (!$this -> I_stmtID){AlertExit(' sql格式出错！请与程序员联系');} //如果没指定绑定的字段，则从SQL语句中去取 if($A_define=='') { $A_Cur = explode('select',$C_sql); $A_Cur = explode('from',$A_Cur[1]); $A_define = explode(',',$A_Cur[0]); } //绑定数据库表字段 if(gettype($A_define) == 'array');//查询列是数组 { for($i=0;$i<count($A_define);$i++) { $A_define_up[$i] = trim(strtoupper($A_define[$i]));;//大写并去除空格 } for($i=0;$i<count($A_define_up);$i++) { OCIDefineByName($this -> I_stmtID,'$A_define_up[$i]',&$$A_define[$i]);;//绑定 } } elseif(trim($A_define) <> '');;;;;//查询列只有一个 { $A_define_up = trim(strtoupper($A_define)); OCIDefineByName($this -> I_stmtID,'$A_define_up',&$$A_define); }

//执行绑定好的SQL语句 if(!OCIExecute($this -> I_stmtID)) { echo '<font color=red><b>执行出错:</b></font>SQL Error:<font color=red>$C_sql</font><br>'; return false; } $lower = 0;;//返回二维数组的第一维下标控制变量 $cnt = 0;;//开始取数标识 //取记录 while (OCIFetchInto($this -> I_stmtID,&$cur,OCI_ASSOC)) { //取查询出来的所有记录 if ($I_start == -1) { if (gettype($A_define) == 'array');;;;;//查询列是数组 { for ($i=0;$i<count($A_define);$i++) { if ($cur[$A_define_up[$i]] <> $$A_define[$i]) { $$A_define[$i] = $cur[$A_define_up[$i]];;; } $A_rs[$lower][$i] = $$A_define[$i];;//用数字访问 $A_rs[$lower][$A_define[$i]] = $$A_define[$i] //用小些访问 $A_rs[$lower][$A_define_up[$i]] = $$A_define[$i];;//用大写访问 } } elseif (trim($A_define) <> '');//查询列只有一个 { if ($cur[$A_define_up] <> $$A_define) { $$A_define = $cur[$A_define_up];;; } $A_rs[$lower][0] = $$A_define;;//用数字访问 $A_rs[$lower][$A_define] = $$A_define //用小写访问 $A_rs[$lower][$A_define_up] = $$A_define;;//用大些访问 } $lower++;;//下标加一 } //取出指定记录(配合分页使用) if ($I_start <> -1) { if ($cnt >= $I_start) { $cnt++; if ($I_end - $I_start <> 0) { $I_end--; if (gettype($A_define) == 'array') { for($i=0;$i<count($A_define_up);$i++) { if ($cur[$A_define_up[$i]] <> $$A_define[$i]) { $$A_define[$i] = $cur[$A_define_up[$i]];;; } $A_rs[$lower][$i] = $$A_define[$i];;//用数字访问 $A_rs[$lower][$A_define[$i]] = $$A_define[$i] //用小些访问 $A_rs[$lower][$A_define_up[$i]] = $$A_define[$i];;//用大写访问 } }elseif(trim($A_define) <> '') { if ($cur[$A_define_up] <> $$A_define) { $$A_define = $cur[$A_define_up];;; } $A_rs[$lower][0] = $$A_define;;//用数字访问 $A_rs[$lower][$A_define] = $$A_define //用小些访问 $A_rs[$lower][$A_define_up] = $$A_define;;//用大写访问;; } $lower++; }else { break //如果$I_end-$I_start=0; 表示取完记录并跳出while循环 };; }else { $cnt++ //如果$cnt<$I_start,$cnt++ } } };;//while的结束 //释放句柄并返回查询数据（一个二维数组） OCIFreestatement($this -> I_stmtID); return $A_rs;;;; } //function的结束//------------------------------------------------------------------------------------------

//------------------------------------------------------------------------------------------//;;;;;函数名：db_change($C_sql,$A_bind)//;;;;;作; 用：db change//;;;;;参; 数：$C_sql;;;;;sql语句//;;;;;$A_bind;;;;;需绑定的字段。数组型 //;;;;;返回值：布尔值//;;;;;备; 注：insert,delete,update通用//------------------------------------------------------------------------------------------ function db_change($C_sql,$A_bind='') { if (!$C_sql){AlertExit('参数不全！');}//检查参数 //连接检测 if($this -> I_linkID==''){;AlertExit('我们的数据库正忙，请稍后再连接！');};; //格式检测 $this -> I_stmtID = OCIParse($this -> I_linkID,$C_sql);;; if (!$this -> I_stmtID){AlertExit(' sql格式出错！请与程序员联系');} //绑定 if(gettype($A_bind) == 'array') { for($i=0;$i<count($A_bind);$i++) { global $$A_bind[$i]; $$A_bind[$i] = StripSlashes($$A_bind[$i]);;//去掉反斜线字元 $$A_bind[$i] = str_replace('<?','< ?',$$A_bind[$i]);;//过滤掉PHP标示 } for($i=0;$i<count($A_bind);$i++){ OCIBindByName($this -> I_stmtID, ':$A_bind[$i]', &$$A_bind[$i], -1)//绑定 } } elseif(trim($A_bind) <> '');;;;;//不是数组，是字符 { global $$A_bind; $$A_bind = StripSlashes($$A_bind); $$A_bind = str_replace('<?','< ?',$$A_bind) //过滤掉PHP标示 OCIBindByName($this -> I_stmtID, ':$arrBind', &$$A_bind, -1); } //执行并检测是否成功 if(!OCIExecute($this -> I_stmtID,OCI_DEFAULT)) { echo '<font color=red><b>执行出错:</b></font>SQL Error:<font color=red>$C_sql</font><br>'; return false; } /*//传回受影响的行数 global $I_changenum; $I_changenum = OCINumrows($this -> I_stmtID);*/ //释放句柄，传回值 OCIFreeStatement($this -> I_stmtID); return true; }//------------------------------------------------------------------------------------------

//------------------------------------------------------------------------------------------//;;;;;函数名：db_delete($C_sql)//;;;;;作; 用：delete//;;;;;参; 数：C_sql;sql语句//;;;;;返回值：布尔值//;;;;;备; 注：该函数只是为了使用直观,本质调用db_change()//------------------------------------------------------------------------------------------ function db_delete($C_sql) { return $this -> db_change($C_sql); }//------------------------------------------------------------------------------------------

//------------------------------------------------------------------------------------------//;;;;;函数名：db_insert($C_sql,A_bind)//;;;;;作; 用：insert//;;;;;参; 数：C_sql;sql语句//;;;;;A_bind;绑定//;;;;;返回值：布尔值//;;;;;备; 注：该函数只是为了使用直观,本质调用db_change()//------------------------------------------------------------------------------------------ function db_insert($C_sql,$A_bind='') { return $this -> db_change($C_sql,$A_bind); }//------------------------------------------------------------------------------------------

//------------------------------------------------------------------------------------------//;;;;;函数名：db_update($C_sql,A_bind)//;;;;;作; 用：update//;;;;;参; 数：C_sql;sql语句//;;;;;A_bind;绑定//;;;;;返回值：布尔值//;;;;;备; 注：该函数只是为了使用直观,本质调用db_change()//------------------------------------------------------------------------------------------ function db_update($C_sql,$A_bind='') { return $this -> db_change($C_sql,$A_bind); }//------------------------------------------------------------------------------------------

//------------------------------------------------------------------------------------------//;;;;;函数名：db_commit()//;;;;;作; 用：事务递交//;;;;;参; 数：无//;;;;;返回值：布尔值//;;;;;备; 注：无//------------------------------------------------------------------------------------------;; function db_commit() { return;(OCICommit($this->I_linkID)); };;//------------------------------------------------------------------------------------------

//------------------------------------------------------------------------------------------//;;;;;函数名：db_rollback()//;;;;;作; 用：事务回退//;;;;;参; 数：无//;;;;;返回值：布尔值//;;;;;备; 注：无//------------------------------------------------------------------------------------------;; function db_rollback() { return; (OCIRollback($this->I_linkID)); };;//------------------------------------------------------------------------------------------ //------------------------------------------------------------------------------------------//;;;;;函数名：db_logoff()//;;;;;作; 用：断开数据库连接//;;;;;参; 数：无//;;;;;返回值：布尔值//;;;;;备; 注：无//------------------------------------------------------------------------------------------;; function db_logoff() { return (OCILogoff($this->I_linkID)); }//------------------------------------------------------------------------------------------ //------------------------------------------------------------------------------------------}?>