操作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　　{
　　$A_define_up[$i] = trim(strtoupper($A_define[$i])); //大写并去除空格
　　}
　　for($i=0;$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 "执行出错:SQL Error:$C_sql
";
　　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　　{
　　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　　{
　　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

查看本文来源