function mysqldb($tablename="",$database="mysql") //构造函数
{
$this->nerr=0;
$this->newedit=0;
$this->stname=$tablename;
$this->nresult=-1;
$this->ncols=0;
$this->nrows=0;
$this->noffset=0;
$this->eof=true;
unset($this->afname);
unset($this->anew);
if(!$this->linkid=mysql_connect($host,$user,$password))
{
$this->nerr=1;
$this->serr="mysqldb:数据库连接出错，请启动服务!";
return;
}
if(!$this->dbid=mysql_select_db($database))
{
$this->nerr=1;
$this->serr="mysqldb:选择的数据库".$database."不存在!";
return;
}
}

function isempty($value)
{
if(is_string($value)&&empty($value))
return true;
return false;
}

function destroy() //数据清除处理
{
mysql_query("commit");
mysql_close();
}

function printerr()
{
if($this->nerr==1)
{
echo($this->serr."<br><br>");
}
else
{
echo("没有错误<br><br>");
}
}

function execute($sql) //直接执行sql语句
{
if(empty($sql))
{
$this->nerr=1;
$this->serr="execute:执行语句不能为空！";
return false;
}
$this->ssql=$sql;
if(!mysql_query($sql))
{
$this->nerr=1;
$this->serr="execute:sql语句：".$sql."<br>mysql错误：".mysql_error();
return false;
}
return true;
}

//在数据库里执行查询，sql是查询的字段，condition是查询条件，order是以什么排序，sequenc是按升序还是降序
function query($tablename="",$sql="*",$condition="",$order="",$sequenc="")
{
if(!empty($tablename))
$this->stname=$tablename;
$strsql="select ".$sql." from ".$this->stname;
if(!empty($condition))
$strsql=$strsql." where ".$condition;
if(!empty($order))
$strsql=$strsql." order by ".$order;
if(!empty($sequenc))
$strsql=$strsql." ".$sequenc;
$this->ssql=$strsql;
if(!$this->nresult=mysql_query($strsql))
{
$this->nerr=1;
$this->serr="query:sql语句：".$strsql."<br>mysql错误：".mysql_error()."<br>";
return;
}
$this->noffset=0;
$this->nrows=mysql_num_rows($this->nresult);
$this->ncols=mysql_num_fields($this->nresult);
if($this->nrows>0)
$this->eof=false;
else
$this->eof=true;
unset($this->afname);
$this->afname=array();
for($i=0;$i<$this->ncols;$i++)
$this->afname[$i]=strtolower(mysql_field_name($this->nresult,$i));
}

function movenext()
{
if($this->eof)
{
$this->nerr=1;
$this->serr="movenext:已经移到记录集末尾！";
return;
}
$this->noffset++;
if($this->noffset>=$this->nrows)
$this->eof=true;
}

function moveto($offset)
{
if(empty($offset))
{
$this->nerr=1;
$this->serr="moveto:必须指定偏移量! ";
return;
}

if(!$this->nresult)
{
$this->nerr=1;
$this->serr="moveto:请先执行查询:query";
return;
}
$this->noffset=$offset;
}

//得到指定行的指定列的值，返回字符串
//如果不指定offset将取得下一行的值
//如果不指定nfields将取得该行的值，并已数组形式返回
function getvalue($nfields=-1,$offset=-1)
{
if($this->nresult==-1)
{
$this->nerr=1;
$this->serr="getvalue:请先执行query()函数！";
return;
}
if($offset>-1)
{
$this->noffset=$offset;
if($this->noffset>=$this->nrows)
{
$this->nerr=1;
$this->serr="getvalue:所要求的偏移量太大，无法达到！";
return;
}
}
if(!@mysql_data_seek($this->nresult,$this->noffset))
{
$this->nerr=1;
$this->serr="getvalue:请求不存在的记录！";
return;
}
$aresult=mysql_fetch_row($this->nresult);
if(is_int($nfields)&&$nfields>-1)
{
if($nfileds>$this->ncols)
{
$this->nerr=1;
$this->serr="getvalue:所请求的列值大于实际的列值！";
return;
}
return $aresult[$nfields];
}
if(is_string($nfields))
{
$nfields=strtolower($nfields);
for($i=0;$i<$this->ncols;$i++)
{
if($this->afname[$i]==$nfields)
break;
}
if($i==$this->ncols)
{
$this->nerr=1;
$this->serr="getvalue:所请求的列不存在，请仔细检查！";
return;
}
return $aresult[$i];
}
return $aresult;
}

function addnew($tablename="") //标志开始添加数据
{
if(!empty($tablename))
$this->stname=$tablename;
if($this->newedit>0)
{
$this->nerr=1;
$this->serr="addnew:你正在对数据库进行添加或更新操作！";
return;
}
if(empty($this->stname))
{
$this->nerr=1;
$this->serr="addnew:想要添加的数据库表为空，可以在构造时指定，也可在addnew()时指定！";
return;
}
unset($this->anew);
$this->anew=array();
$this->newedit=1;
$strsql="select * from ".$this->stname;
$this->ssql=$strsql;
if(!$this->nresult=mysql_query($strsql))
{
$this->nerr=1;
$this->serr="addnew:sql语句：".strsql."<br><br>mysql错误：".mysql_error();
return;
}
$this->ncols=mysql_num_fields($this->nresult);
unset($this->afname);
$this->afname=array();
for($i=0;$i<$this->ncols;$i++)
$this->afname[$i]=strtolower(mysql_field_name($this->nresult,$i));
}

function edit($condition="",$tablename="") //对指定数据库表进行编辑
{
if(!empty($tablename))
$this->stname=$tablename;
$this->seditcon=$condition;
if(empty($this->stname))
{
$this->nerr=1;
$this->serr="edit:在编辑前请先指定数据库表！";
return;
}
unset($this->anew);
$this->anew=array();
$this->newedit=2;
$strsql="select * from ".$this->stname;
$this->ssql=$strsql;
if(!$this->nresult=mysql_query($strsql))
{
$this->nerr=1;
$this->serr="edit:sql语句：".strsql."<br><br>mysql错误：".mysql_error();
return;
}
$this->ncols=mysql_num_fields($this->nresult);
unset($this->afname);
$this->afname=array();
for($i=0;$i<$this->ncols;$i++)
$this->afname[$i]=strtolower(mysql_field_name($this->nresult,$i));
}

function setvalue($index,$value) //指定数据，跟在addnew后执行;
{
if($this->newedit==0)
{
$this->nerr=1;
$this->serr="setvalue:请先执行addnew()或者edit()！";
return;
}
if(is_int($index))
{
if($index<0||$index>$this->ncols)
{
$this->nerr=1;
$this->serr="setvalue:插入不存在的列值！";
return;
}
$this->anew[$index]=$value;
return;
}
if(is_string($index))
{
$index=strtolower($index);
for($i=0;$i<$this->ncols;$i++)
{
if($this->afname[$i]==$index)
break;
}
if($i==$this->ncols)
{
$this->nerr=1;
$this->serr="setvalue:插入不存在的列值！";
return;
}
$this->anew[$i]=$value;
return;
}
}

function update() //存储新值到数据库
{
$strsql="";
$sname="";
$svalue="#@!";
$sedit="#@!";

if($this->newedit==0)
{
$this->nerr=1;
$this->serr="update:请先执行addnew()或者edit()，再用setvalue()添加值！";
return;
}

//得到想要添加的字段名
for($i=0;$i<$this->ncols;$i++)
{
if(is_int($this->anew[$i])||(is_string($this->anew[$i])&&!empty($this->anew[$i])))
{
if(!empty($sname))
$sname.=",";
$sname.=$this->afname[$i];
//根据当前字段的类型生成相应的新值
if($svalue!="#@!")
$svalue.=",";
else
$svalue="";
$ftype=@mysql_field_type($this->nresult,$i);
//echo($ftype.",".$this->anew[$i].",".$i.":".$svalue."<br>");
switch($ftype)
{
case "string":
case "date":
$svalue.="\"".$this->anew[$i]."\"";
$sedit="\"".$this->anew[$i]."\"";
break;
case "int":
case "unknown":
$svalue.=$this->anew[$i];
$sedit=$this->anew[$i];
break;
default:
$this->nerr=1; $this->serr="update:字段名为".$this->afname[$i]."的".$ftype."类型目前版本不支持，请用别的方法添加数据！";
return;
}
if($this->newedit==2)
$sname.="=".$sedit;
}
}

if(empty($svalue))
{
$this->nerr=1;
$this->serr="update:在数据为空的情况下，不能添加或修改数据！";
return;
}

switch($this->newedit)
{
case 1:
$strsql="insert into ";
$strsql.=$this->stname;
$strsql.=" (".$sname.") ";
$strsql.="values (".$svalue.")";
break;
case 2:
$strsql="update ";
$strsql.=$this->stname;
$strsql.=" set ";
$strsql.=$sname;
if(!empty($this->seditcon))
$strsql.=" where ".$this->seditcon;
break;
default:
$this->nerr=1;
$this->serr="update:update()生成sql语句出错，请检查！";
return;
}

$this->ssql=$strsql;
if(!$this->nresult=mysql_query($strsql))
{
$this->nerr=1;
$this->serr="update:sql语句：".$strsql."<br><br>mysql错误：".mysql_error();
return;
}

//作清理工作
$this->newedit=0;
unset($this->anew);
mysql_query("commit");
return;
}
}
?>

编辑：黑鹰　[发送给好友] [打印本页] [关闭窗口] [返回顶部]
上一篇：谈两种数据库内容html格式的输出方法
下一篇：万能的数据库连接程序
转载请注明来源：www.iyit.net
特别声明： 本站除部分特别声明禁止转载的专稿外的其他文章可以自由转载，但请务必注明出处和原始作者。文章版权归文章原始作者所有。对于被本站转载文章的个人和网站，我们表示深深的谢意。如果本站转载的文章有版权问题请联系编辑人员，我们尽快予以更正。