PHP简单的ORM实现（postgresql）

andyyuduo

　　用户表简单操作，简单orm实现原理：
　　postgresql:system_user表如下：
　　/*
　　Navicat Premium Data Transfer
　　Source Server         : 本地
　　Source Server Type    : PostgreSQL
　　Source Server Version : 90404
　　Source Host           : 127.0.0.1
　　Source Database       : dbname
　　Source Schema         : public
　　Target Server Type    : PostgreSQL
　　Target Server Version : 90404
　　File Encoding         : utf-8
　　Date: 08/21/2015 16:33:36 PM
　　*/
　　-- ----------------------------
　　--  Table structure for system_user
　　-- ----------------------------
　　DROP TABLE IF EXISTS "public"."system_user";
　　CREATE TABLE "public"."system_user" (
　　"id" int4 NOT NULL DEFAULT nextval('system_user_id_seq'::regclass),
　　"first_name" varchar(64) COLLATE "default",
　　"last_name" varchar(128) COLLATE "default",
　　"username" varchar(32) COLLATE "default",
　　"md5_pw" varchar(32) COLLATE "default",
　　"email_address" varchar(128) COLLATE "default",
　　"date_last_login" date,
　　"date_account_created" date,
　　"time_last_login" time(6),
　　"time_account_created" time(6)
　　)
　　WITH (OIDS=FALSE);
　　ALTER TABLE "public"."system_user" OWNER TO "username";
　　-- ----------------------------
　　--  Records of system_user
　　-- ----------------------------
　　BEGIN;
　　INSERT INTO "public"."system_user" VALUES ('9', 'Tim', 'Nowicki', '', null, '', '2015-08-21', '2015-08-21', '16:01:42', '16:01:46');
　　INSERT INTO "public"."system_user" VALUES ('11', 'Tim', 'Nowicki', '', null, '', '2015-08-21', '2015-08-21', '16:04:11', '16:04:13');
　　INSERT INTO "public"."system_user" VALUES ('12', 'Tim', 'Nowicki', '', null, '', '2015-08-21', '2015-08-21', '16:05:15', '16:06:02');
　　INSERT INTO "public"."system_user" VALUES ('13', 'Tim', 'LinLIIII', null, null, null, '2015-08-21', '2015-08-21', null, null);
　　INSERT INTO "public"."system_user" VALUES ('14', 'Lin', 'Nowicki', null, null, null, null, '2015-08-21', null, null);
　　INSERT INTO "public"."system_user" VALUES ('15', 'Lin', 'Nowicki', null, null, null, null, '2015-08-21', null, null);
　　COMMIT;
　　-- ----------------------------
　　--  Primary key structure for table system_user
　　-- ----------------------------
　　ALTER TABLE "public"."system_user" ADD PRIMARY KEY ("id") NOT DEFERRABLE INITIALLY IMMEDIATE;
　　1,简单的orm实现
　　用户类（User2.php）
　　<?php
　　/* 
　　* To change this license header, choose License Headers in Project Properties.
　　* To change this template file, choose Tools | Templates
　　* and open the template in the editor.
　　*/
　　class User{
　　private $ID;
　　private $objPDO;
　　private $strTableName;
　　private $arRelationMap;
　　private $blForDeletion;
　　private $FirstName;
　　private $LastName;
　　private $Username;
　　private $Password;
　　private $EmailAddress;
　　private $DateLastLogin;
　　private $TimeLastLogin;
　　private $DateAccountCreated;
　　private $TimeAccountCreated;
　　public function __construct(PDO $objPDO,$id = NULL) {
　　$this->strTableName = "system_user";
　　$this->arRelationMap = [
　　"id"                    => "ID",
　　"first_name"            => "FirstName",
　　"last_name"             => "LastName",
　　"username"              => "Username",
　　"md5_pw"                => "password",
　　"email_address"         => "EmailAddress",
　　"date_last_login"       => "DateLastLogin",
　　"time_last_login"       => "TimeLastLogin",
　　"date_account_created"  => "DateAccountCreated",
　　"time_account_created"  => "TimeAccountCreated"
　　];
　　$this->objPDO = $objPDO;
　　if(isset($id)){
　　$this->ID = $id;
　　$strQuery = "SELECT ";
　　foreach ($this->arRelationMap as $key => $value) {
　　$strQuery .= "\"".$key."\",";
　　}
　　$strQuery = substr($strQuery, 0, strlen($strQuery)-1);
　　$strQuery .=" FROM ".$this->strTableName." WHERE \"id\" = :eid";
　　$objStatement = $this->objPDO->prepare($strQuery);
　　$objStatement->bindParam(':eid', $this->ID, PDO::PARAM_INT);
　　$objStatement->execute();
　　$arRow = $objStatement->fetch(PDO::FETCH_ASSOC);
　　foreach ($arRow as $key => $value) {
　　$strMember = $this->arRelationMap[$key];
　　if(property_exists($this, $strMember)){
　　if(is_numeric($value)){
　　eval('$this->'.$strMember .' = '.$value.';');
　　}else{
　　eval('$this->'.$strMember.' = "'.$value.'";');
　　}
　　}
　　}
　　}
　　}
　　public function Save(){
　　if(isset($this->ID)){
　　$strQuery = 'UPDATE "'.$this->strTableName.'" SET ';
　　foreach ($this->arRelationMap as $key => $value) {
　　eval('$actualVal = &$this->'.$value.';');
　　if(isset($actualVal)){
　　$strQuery .= '"' .$key. "\" = :$value,";
　　}
　　}
　　$strQuery = substr($strQuery, 0,strlen($strQuery)-1);
　　$strQuery .=' WHERE "id"=:eid';
　　unset($objStatement);
　　$objStatement = $this->objPDO->prepare($strQuery);
　　$objStatement->bindValue(':eid', $this->ID,  PDO::PARAM_INT);
　　foreach ($this->arRelationMap as $key => $value) {
　　eval('$actualVal = &$this->'.$value.';');
　　if(isset($actualVal)) {
　　if(is_int($actualVal)){
　　$objStatement->bindValue(':'.$value, $this->$value, PDO::PARAM_INT);
　　}elseif($actualVal == NULL){
　　//postgresql：if some column type is null,update will cause error,u need insert null,not ''
　　$objStatement->bindValue(':'.$value, NULL, PDO::PARAM_STR);
　　}else{
　　$objStatement->bindValue(':'.$value, $this->$value, PDO::PARAM_STR);
　　}
　　}
　　}
　　$objStatement->execute();
　　echo '更新成功';exit;
　　}else{
　　$strValueList = "";
　　$strQuery = 'INSERT INTO "'.$this->strTableName.'" (';
　　foreach ($this->arRelationMap as $key => $value) {
　　eval('$actualVal = &$this->'.$value.';');
　　if(isset($actualVal)){
　　$strQuery .= '"' .$key. '",';
　　$strValueList .= ":$value,";
　　}
　　}
　　$strQuery = substr($strQuery, 0, strlen($strQuery)-1);
　　$strValueList = substr($strValueList, 0, strlen($strValueList)-1);
　　$strQuery .= ") VALUES (";
　　$strQuery .= $strValueList;
　　$strQuery .= ")";
　　unset($objStatement);
　　$objStatement = $this->objPDO->prepare($strQuery);
　　foreach ($this->arRelationMap as $key => $value) {
　　eval('$actualVal = &$this->'.$value.';');
　　if(isset($actualVal)){
　　if(is_int($actualVal) || $actualVal == NULL){
　　$objStatement->bindValue(':'.$value, $actualVal, PDO::PARAM_INT);
　　}else{
　　$objStatement->bindValue(':'.$value, $actualVal, PDO::PARAM_STR);
　　}
　　}
　　}
　　$objStatement->execute();
　　$this->ID = $this->objPDO->lastInsertId($this->strTableName."_id_seq");
　　}
　　}
　　public function MarkFordeletion(){
　　$this->blForDeletion = true;
　　}
　　public function __destruct() {
　　if(isset($this->ID)){
　　if($this->blForDeletion == true){
　　$strQuery = 'DELETE FROM "'.$this->strTableName.'" WHERE "id" =:eid';
　　$objStatement = $this->objPDO->prepare($strQuery);
　　$objStatement->bindValue(':eid', $this->ID,  PDO::PARAM_INT);
　　$objStatement->execute();
　　echo '删除成功';exit;
　　}
　　}
　　}
　　public function __call($strFunction, $arArguments) {
　　$strMethodType = substr($strFunction, 0,3);
　　$strMethodMember = substr($strFunction, 3);
　　switch ($strMethodType) {
　　case 'set':
　　return ($this->SetAccessor($strMethodMember, $arArguments[0]));
　　break;
　　case 'get':
　　return ($this->GetAccessor($strMethodMember));
　　}
　　return (false);
　　}
　　private function SetAccessor($strMember,$strNewValue){
　　if(property_exists($this, $strMember)){
　　if(is_numeric($strNewValue)){
　　eval('$this->'.$strMember.' = '.$strNewValue.';');
　　}else{
　　eval('$this->'.$strMember.' = "'.$strNewValue.'";');
　　}
　　}else{
　　return (false);
　　}
　　}
　　private function GetAccessor($strMember){
　　if(property_exists($this, $strMember)){
　　eval('$strRetVal = $this->'.$strMember.';');
　　return ($strRetVal);
　　}else{
　　return (false);
　　}
　　}
　　}
　　2，postgresql连接（PdoFactory.php）：
　　<?php
　　/* 
　　* To change this license header, choose License Headers in Project Properties.
　　* To change this template file, choose Tools | Templates
　　* and open the template in the editor.
　　*/
　　class PdoFactory extends PDO{
　　public static function getPDO($osn,$username, $passwd, $options){
　　try { 
　　$pdo = new PDO($osn,$username, $passwd, $options); 
　　$pdo->setAttribute(PDO::ATTR_PERSISTENT, true);  // 设置数据库连接为持久连接  
　　$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  // 设置抛出错误  
　　} catch (PDOException $e) { 
　　exit('数据库连接失败，错误信息：'. $e->getMessage()); 
　　} 
　　return $pdo;
　　}
　　}
　　测试：
　　1插入用户数据：
　　<?php
　　/* 
　　* To change this license header, choose License Headers in Project Properties.
　　* To change this template file, choose Tools | Templates
　　* and open the template in the editor.
　　*/
　　require_once 'PdoFactory.php';
　　require_once 'User2.php';
　　//$dsn = 'mysql:host=127.0.0.1;dbname=tesst;port=3306';
　　//host=127.0.0.1 port=5432 dbname=dbname user=username password=123456
　　$dsn ="pgsql:dbname=dbname;host=127.0.0.1;port=5432";
　　$objPdo = PdoFactory::getPDO($dsn,'username','123456',[]);
　　$objUser = new User($objPdo);
　　//print_r($objUser);
　　$objUser->setFirstName('Lin');
　　$objUser->setLastName('Nowicki');
　　$objUser->setDateAccountCreated(date('Y-m-d'));
　　echo $objUser->getFirstName();
　　echo '<br />';
　　echo $objUser->getLastName();
　　echo '<br />';
　　print 'Saving...<br/>';
　　$objUser->Save();
　　print "ID in dateBase is ". $objUser->getID()."<br />";
　　执行结果：
　　Lin
Nowicki
Saving...
ID in dateBase is 16
　　2，更新用户数据：
　　require_once 'PdoFactory.php';
　　require_once 'User2.php';
　　//$dsn = 'mysql:host=127.0.0.1;dbname=tesst;port=3306';
　　//host=127.0.0.1 port=5432 dbname=dbname user=username password=123456
　　$dsn ="pgsql:dbname=dbname;host=127.0.0.1;port=5432";
　　$objPdo = PdoFactory::getPDO($dsn,'username','123456',[]);
　　$objUser = new User($objPdo,16);
　　$objUser->setFirstName("Tim");
　　$objUser->setLastName("LinLIIII");
　　$objUser->Save();
　　产生结果：
　　更新成功
　　3,删除用户数据：
　　require_once 'PdoFactory.php';
　　require_once 'User2.php';
　　//$dsn = 'mysql:host=127.0.0.1;dbname=tesst;port=3306';
　　//host=127.0.0.1 port=5432 dbname=dbname user=username password=123456
　　$dsn ="pgsql:dbname=dbname;host=127.0.0.1;port=5432";
　　$objPdo = PdoFactory::getPDO($dsn,'username','123456',[]);
　　$objUser = new User($objPdo,16);
　　$objUser->MarkFordeletion();
　　执行结果：
　　删除成功