类页面
include_once (dirname(__FILE__)."\ConnDB.php");
class SqlHelper{
private $_arr;
public $tableName;
public function dataBind($key,$value)
{
$this->_arr[$key]=$value;
}
public function validate()
{
if(!isset($this->tableName))
{
die("表名不能为空!");
}
if(!isset($this->_arr))
{
die("值与列名未绑定");
}
}
public function update($condition){
foreach($this->_arr as $key => $value){
$s .= "$key = $value,";
}
$ss = substr($s,0,-1);
$sql = "update $this->tableName set $ss where $condition";
$query = mysql_query($sql);
echo $sql;
if($query)
{
echo "数据修改成功";
}
else
{
echo "数据修改失败";
}
}
public function insert()
{
$this->validate();
$keys = "";
$values = "";
foreach($this->_arr as $key=>$value)
{
$keys.="`$key`,";
if($value=="")
{
$values.="null,";
}
else
{
$values.="'$value',";
}
}
$keys = substr($keys,0,strlen($keys)-1);
$values = substr($values,0,strlen($values)-1);
$sql = "insert into `$this->tableName`($keys)values($values)";
$query = mysql_query($sql);
if($query)
{
echo "ok";
}
else
{
echo "no";
}
//echo mysql_error();
//return $query;
}
public function Delete($condition)
{
if(!isset($this->tableName))
{
die("表名不能为空!");
}
$sql="delete from $this->tableName where $condition";
$query=mysql_query($sql);
if($query)
{
echo "删除成功!";
}
else
{
echo mysql_error();
}
}
function select($sqls)//读取出符合where子句的所有信息
{
$sql = "select * from `$this->tableName` where $sqls";
$query = mysql_query($sql);
/*
$result = array();
while($rs = mysql_fetch_array($query))
{
$result[]=$rs;
}
return $result; */
$num = mysql_num_rows($query);
return $num;
}
function selectNew($sqls,$n)//读取出符合where子句的最新的n条信息
{
$sql = "select * from `$this->tableName`
where $sqls
order by `id` desc
limit 0,$n";
$query = mysql_query($sql);
$result = array();
while($rs = mysql_fetch_array($query))
{
$result[]=$rs;
}
return $result;
}
}
?>
实例化页面
$inserts = new SqlHelper();
$inserts->tableName="user";
$inserts->dataBind("name","bbbb");
$inserts->dataBind("address","");
$inserts->insert();
$inserts = new SqlHelper();
$inserts->tableName="user";
$inserts->dataBind("name","33333");
$inserts->dataBind("address","44444");
$inserts->update("id = 13");
$inserts=new SqlHelper();
$inserts->tableName="user";
$inserts->Delete("id=4");
这是我以前写的类,你看看!
update 如果要是用数组来插入的话 可以用FOREACH 循环
$array 为POST 或者GET的数组 当然字段要都是表里面的字段
function update($array)
{
if($this->where == '')
{
$where = '';
}else{
$where = ' where '.$this->where;
}
if(empty($array))
{
echo "不能插入空数组";exit;
}
$str = '';
foreach($array as $key => $val)
{
$str .= '`'.$key.'`'.'='.'\''.$val.'\''.',';
}
$str = substr($str,0,-1);
$sql ="update `".$this->table."` set ".$str.$where." ";
$this->query($sql);
}
function fn_update($table,$FieldName2,$value2,$FieldName1,$value1)
{
$this->query("update `$table` set $FieldName2 where $FieldName1");
}
$db->fn_update('weblink','`weblink` = \'abc\', `WebName` = \'def\',`Introduction` = \'ghk\'','`link_id` = 29');