昆汀·澤瓦斯的 DBO

《Web 2.0 開發實戰》一書的作者，Quentin Zervaas 在書中提到的一個簡易PHP資料存取物件。

 /**
 * DatabaseObject
 *
 * 用於輕鬆操作資料庫表中資料的抽象類別
 * 透過簡單的載入/儲存/刪除方法
*/
 抽象類別 DatabaseObject
 {
 const TYPE_TIMESTAMP = 1;
 {
 const TYPE_TIMESTAMP = 1;
 conOOst 2;

 protected static $types = array(self::TYPE_TIMESTAMP, self::TYPE_BOOLEAN);

 private $_id = null;
 private $arra_perties;


 protected $_db = null;
 protected $_table = '';
 protected $_idField = '';

 public function __construct(Zend_b_AdAd表, $idField)
 {
 $this->_db = $db;
 $this->_table = $table;
 $this->_idField = $idField;
 }

 public function load($id, $field = null)
 {
 if (strlen($field) == 0)
 $field = $this->_idField ;

 if ($field == $this->_idField) {
 $id = (int) $id;
 if ($id  回傳false ;
 }

 $query = sprintf('從%s 中選擇%s，其中%s = ?',
 join(', ', $this->getSelectFields()),
 $this- >_table,
 $field);

 $query = $this->_db->quoteInto($query, $id);

 return $this->_load($query );
 }

 protected function getSelectFields($prefix = '')
 {
 $fields = array($prefix . $this->_idField);
 foreach ($prefix . $this->_idField);
 foreach ($prefix . $this->_idField);
 foreach ($prefix . $this->_idField);
 foreach ($prefix> foreach ($ this->_properties as $k => $v)
 $fields[] = $prefix 。 load ($query)
 {
 $result = $this->_db->query ($query);
 $row = $result->fetch();
 if (!$row )
 回傳false;

 $this->_init($row );

 $this->postLoad();

 回傳true;
 }

 public function _init($row)
 {
 foreach ($this->_properties as $k => $v) {
 $val = $row[$k];

 switch ($v['type']) {
 case self::TYPE_TIMESTAMP:
 if (!is_null($val))
 $val = strtotime($val);
 break;
 case self::TYPE_BOOLEAN:
 $val = (bool) $val;
 規則;
 }

 $this->_properties[$k][$k][$k] ' value'] = $val;
 }
 $this ->_id = (int) $row[$this->_idField];
 }


 public function save ( $useTransactions = true)
 {
 $update = $this->isSaved();

 if ($useTransactions)
 $this->_db->beginTransaction();

 if ($update)
 $commit = $this->preUpdate();
 else
 $commit = $this->preInsert();

 if (> if (> if ( ! $commit) {
 if ( $useTransactions)
 $this->_db->rollback();
 return false;
 }

 $row = array();

 foreach ( $this->_properties 為 $k =>; $v) {
 if ($update && !$v['updated'])
 continue;

 switch ($v['type']) {
 case self:: TYPE_TIMESTAMP:
 if (!is_null($v['value'])) {
 if ($this->_db instanceof Zend_Db_Adapter_Pdo_Pgsql)
 $v['value'] = date'Y-m-m i:sO', $v['value']);
 else
 $v['value'] = date('Y-m-d H:i:s', $v['value']);
 }
 中斷;

 case self::TYPE_BOOLEAN:
 $v['value'] = (int) ((bool) $v['value']);
break;
 }

 $row[$k] = $v['value'];
 }

 if (count($row) > 0) {
 // 執行插入/更新
 if ($update) {
 $this->_db->update($this->_table, $row, sprintf('%s = %d) ', $ this->_idField, $this->getId()));
 }
 else {
 $this->_db->insert($this->_table, $row);
 $this->_id = $this->_db->lastInsertId ($this->_table , $this->_idField);
 }
 }

 // 更新內部id

 if ($commit) {
 if ($update)
 $commit = $this->postUpdate();
 else
 $commit = $this->postInsert();
 }

 if ($useTransactions) {
 if ( $commit)
 $this->_db->commit();
 else
 $this->_db->rollback();
 }

 return $commit;
 }

 public function delete($useTransactions = true)
 {
 if (!$this->isSaved() )
 return false;

if ( $useTransactions)
 $this->_db->beginTransaction();

 $commit = $this->preDelete( );

 if ($commit) {
 $ this->_db->delete($this->_table, sprintf('%s = %d', $this->; _idField, $this->getId()));
 }
 else {
 if ($useTransactions)
 $this->_db->rollback();
 return false;
 }

 $commit = $this->postDelete();

 $this->_id = null;

 if ($useTransactions) {
 if ($commit)
 $this->_db->commit();
 else
 $this->_db->rollback();
 }

 return $commit;
 }

 public function isSaved()
 {
 { return $this->getId() > 0;
 }

 public function getId()
 {
 return (int) $this->_id;
 }

 public function getDb()
 {
 return $this->_db;
 }

 public function __set($name, $value)
 {
 if (array_key_exists($name, $this->_properties)) {
 $this->_properties[$name]['value'] = $value;
 $this->_properties[$name][' 。 array_key_exists($name, $this->_properties) ？ $this->_properties[$name]['value'] : null;
 }

 protected function add($field, $default = null, $type = null)
 {
 $this->_properties[$field] = array('value' => $default,
 'type' => in_array($type, self::$types) ? $type : null,
 ' Updated' => false);
 }

 受保護函數preInsert()
 {
 回傳true;
 }

 受保護函數postInsert ()
 {
 回傳true;
 }

 受保護函數preUpdate()
 {
 回傳true;
 }

 受保護函數postUp )
 {
 回傳true;
 }

 受保護函數preDelete()
 {
 回傳true;
 }

 受保護函數postDelete ()
 {
 return true;
 }

 protected function postLoad()
 {
 return true;
 }
 }
 return true;
 }
函數BuildMultiple($db, $class, $data)
 {
 $ret = array();

 if (!class_exists($class))
 throw new Exception('未未定義的類別指定的： ' 。 '類別不是來自DatabaseObject 擴充的' );

 foreach ($data as $row) {
 $obj = new $class($db);
 $obj->_init($row );

 $ret[$obj->getId()] = $obj;
 }

 return $ret;
 }
 }



 複製程式碼


 class DatabaseObject_User extends DatabaseObject
 {
 static $userTypes = array('member' => 'Member',
 '管理員> ' => '管理員');

 public $profile = null;
 public $_newPassword = null;

 public function __construct($db)
 {
 Parent::__construct($db, 'users', 'user_id');

 $this->add('使用者名稱');
 $this->add('密碼') ;
 $this->add('user_type', 'member');
 $this->add('ts_created', time(), self::TYPE_TIMESTAMP);
 $this->add(' ts_last_login', null, self::TYPE_TIMESTAMP);

 $this->profile = new Profile_User($db);
 }

 protected function presert( ) $this->_newPassword = Text_Password::create(8);
 $this->password = $this->_newPassword;
 return true;
 }

 protected function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function postLoted function post」 ()
 {
 $this->profile->setUserId($this->getId());
 $this->profile-> ;load();
 }

 $this->profile->setUserId($this->getId());
 $this->profile->save(false);

 $this->sendEmail('user-register.tpl');
 return true;
 }

 受保護函數postUpdate()
 {
 $this $this ->profile->save(false);
 return true;
 }

 受保護函數preDelete()
 {
 $this->profile->delete();
 return true;
 }

 public function sendEmail($tpl)
 {
 $templater = new Templater();
 $templater-> $templater = new Templater();
 $templater->user =thislater->user =this;

 // 取得電子郵件正文
 $body = $templater->render('email /'. $tpl);

 // 從第一行擷取主題
 list($subject, $body) = preg_split('/r|n/', $body, 2);

 // 現在設定並傳送電子郵件
 $mail = new Zend_Mail();

 // 在「食譜」中設定食譜位址與使用者全名
 $mail->addTo($this->個人資料->電子郵件,
trim( $this->個人資料->first_name 。 ' ' .
 $this->個人資料->; last_name));

 // 從設定中取得管理員「寄件者」詳細資料
 $mail->setFrom(Zend_Registry::get('config')->email->from- >email,
 Zend_Registry::get('config')->email->from->name);

 // 設定主題和正文並發送郵件
 $mail->setSubject( trim($subject));
 $mail->setBodyText(trim($body));
 $mail->send();
 }

 public function createAuthIdentity()

 public function createAuthIdentity()
 {
 $identity = new stdClass;
 $identity->user_id = $this->getId();
 $identity->username = $this->使用者名稱;
 $identity ->user_type = $this->user_type;
 $identity->first_name = $this->profile->first_name;
 $identity ->last_name = $this->profile->last_name;
 $>身分->電子郵件= $this->個人資料->電子郵件;

 return $identity;
 }

 public function loginSuccess()
 {
 $ this-> ts_last_login = time();
 unset($this->profile->new_password);
取消設定($這->個人資料->new_password_ts);
取消設定($這- >個人資料->new_password_key);
 $這->save();

 $ message = sprintf('%s 用戶%s 成功登入嘗試',
 $_SERVER['REMOTE_ADDR' ],
 $this->使用者名稱);

 $logger = Zend_Registry:: get('logger');
 $logger->notice($message);
 }
 static public function LoginFailure($username, $code = '')
 {
 switch ($code) {
 case Zend_Auth_Result::FAILURE_IDENTITY_NOT_FO:break;
 case Zend_Auth_Result::FAILURE_IDENTITY_AMBIGUOUS:
 $reason = '使用此使用者名稱找到多個使用者';
break;
 casePend_Auth_Result; reason = '密碼無效';
 break;
 預設值：
 $reason = '';
 }

 $message = sprintf('%s 使用者%s 登入嘗試失敗',
 $_SERVER['REMOTE_ADDR'],
 $用戶名);

 if (strlen($reason) > 0)
 $message .= sprintf(' (% s)' , $reason);

 $logger = Zend_Registry::get('logger');
 $logger->warn($message);
 }

公用函數fetchPassword()
 {
 if (!$this->isSaved())
 return false;

 // 產生新密碼屬性
 $this->_newPassword = Text_Password::create(8);
 $this->profile->new_password = md5($this->_newPassword);
 $this->profile->new_password_ts = time();
 $this ->profile->new_password_key = md5(uniqid() .
 $this->getId() .
 $this->_newPassword);

 / / 將新密碼儲存到個人資料並寄電子郵件
 $this->profile->save();
 $this->sendEmail('user-fetch-password.tpl');

 return true;
 }

 public function recognizeNewPassword($key)
 {
 // 檢查是否設定了有效的密碼重設資料
 if (!isset($這->個人資料->新密碼)
 || !isset($this->個人資料->new_password_ts)
 || !isset($this->profile->new_password_key)) {

 return false;
 }

 // 檢查密碼是否在一天內確認
 if (time() - $this->profile->new_password_ts > 86400)
 return false;

 //檢查金鑰是否正確
 if ($this->; profile->new_password_key != $key)
 return false;

 // 一切都有效，現在更新帳戶以使用新密碼

 // 繞過本地設定器new_password 已經是md5
 父級::__set('password', $this->profile->new_password);

 unset($this- >profile->new_password);
 unset($this->profile->new_password_ts);
 unset($this->profile->new_password_key);

 // 最後，儲存更新後的使用者記錄與更新的個人資料
 return $this->save();
 }

 public function usernameExists($username)
 {
 $query = sprintf(' select count(*)) as num from %s where username = ?',
 $this->_table);

 $result = $this->_db->fetchOne($query, $username );

回傳$結果> 0;
 }

 static public function IsValidUsername($username)
 {
 $validator = new Zend_Valusername)
 {
 $validator = new Zend_Validate_Alnum(); return $validator->isValid($username);
 }

 public function __set($name, $value)
 {
 switch ($name) {
 case 'password ':
 $value = md5($ value);
 break;

 case 'user_type':
 if (!array_key_exists($value, self::$userTypes))
 $value = 'member';
 Break;
 }

 return Parent::__set($name, $value);
 }
 }
?>