http://www.xuebuyuan.com/1236808.html

心血来潮，做了一下PHP的对象到数据库的简单持久层。

不常用PHP，对PHP也不熟，关于PHP反射的大部分内容都是现学的。

目前功能比较弱，只是完成一些简单的工作，对象之间的关系还没法映射，并且对象的成员只能支持string或者integer两种类型的。

成员变量的值也没有转义一下。。。

下面就贴一下：

首先是数据库的相关定义，该文件定义了数据库的连接属性：

 

 

下面是数据库访问的简单封装：

 

其实上面的两个文件都是之前写好的，持久层的东西是下面的：

 

    hasProperty('tablename')) {			throw new Exception("Class '$class' has no [tablename] property");		}		$table = $r->getStaticPropertyValue('tablename');		if (!$r->hasProperty('id')) {			throw new Exception("Class '$class' has no [id] property");		}		$mpts = Array ();		$pts = $r->getProperties(ReflectionProperty :: IS_PUBLIC);		foreach ($pts as $pt) {			if (!$pt->isStatic()) {				array_push($mpts, $pt);			}		}		return Array (			$table,			$mpts		);	}		function SinORM_GetPropertyString($pts, $class, $obj = false, $noid = false) {		if (is_null($pts)) {			list ($tb, $pts) = SinORM_GetClassPropertys($class);		}		$s = false;		$v = false;		$l = false;		foreach ($pts as $pt) {			$name = $pt->name;			if ($noid == false || $name != 'id') {				if ($l) {					$s = $s . ',';				}				$s = $s . $name;					if ($obj) {					if ($l) {						$v = $v . ',';					}					$val = $pt->getValue($obj);					if (is_null($val))						$v = $v . 'null';					if (is_string($val))						$v = $v . "'$val'";					else						$v = $v . $val;				}				$l = true;			}		}		return Array (			$s,			$v		);	}		function SinORM_GetTableName($class){		$r = new ReflectionClass($class);		if (!$r->hasProperty('tablename')) {			throw new Exception("Class '$class' has no [tablename] property");		}		$table = $r->getStaticPropertyValue('tablename');		if (!$r->hasProperty('id')) {			throw new Exception("Class '$class' has no [id] property");		}		return $table;	}		function SinORM_ResetORM($class) {		list ($tb, $pts) = SinORM_GetClassPropertys($class);		$sql = "CREATE TABLE `$tb` (`id`  int NOT NULL AUTO_INCREMENT";		$r = new ReflectionClass($class);		$obj = $r->newInstance();		foreach ($pts as $pt) {			$val = $pt->getValue($obj);			$name = $pt->name;			if ($name != 'id') {				$sql = $sql . ',';			} else {				continue;			}			if (is_null($val))				throw new Exception($class . '->' . "name must have a default value");			if (is_string($val))				$sql = $sql . "`$name`  text NULL";			else				$sql = $sql . "`$name`  int NULL";		}		$sql = $sql . ",PRIMARY KEY (`id`));";		$dsql = "DROP TABLE IF EXISTS `$tb`;";		return SinORM_ExecSql($dsql) && SinORM_ExecSql($sql);	}	function SinORM_SaveObject($obj) {		$class = get_class($obj);		list ($tb, $pts) = SinORM_GetClassPropertys($class);		list ($names, $vals) = SinORM_GetPropertyString($pts, $class, $obj, true);		$sql = "INSERT INTO `$tb`($names) values($vals)";		if(SinORM_ExecSql($sql)){			$q = "SELECT `id` FROM `$tb` ORDER BY `id` DESC LIMIT 1;";			$id = SinORM_ExecResult($q);			if($id){				$obj->id = $id;			}		}		return false;	}	function SinORM_GetObjects($class) {		list ($tb, $pts) = SinORM_GetClassPropertys($class);		$sql = "SELECT * from `$tb`;";		$ary = SinORM_ExecArray($sql);		$res = false;		if (is_array($ary)) {			$res = Array ();			$ref = new ReflectionClass($class);			foreach ($ary as $a) {				$obj = $ref->newInstance();				foreach ($pts as $pt) {					$name = $pt->name;					$olv = $pt->getValue($obj);					$val = $a[$name];					if (is_string($olv))						$pt->setValue($obj, $val);					else						$pt->setValue($obj, intval($val));				}				array_push($res, $obj);			}		} else {			echo 'no';		}		return $res;	}	function SinORM_GetObject($class, $id) {		list ($tb, $pts) = SinORM_GetClassPropertys($class);		$sql = "SELECT * from `$tb` where `id`=$id;";		$ary = SinORM_ExecArray($sql);		$res = null;		if (is_array($ary) && count($ary) > 0) {			$res = Array ();			$ref = new ReflectionClass($class);			$a = $ary[0];			$obj = $ref->newInstance();			foreach ($pts as $pt) {				$name = $pt->name;				$olv = $pt->getValue($obj);				$val = $a[$name];				if (is_string($olv))					$pt->setValue($obj, $val);				else					$pt->setValue($obj, intval($val));			}			return $obj;		}		return null;	}	function SinORM_Update($obj) {		$class = get_class($obj);		list ($tb, $pts) = SinORM_GetClassPropertys($class);		$sql = "UPDATE `$tb` SET ";		$l = false;		foreach ($pts as $pt) {			$name = $pt->name;			$val = $pt->getValue($obj);			if ($name == 'id')				continue;			if ($l)				$sql = $sql . ',';			if (is_string($val))				$sql = $sql . "$name='$val'";			else				$sql = $sql . "$name=$val";			$l = true;		}		$sql = $sql . " WHERE `id`=$obj->id;";		return SinORM_ExecSql($sql);	}	function SinORM_SaveOrUpdate($obj) {		if (SinORM_GetObject(get_class($obj), $obj->id) == null) {			SinORM_SaveObject($obj);		} else {			SinORM_Update($obj);		}	}	function SinORM_DeleteObject($obj){		$class = get_class($obj);		$tb = SinORM_GetTableName($class);		$sql = "DELETE FROM `$tb` WHERE `id`=$obj->id;";		return SinORM_ExecSql($sql);	}	function SinORM_DeleteAll($class){		$tb = SinORM_GetTableName($class);		$sql = "DELETE FROM `$tb`;";		return SinORM_ExecSql($sql);	}?>

下面是使用的例子：

    name = 'TRB';	$user1->age = 22;	$user1->email = 'trbbadboy@qq.com';	SinORM_SaveObject($user1);	// 把对象保存到数据库中		// 保存之后会自动给id的	$id = $user1->id;	echo $id . '
';	 	$user2 = SinORM_GetObject('User', $id); // 通过ID从数据库创建一个对象	echo $user2->name . '
';		$user1->name = 'trb'; // 改变一下	SinORM_Update($user1); // 更新到数据库		$user3 = SinORM_GetObject('User', $id); // 重新读出	echo $user3->name . '
';?>