php mysql数据库操作类

<div class="codetitle"><a style="CURSOR: pointer" data="34548" class="copybut" id="copybut34548" onclick="doCopy('code34548')"> 代码如下:<div class="codebody" id="code34548">
<?php
/
mysql数据库DB类
@packagedb
@authoryytcpt(无影)
@version2008-03-27
@copyrigthhttp://www.d5s.cn/
/
classdb{
var$connection_id="";
var$pconnect=0;
var$shutdown_queries=array();
var$queries=array();
var$query_id="";
var$query_count=0;
var$record_row=array();
var$failed=0;
var$halt="";
var$query_log=array();
functionconnect($db_config){
if($this->pconnect){
$this->connection_id=mysql_pconnect($db_config["hostname"],$db_config["username"],$db_config["password"]);
}else{
$this->connection_id=mysql_connect($db_config["hostname"],$db_config["password"]);
}
if(!$this->connection_id){
$this->halt("CannotconnectMySQLServer");
}
if(!@mysql_select_db($db_config["database"],$this->connection_id)){
$this->halt("CannotconnectMySQLDatabase");
}
if($db_config["charset"]){
@mysql_unbuffered_query("SETNAMES'".$db_config["charset"]."'");
}
returntrue;
}
//发送SQL查询，并返回结果集
functionquery($query_id,$query_type='mysql_query'){
$this->query_id=$query_type($query_id,$this->connection_id);
$this->queries[]=$query_id;
if(!$this->query_id){
$this->halt("查询失败:n$query_id");
}
$this->query_count++;
$this->query_log[]=$str;
return$this->query_id;
}
//发送SQL查询，并不获取和缓存结果的行
functionquery_unbuffered($sql=""){
return$this->query($sql,'mysql_unbuffered_query');
}
//从结果集中取得一行作为关联数组
functionfetch_array($sql=""){
if($sql=="")$sql=$this->query_id;
$this->record_row=@mysql_fetch_array($sql,MYSQL_ASSOC);
return$this->record_row;
}
functionshutdown_query($query_id=""){
$this->shutdown_queries[]=$query_id;
}
//取得结果集中行的数目，仅对INSERT，UPDATE或者DELETE
functionaffected_rows(){
return@mysql_affected_rows($this->connection_id);
}
//取得结果集中行的数目，仅对SELECT语句有效
functionnum_rows($query_id=""){
if($query_id=="")$query_id=$this->query_id;
return@mysql_num_rows($query_id);
}
//返回上一个MySQL操作中的错误信息的数字编码
functionget_errno(){
$this->errno=@mysql_errno($this->connection_id);
return$this->errno;
}
//取得上一步INSERT操作产生的ID
functioninsert_id(){
return@mysql_insert_id($this->connection_id);
}
//得到查询次数
functionquery_count(){
return$this->query_count;
}
//释放结果内存
functionfree_result($query_id=""){
if($query_id=="")$query_id=$this->query_id;
@mysql_free_result($query_id);
}
//关闭MySQL连接
functionclose_db(){
if($this->connection_id)return@mysql_close($this->connection_id);
}
//列出MySQL数据库中的表
functionget_table_names(){
global$db_config;
$result=mysql_list_tables($db_config["database"]);
$num_tables=@mysql_numrows($result);
for($i=0;$i<$num_tables;$i++){
$tables[]=mysql_tablename($result,$i);
}
mysql_free_result($result);
return$tables;
}
//从结果集中取得列信息并作为对象返回，取得所有字段
functionget_result_fields($query_id=""){
if($query_id=="")$query_id=$this->query_id;
while($field=mysql_fetch_field($query_id)){
$fields[]=$field;
}
return$fields;
}
//错误提示
functionhalt($the_error=""){
$message=$the_error."
rn";
$message.=$this->get_errno()."
rn";
$sql="INSERTINTOdb_error(pagename,errstr,timer)VALUES('".$_SERVER["PHP_SELF"]."','".addslashes($message)."',".time().")";
@mysql_unbuffered_query($sql);
if(DEBUG==true){
echo"";
echo"<styletype="text/css">rn";
echo"rn";
echo"

rn";
echo"<textareaclass="error"rows="15"cols="100"wrap="on">".htmlspecialchars($message)."rn";
echo"