一个MYSQL连接类

来源:www.phpres.com 作者：Angelover 出处：www.phpres.com 2007-8-7 19:20:37 进入讨论组

关键词：连接一个 base // result this-dBaseLink 数据库 function

class dbLink            //数据库查询的类
{   var $dBaseLink;        //数据库连接指针
var $dBase;

function dbLink($base="")        //构造函数
//$base 为选择数据库名称
{ $this->dBaseLink=@mysql_connect("host","user","password");
if(!$this->dBaseLink) die($this->dbError("1"));
if($base!="") $this->dbChange($base);

}

function dbClose()        //关闭数据库连接
{ mysql_close($this->dBaseLink);
}

function dbError($n,$sql="")    //输出错误信息,并退出程序
{
$dbErrorCode=array(
1 => "不能连接到数据库",
1004 => DB_ERROR_CANNOT_CREATE,
1005 => DB_ERROR_CANNOT_CREATE,
1006 => DB_ERROR_CANNOT_CREATE,
1007 => "对象已经存在，不能完成创建操作",
1008 => "不能完成删除操作",
1046 => DB_ERROR_NODBSELECTED,
1050 => DB_ERROR_ALREADY_EXISTS,
1051 => DB_ERROR_NOSUCHTABLE,
1054 => "所检索的字段不存在",
1062 => DB_ERROR_ALREADY_EXISTS,
1064 => DB_ERROR_SYNTAX,
1100 => DB_ERROR_NOT_LOCKED,
1136 => DB_ERROR_VALUE_COUNT_ON_ROW,
1146 => "所检索的数据表不存在",
1049 => "所选择的数据库不存在"
);
echo "<div style='background-color:#dddddd;color:#000000;font-size:9pt;width=400' align=center>错误 $n ：".$dbErrorCode[$n]."<BR>".$sql."</div>";

}
function dbChange($base)        //改变当前数据库
{
$this->dBase=$base;
@mysql_select_db($base,$this->dBaseLink);
if($msg=mysql_errno($this->dBaseLink)) die($this->dbError($msg));

}

function dbQuery($sql,$base="",$type=0)     //对指定数据库进行访问
//$sql为SQL语句
//$base为访问的数据库名，如果没有则使用上次使用的
//$type为返回数组格式，0返回name=>value形式，1返回value格式
{ if($base!="" || $this->dBase!=$base) $this->dbChange($base);
$result=@mysql_query($sql,$this->dBaseLink);
if($msg=mysql_errno($this->dBaseLink)) die($this->dbError($msg,$sql));

@$num=mysql_num_rows($result);
if($num==0) $rtArray="";
else {
for($i=0;$i<$num;$i++)
$rtArray[$i]=($type==0)?mysql_fetch_array($result):mysql_fetch_row($result);

}
@mysql_free_result($result);
return $rtArray;
}

function dbCountRecords($table,$where="",$base="",$index="id")  //统计表中记录的数目
//$table 操作的数据表名称
//$where 完整的where子句
//$base  操作的数据库名称
//$index 操作所使用的索引字段
{ if($base!="" || $this->dBase!=$base) $this->dbChange($base);
$result = mysql_query("select count(".$index.") as 'num' from $table ".$where,$this->dBaseLink);
@$num = mysql_result($result,0,"num");
@mysql_free_result($result);
return $num;
}

function dbIo($sql,$base="")                //无返回值的SQL操作，例如insert操作，返回新插入的id,update和delete无返回值
{ if($base!="" || $this->dBase!=$base) $this->dbChange($base);
$result=@mysql_query($sql,$this->dBaseLink);
@mysql_free_result($result);
return mysql_insert_id($this->dBaseLink);

}

function dbFieldList($table,$base)                //字段信息列表
{ $pt = @mysql_list_fields($base,$table);
if($msg=mysql_errno($this->dBaseLink)) die($this->dbError($msg));
$n=mysql_num_fields($pt);
for($i=0;$i<$n;$i++) {
$name    =    mysql_field_name($pt,$i);
$type    =    mysql_field_type($pt,$i);
$len    =    mysql_field_len($pt,$i);
$rt[$i]=array("name" => $name,                //字段名称
"type" => $type,                //字段类型
"len"     => $len);                //字段长度
}
return $rt;
}

function dbTableList($basename)                //数据库basename的表信息
{
$result=mysql_list_tables($basename,$this->dBaseLink);
$rt=mysql_fetch_array($result);
@mysql_free_result($result);
return $rt;
}

}欢迎进入PHP开发资源论坛讨论。

【收藏此文】【大中小】【打印】【关闭】

上一篇：一个很方便的 XML 类
下一篇：写了一个odbc连mssql分页的类