123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243 |
- <?php
- namespace think\model\relation;
- use think\db\Query;
- use think\Loader;
- use think\Model;
- class BelongsTo extends OneToOne
- {
-
- public function __construct(Model $parent, $model, $foreignKey, $localKey, $joinType = 'INNER', $relation = null)
- {
- $this->parent = $parent;
- $this->model = $model;
- $this->foreignKey = $foreignKey;
- $this->localKey = $localKey;
- $this->joinType = $joinType;
- $this->query = (new $model)->db();
- $this->relation = $relation;
- }
-
- public function getRelation($subRelation = '', $closure = null)
- {
- $foreignKey = $this->foreignKey;
- if ($closure) {
- call_user_func_array($closure, [ & $this->query]);
- }
- $relationModel = $this->query
- ->removeWhereField($this->localKey)
- ->where($this->localKey, $this->parent->$foreignKey)
- ->relation($subRelation)
- ->find();
- if ($relationModel) {
- $relationModel->setParent(clone $this->parent);
- }
- return $relationModel;
- }
-
- public function has($operator = '>=', $count = 1, $id = '*')
- {
- return $this->parent;
- }
-
- public function hasWhere($where = [], $fields = null)
- {
- $table = $this->query->getTable();
- $model = basename(str_replace('\\', '/', get_class($this->parent)));
- $relation = basename(str_replace('\\', '/', $this->model));
- if (is_array($where)) {
- foreach ($where as $key => $val) {
- if (false === strpos($key, '.')) {
- $where[$relation . '.' . $key] = $val;
- unset($where[$key]);
- }
- }
- }
- $fields = $this->getRelationQueryFields($fields, $model);
- return $this->parent->db()->alias($model)
- ->field($fields)
- ->join([$table => $relation], $model . '.' . $this->foreignKey . '=' . $relation . '.' . $this->localKey, $this->joinType)
- ->where($where);
- }
-
- protected function eagerlySet(&$resultSet, $relation, $subRelation, $closure)
- {
- $localKey = $this->localKey;
- $foreignKey = $this->foreignKey;
- $range = [];
- foreach ($resultSet as $result) {
-
- if (isset($result->$foreignKey)) {
- $range[] = $result->$foreignKey;
- }
- }
- if (!empty($range)) {
- $this->query->removeWhereField($localKey);
- $data = $this->eagerlyWhere($this->query, [
- $localKey => [
- 'in',
- $range,
- ],
- ], $localKey, $relation, $subRelation, $closure);
-
- $attr = Loader::parseName($relation);
-
- foreach ($resultSet as $result) {
-
- if (!isset($data[$result->$foreignKey])) {
- $relationModel = null;
- } else {
- $relationModel = $data[$result->$foreignKey];
- $relationModel->setParent(clone $result);
- $relationModel->isUpdate(true);
- }
- if (!empty($this->bindAttr)) {
-
- $this->bindAttr($relationModel, $result, $this->bindAttr);
- } else {
-
- $result->setRelation($attr, $relationModel);
- }
- }
- }
- }
-
- protected function eagerlyOne(&$result, $relation, $subRelation, $closure)
- {
- $localKey = $this->localKey;
- $foreignKey = $this->foreignKey;
- $this->query->removeWhereField($localKey);
- $data = $this->eagerlyWhere($this->query, [$localKey => $result->$foreignKey], $localKey, $relation, $subRelation, $closure);
-
- if (!isset($data[$result->$foreignKey])) {
- $relationModel = null;
- } else {
- $relationModel = $data[$result->$foreignKey];
- $relationModel->setParent(clone $result);
- $relationModel->isUpdate(true);
- }
- if (!empty($this->bindAttr)) {
-
- $this->bindAttr($relationModel, $result, $this->bindAttr);
- } else {
-
- $result->setRelation(Loader::parseName($relation), $relationModel);
- }
- }
-
- public function associate($model)
- {
- $foreignKey = $this->foreignKey;
- $pk = $model->getPk();
- $this->parent->setAttr($foreignKey, $model->$pk);
- $this->parent->save();
- return $this->parent->setRelation($this->relation, $model);
- }
-
- public function dissociate()
- {
- $foreignKey = $this->foreignKey;
- $this->parent->setAttr($foreignKey, null);
- $this->parent->save();
- return $this->parent->setRelation($this->relation, null);
- }
-
- protected function baseQuery()
- {
- if (empty($this->baseQuery)) {
- if (isset($this->parent->{$this->foreignKey})) {
-
- $this->query->where($this->localKey, '=', $this->parent->{$this->foreignKey});
- }
- $this->baseQuery = true;
- }
- }
- }
|