Quentin Zerva의 DBO-PHP 튜토리얼-php.cn

"Web 2.0 Development in Practice"의 저자인 Quentin Zervaas는 책에서 간단한 PHP 데이터 액세스 개체를 언급했습니다.

/**
* DatabaseObject
*
* 데이터베이스 테이블의 데이터를 쉽게 조작하는 데 사용되는 추상 클래스
* 간단한 로드/저장/삭제 방법을 통해
*/
추상 클래스 DatabaseObject
{
const TYPE_TIMESTAMP = 1;
const TYPE_BOOLEAN = 2;
protected static $types = array(self::TYPE_TIMESTAMP, self::TYPE_BOOLEAN);
private $_id = null;
private $_properties = array();
protected $_db = null;
protected $_table = '';
protected $_idField = '';
공용 함수 __construct(Zend_Db_Adapter_Abstract $db, $ 테이블, $idField)
{
$this->_db = $db;
$this->_table = $table;
$this->_idField = $idField;
}
공용 함수 로드($id, $field = null)
{
if (strlen($field) == 0)
$field = $this->_idField ;
if ($field == $this->_idField) {
$id = (int) $id;
if ($id <= 0)
return false ;
}
$query = sprintf('%s에서 %s 선택, 여기서 %s = ?',
Join(', ', $this->getSelectFields()),
$this->_table,
$field);
$query = $this->_db->quoteInto($query, $id);
return $this->_load($query);
}
보호 함수 getSelectFields($prefix = '')
{
$fields = array($prefix . $this->_idField);
foreach ($this->_properties as $k => $v)
$fields[] = $prefix . $k;
return $fields;
}
보호 함수 _load($query)
{
$result = $this->_db->query ($query);
$row = $result->fetch();
if (!$row)
return false;
$this->_init($row );
$this->postLoad();
return true;
}
공개 함수 _init($row)
{
foreach ($this->_properties as $k => $v) {
$val = $row[$k];
스위치($v['type']) {
case self::TYPE_TIMESTAMP:
if (!is_null($val))
$val = strtotime($val);
break;
case self::TYPE_BOOLEAN:
$val = (bool) $val;
break;
}
$this->_properties[$k]['value'] = $val;
}
$this ->_id = (int) $row[$this->_idField];
}
공개 함수 save($useTransactions = true)
{
$update = $this->isSaved();
if ($useTransactions)
$this->_db->beginTransaction();
if ($update)
$commit = $this->preUpdate();
else
$commit = $this->preInsert();
if (!$commit) {
if ( $useTransactions)
$this->_db->rollback();
return false;
}
$row = array();
foreach( $this->_properties as $k => $v) {
if ($update && !$v['updated'])
계속;
스위치 ($v['type']) {
케이스 자체:: TYPE_TIMESTAMP:
if (!is_null($v['value'])) {
if ($this->_db instanceof Zend_Db_Adapter_Pdo_Pgsql)
$v['value'] = date('Y-m-d H :i:sO', $v['value']);
else
$v['value'] = date('Y-m-d H:i:s', $v['value']);
}
break;
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;
}
공개 함수 delete($useTransactions = true)
{
if (!$this->isSaved() )
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;
}
공개 함수 isSaved()
{
return $this->getId() > 0;
}
공용 함수 getId()
{
return (int) $this->_id;
}
공용 함수 getDb()
{
return $this->_db;
}
공개 함수 __set($name, $value)
{
if (array_key_exists($name, $ this->_properties)) {
$this->_properties[$name]['value'] = $value;
$this->_properties[$name]['updated'] = true ;
true 반환;
}
false 반환;
}
공개 함수 __get($name)
{
return array_key_exists($name, $this->_properties) ? $this->_properties[$name]['value'] : null;
}
보호 함수 add($field, $default = null, $type = null)
{
$this->_properties[$field] = array('value' => $default,
'type' => in_array($type, self::$types) ? $type : null,
'updated' => false);
}
보호 함수 preInsert()
{
return true;
}
보호 함수 postInsert ()
{
true 반환;
}
보호 함수 preUpdate()
{
true 반환;
}
보호 함수 postUpdate ()
{
true 반환;
}
보호 함수 preDelete()
{
true 반환;
}
보호 함수 postDelete ()
{
true 반환;
}
보호 함수 postLoad()
{
true 반환;
}
공개 정적 함수 BuildMultiple($db, $class, $data)
{
$ret = array();
if (!class_exists($class))
throw new Exception('정의되지 않은 클래스 지정됨: ' . $class);
$testObj = new $class($db);
if (!$testObj instanceof DatabaseObject)
throw new Exception('클래스는 DatabaseObject에서 확장되지 않습니다.' );
foreach ($data as $row) {
$obj = new $class($db);
$obj->_init($row);
$ret[$obj->getId()] = $obj;
}
return $ret;
}
}