电脑技术学习

操作Oracle的php类

dn001

<?
//【警告】:未经许可请勿随便修改
//------------------------------------------------------------------------------------------
//------------------------------------------------------------------------------------------
//
// 【文件名】:;;;;;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));
}
//------------------------------------------------------------------------------------------

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

标签：

上一篇 怎么样写PHP代码才会被录用?

下一篇 用PHP5的DirectoryIterators递归扫描目录

相关文章