您现在的位置是：首页 > 数据库

当前栏目

操作Oracle的php类

Oracle PHP 操作

2023-06-13 09:13:43 时间

<?
//【警告】:未经许可请勿随便修改
//------------------------------------------------------------------------------------------
//------------------------------------------------------------------------------------------
//
//【文件名】: 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() 断开数据库连接
//------------------------------------------------------------------------------------------

Classc_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"<fontcolor=red>执行出错:SQLError:<fontcolor=red>$C_sql ";
 returnfalse;
 }

 $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)
// 作 用：dbchange
// 参 数：$C_sql sql语句
// $A_bind 需绑定的字段。数组型
// 返回值：布尔值
// 备 注：insert,delete,update通用
//------------------------------------------------------------------------------------------
 functiondb_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"<fontcolor=red>执行出错:SQLError:<fontcolor=red>$C_sql ";
 returnfalse;
 }

 /*//传回受影响的行数
 global$I_changenum;
 $I_changenum=OCINumrows($this->I_stmtID);*/

 //释放句柄，传回值
 OCIFreeStatement($this->I_stmtID);
 returntrue;
 }
//------------------------------------------------------------------------------------------

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

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

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

//------------------------------------------------------------------------------------------
// 函数名：db_rollback()
// 作 用：事务回退
// 参 数：无
// 返回值：布尔值
// 备 注：无
//------------------------------------------------------------------------------------------
 functiondb_rollback()
 {
 return (OCIRollback($this->I_linkID));
 }
//------------------------------------------------------------------------------------------


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


//------------------------------------------------------------------------------------------
}
?>

猜你喜欢

网站速度测试工具
Microsoft Office主要套件已支持WEBP图像格式不需要转格式插入更方便
大学生数学竞赛非数专题三（1）
ORA-39315: Cannot drop the first data file from a permanent or undo tablespace. ORACLE 报错故障修复远程处理
Redis集群分类灵活解决复杂集群管理（redis集群分类）
【开发工具】前端开发者更换新电脑，需要做哪些准备？
Google 为什么要从头开发一套新的操作系统 Fuchsia ？
Oracle表全局搜索从容面对海量数据（oracle全表搜索内容）
Linux重启IP：重启让系统更加健康！（linux 重启ip）
借你一双慧眼，识别代码安全审计工具「建议收藏」
的交互深入MySQL数据库交互之旅（与mysql数据库）
MySQL新建数据库：一步一步指南（mysql新建数据库）
Ruby语言中的String深入理解
传三星将缩减中低端机型镜头数量，模组需求或将减少8700万个
Redis取回集合中的所有值（redis返回集合所有值）

zl程序教程

当前栏目

操作Oracle的php类

相关文章