这个模式涉及到了领域模型、数据映射器和标识映射，这里就统一进行整理和回顾了。
$venue = new \woo\domain\Venue(null,"The Green Tree");
\woo\domain\ObjectWatcher::instance()->performOperations();
现在以上面的二行客户端代码为切入点大概的叙述一下这个模式是怎么工作的。
第一句在使用领域模型对象创建一个对象的时候，它就调用了标识映射ObjectWatcher类
将自己标记为一个需要新增的对象。第二句的performOperations方法将保存在标识映射器的属性$new中的对象
插入到了数据库中。注意它内部调用的$obj->finder()方法是领域模式中通过HelperFactory工厂类生成一个相对应的数据映射器类并return过来。
HelperFactory这个类下面没有具体实现(原文也没有实现),其实就是根据参数传入的类的类型使用条件分支创建对应的数据映射器。
下面直接看代码和注释进行理解。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
|
namespace woo\domain;//标识映射class ObjectWatcher{ private $all = array(); //存放对象的小仓库 private $dirty = array(); //存放需要在数据库中修改的对象 private $new = array(); //存放需要在数据库中新增的对象 private $delete = array(); //存放需要在数据库中删除的对象 private static $instance; //单例 private function __construct (){} static function instance(){ if(!self::$instance){ self::$instance = new ObjectWatcher(); } return self::$instance; } //获取一个唯一的标识,这里采用了领域类类名+ID的方式创建一个唯一标识，避免多个数据库表调用这个类时出现ID重复的问题 function globalKey(DomainObject $obj){ $key = get_class($obj) . "." . $obj->getId(); return $key; } //添加对象 static function add(DomainObject $obj){ $inst = self::instance(); $inst->all[$inst->globalKey($obj)] = $obj; } //获取对象 static function exists($classname,$id){ $inst = self::instance(); $key = "$classname.$id"; if(isset($inst->all[$key]){ return $inst->all[$key]; } return null; } //标记为需要删除的对象 static function addDelete(DomainObject $obj){ $self = self::instance(); $self->delete[$self->globalKey($obj)] = $obj; } //标记为需要修改的对象 static function addDirty(DomainObject $obj){ $inst = self::instance(); if(!in_array($obj,$inst->new,true)){ $inst->dirty[$inst->globalKey($obj)] = $obj; } } //标记为需要新增的对象 static function addNew(DomainObject $obj){ $inst = self::instance(); $inst->new[] = $obj; } //标记为干净的对象 static function addClean(DomainObject $obj){ $self = self::instance(); unset($self->delete[$self->globalKey($obj)]); unset($self->dirty[$self->globalKey($obj)]); $self->new = array_filter($self->new,function($a) use($obj) {return !($a === $obj);}); } //将上述需要增删改的对象与数据库交互进行处理 function performOperations(){ foreach($this->dirty as $key=>$obj){ $obj->finder()->update($obj); //$obj->finder()获取一个数据映射器 } foreach($this->new as $key=>$obj){ $obj->finder()->insert($obj); } $this->dirty = array(); $this->new = array(); }}//领域模型abstract class DomainObject{ //抽象基类 private $id = -1; function __construct ($id=null){ if(is_null($id)){ $this->markNew(); //初始化时即被标记为需要新增的对象了 } else { $this->id = $id; } } //调用了标识映射的标记对象的方法 function markNew(){ ObjectWatcher::addNew($this); } function markDeleted(){ ObjectWatcher::addDelete($this); } function markDirty(){ ObjectWatcher::addDirty($this); } function markClean(){ ObjectWatcher::addClean($this); } function setId($id){ $this->id = $id; } function getId(){ return $this->id; } function finder(){ return self::getFinder(get_class($this)); } //通过工厂类来实例化一个特定类型的数据映射器对象，例如VenueMapper //这个对象将被标识映射器中的performOperations方法调用用于与数据库交互进行增删改的操作 static function getFinder($type){ return HelperFactory::getFinder($type); } }class Venue extends DomainObject { private $name; private $spaces; function __construct ($id = null,$name=null){ $this->name= $name; $this->spaces = self::getCollection('\\woo\\domain\\space'); parent::__construct($id); } function setSpaces(SpaceCollection $spaces){ $this->spaces = $spaces; $this->markDirty(); //标记为需要修改的对象 } function addSpace(Space $space){ $this->spaces->add($space); $space->setVenue($this); $this->markDirty(); //标记为需要修改的对象 } function setName($name_s){ $this->name = $name_s; $this->markDirty(); //标记为需要修改的对象 } function getName(){ return $this->name; }}//领域模型class Space extends DomainObject{ //......... function setName($name_s){ $this->name = $name_s; $this->markDirty(); } function setVenue(Venue $venue){ $this->venue = $venue; $this->markDirty(); }}//数据映射器abstract class Mapper{ abstract static $PDO; //操作数据库的pdo对象 function __construct (){ if(!isset(self::$PDO){ $dsn = \woo\base\ApplicationRegistry::getDSN(); if(is_null($dsn)){ throw new \woo\base\AppException("no dns"); } self::$PDO = new \PDO($dsn); self::$PDO->setAttribute(\PDO::ATTR_ERRMODE,\PDO::ERRMODE_EXCEPTION); } } //获取标记的对象 private function getFroMap($id){ return \woo\domain\ObjectWatcher::exists($this->targetClass(),$id); } //新增标记的对象 private function addToMap(\woo\domain\DomainObject $obj){////// return \woo\domain\ObjectWatcher::add($obj); } //将数据库数据映射为对象 function createObject($array){ $old = $this->getFromMap($array['id']); if($old){return $old;} $obj = $this->doCreateObject($array); $this->addToMap($obj); $obj->markClean(); return $obj; } function find($id){ //通过ID从数据库中获取一条数据并创建为对象 $old = $this->getFromMap($id); if($old){return $old} $this->selectStmt()->execute(array($id)); $array= $this->selectStmt()->fetch(); $this->selectStmt()->closeCursor(); if(!is_array($array)){ return null; } if(!isset($array['id'])){ return null; } $object = $this->createObject($array); $this->addToMap($object); return $object; } function insert(\woo\domain\DomainObject $obj){ //将对象数据插入数据库 $this->doInsert($obj); $this->addToMap($obj); } //需要在子类中实现的各个抽象方法 abstract function targetClass(); //获取类的类型 abstract function update(\woo\domain\DomainObject $objet); //修改操作 protected abstract function doCreateObject(array $array); //创建对象 protected abstract function selectStmt(); //查询操作 protected abstract function doInsert(\woo\domain\DomainObject $object); //插入操作 }class VenueMapper extends Mapper { function __construct (){ parent::__construct(); //预处理对象 $this->selectStmt = self::$PDO->prepare("select * from venue where id=?"); $this->updateStmt = self::$PDO->prepare("update venue set name=?,id=? where id=?"); $this->insertStmt = self::$PDO->prepare("insert into venue (name) values(?)"); } protected function getCollection(array $raw){ //将Space数组转换成对象集合 return new SpaceCollection($raw,$this); } protected function doCreateObject (array $array){ //创建对象 $obj = new \woo\domain\Venue($array['id']); $obj->setname($array['name']); return $obj; } protected function doInsert(\woo\domain\DomainObject $object){ //将对象插入数据库 print 'inserting'; debug_print_backtrace(); $values = array($object->getName()); $this->insertStmt->execute($values); $id = self::$PDO->lastInsertId(); $object->setId($id); } function update(\woo\domain\DomainObject $object){ //修改数据库数据 print "updation\n"; $values = array($object->getName(),$object->getId(),$object->getId()); $this->updateStmt->execute($values); } function selectStmt(){ //返回一个预处理对象 return $this->selectStmt; } }//客户端$venue = new \woo\domain\Venue(null,"The Green Tree"); //在初始化时就被标记为新增对象了$venue->addSpace(new \woo\domain\Space(null,"The Space Upstairs")); //这二行addSpace方法因为venue已经被标记新增所以不会再标记为修改对象,但是space在初始化的时候会被标记为新增对象$venue->addSpace(new \woo\domain\Space(null,"The Bar Stage")); \woo\domain\ObjectWatcher::instance()->performOperations(); //与数据库交互新增一条Venue数据,以及二条space数据 |
以上这篇PHP面向对象之工作单元(实例讲解)就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持服务器之家。
