PHP中使用匿名函数操作数据库的例子
Basedaoclassillustratingtheusefulnessofclosures. *Handlesopeningandclosingofconnections. *Addsslashessql *Typecheckingofsqlparametersandcastsasappropriate *Provideshookforprocessingofresultsetandemittingoneormoreobjects. *Provideshookforaccessingunderlyinglinkandresultobjects.
<?php
define("userName","root"); define("password","root"); define("dbName","ahcdb"); define("hostName","localhost");
classBaseDao{
functiongetConnection() { $link=mysql_connect(hostName,userName,password); if(!$link) die("Couldnotconnect:".mysql_error()); if(!mysql_select_db(dbName)) die("Couldnotselectdatabase:".mysql_error()); return$link; } functionsetParams(&$sql,$params) { if($params!=null) $sql=vsprintf($sql,array_map(function($n){ if(is_int($n)) return(int)$n; if(is_float($n)) return(float)$n; if(is_string($n)) return"'".mysql_real_escape_string($n)."'"; returnmysql_real_escape_string($n); },$params)); }
functionexecuteQuery($sql,$params,$callback=null) { $link =$this->getConnection(); $this->setParams($sql,$params); $return=null; if(($result=mysql_query($sql,$link))!=null) if($callback!=null) $return=$callback($result,$link); if($link!=null) mysql_close($link); if(!$result) die("FatalError:Invalidquery'$sql':".mysql_error()); return$return; } functiongetList($sql,$params,$callback) { return$this->executeQuery($sql,$params,function($result,$link)use($callback){ $idx=0; $list=array(); while($row=mysql_fetch_assoc($result)) if($callback!=null) $list[$idx]=$callback($idx++,$row); return$list; }); } functiongetSingle($sql,$params,$callback) { return$this->executeQuery($sql,$params,function($result,$link)use($callback){ if($row=mysql_fetch_assoc($result)) $obj=$callback($row); return$obj; }); } }
classExample { var$id; var$name; functionExample($id,$name){ $this->id=$id; $this->name=$name; } functionsetId($id){ $this->id=$id; } }
classExampleDaoextendsBaseDao { functiongetAll(){ returnparent::getList("select*fromnodes",null,function($idx,$row){ returnnewExample($row["id"],$row["name"]); }); } functionload($id){ returnparent::getSingle("select*fromnodeswhereid=%1\$s",array($id),function($row){ returnnewExample($row["id"],$row["name"]); }); } functionupdate($example){ returnparent::executeQuery("updatenodessetname=''where id=-1",null,function($result,$link){ return$result; }); } functioninsert(&$example){ returnparent::executeQuery("insertintonodes",null,function($result,$link)use($example){ $id=mysql_insert_id($link); $example->setId($id); return$result; }); } }
$exampleDao=newExampleDao();
$list=$exampleDao->getAll());
$exampleObject=$exampleDao->load(1));
$exampleDao->update($exampleObject);
?>