mirror of
https://gitee.com/fastadminnet/framework.git
synced 2026-07-08 07:32:48 +08:00
改进一对一关联预载入查询 支持使用IN方式 一对一关联类增加setEagerlyType方法用于设置预载入查询方式 默认为JOIN方式,setEagerlyType(1) 使用IN方式
Loader类的parseName方法增加第三个参数 用于驼峰法转换是否首字母大写
This commit is contained in:
@@ -494,14 +494,16 @@ class Loader
|
|||||||
* type 0 将Java风格转换为C的风格 1 将C风格转换为Java的风格
|
* type 0 将Java风格转换为C的风格 1 将C风格转换为Java的风格
|
||||||
* @param string $name 字符串
|
* @param string $name 字符串
|
||||||
* @param integer $type 转换类型
|
* @param integer $type 转换类型
|
||||||
|
* @param bool $ucfirst 首字母是否大写(驼峰规则)
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
public static function parseName($name, $type = 0)
|
public static function parseName($name, $type = 0, $ucfirst = true)
|
||||||
{
|
{
|
||||||
if ($type) {
|
if ($type) {
|
||||||
return ucfirst(preg_replace_callback('/_([a-zA-Z])/', function ($match) {
|
$name = preg_replace_callback('/_([a-zA-Z])/', function ($match) {
|
||||||
return strtoupper($match[1]);
|
return strtoupper($match[1]);
|
||||||
}, $name));
|
}, $name);
|
||||||
|
return $ucfirst ? ucfirst($name) : lcfirst($name);
|
||||||
} else {
|
} else {
|
||||||
return strtolower(trim(preg_replace("/[A-Z]/", "_\\0", $name), "_"));
|
return strtolower(trim(preg_replace("/[A-Z]/", "_\\0", $name), "_"));
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -414,7 +414,7 @@ abstract class Model implements \JsonSerializable, \ArrayAccess
|
|||||||
// 类型转换
|
// 类型转换
|
||||||
$value = $this->readTransform($value, $this->type[$name]);
|
$value = $this->readTransform($value, $this->type[$name]);
|
||||||
} elseif ($notFound) {
|
} elseif ($notFound) {
|
||||||
$method = Loader::parseName($name, 1);
|
$method = Loader::parseName($name, 1, false);
|
||||||
if (method_exists($this, $method) && $this->$method() instanceof Relation) {
|
if (method_exists($this, $method) && $this->$method() instanceof Relation) {
|
||||||
// 不存在该字段 获取关联数据
|
// 不存在该字段 获取关联数据
|
||||||
$value = $this->$method()->getRelation();
|
$value = $this->$method()->getRelation();
|
||||||
@@ -1245,7 +1245,7 @@ abstract class Model implements \JsonSerializable, \ArrayAccess
|
|||||||
if (strpos($relation, '.')) {
|
if (strpos($relation, '.')) {
|
||||||
list($relation, $subRelation) = explode('.', $relation);
|
list($relation, $subRelation) = explode('.', $relation);
|
||||||
}
|
}
|
||||||
$relation = Loader::parseName($relation, 1);
|
$relation = Loader::parseName($relation, 1, false);
|
||||||
$this->$relation()->eagerlyResultSet($resultSet, $relation, $subRelation, $closure, $class);
|
$this->$relation()->eagerlyResultSet($resultSet, $relation, $subRelation, $closure, $class);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1272,7 +1272,7 @@ abstract class Model implements \JsonSerializable, \ArrayAccess
|
|||||||
if (strpos($relation, '.')) {
|
if (strpos($relation, '.')) {
|
||||||
list($relation, $subRelation) = explode('.', $relation);
|
list($relation, $subRelation) = explode('.', $relation);
|
||||||
}
|
}
|
||||||
$relation = Loader::parseName($relation, 1);
|
$relation = Loader::parseName($relation, 1, false);
|
||||||
$this->$relation()->eagerlyResult($result, $relation, $subRelation, $closure, $class);
|
$this->$relation()->eagerlyResult($result, $relation, $subRelation, $closure, $class);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,8 +27,7 @@ use think\exception\PDOException;
|
|||||||
use think\Loader;
|
use think\Loader;
|
||||||
use think\Model;
|
use think\Model;
|
||||||
use think\model\Relation;
|
use think\model\Relation;
|
||||||
use think\model\relation\BelongsTo;
|
use think\model\relation\OneToOne;
|
||||||
use think\model\relation\HasOne;
|
|
||||||
use think\Paginator;
|
use think\Paginator;
|
||||||
|
|
||||||
class Query
|
class Query
|
||||||
@@ -1653,9 +1652,9 @@ class Query
|
|||||||
}
|
}
|
||||||
|
|
||||||
/** @var Relation $model */
|
/** @var Relation $model */
|
||||||
$relation = Loader::parseName($relation, 1);
|
$relation = Loader::parseName($relation, 1, false);
|
||||||
$model = $class->$relation();
|
$model = $class->$relation();
|
||||||
if ($model instanceof HasOne || $model instanceof BelongsTo) {
|
if ($model instanceof OneToOne && 0 == $model->getEagerlyType()) {
|
||||||
$model->eagerly($this, $relation, $subRelation, $closure, $first);
|
$model->eagerly($this, $relation, $subRelation, $closure, $first);
|
||||||
$first = false;
|
$first = false;
|
||||||
} elseif ($closure) {
|
} elseif ($closure) {
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ class BelongsTo extends OneToOne
|
|||||||
* @param Model $parent 上级模型对象
|
* @param Model $parent 上级模型对象
|
||||||
* @param string $model 模型名
|
* @param string $model 模型名
|
||||||
* @param string $foreignKey 关联外键
|
* @param string $foreignKey 关联外键
|
||||||
* @param string $otherKey 关联主键
|
* @param string $localKey 关联主键
|
||||||
* @param array $alias 别名定义
|
* @param array $alias 别名定义
|
||||||
* @param string $joinType JOIN类型
|
* @param string $joinType JOIN类型
|
||||||
*/
|
*/
|
||||||
@@ -48,4 +48,68 @@ class BelongsTo extends OneToOne
|
|||||||
return $this->query->where($localKey, $this->parent->$foreignKey)->find();
|
return $this->query->where($localKey, $this->parent->$foreignKey)->find();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 预载入关联查询(数据集)
|
||||||
|
* @access public
|
||||||
|
* @param array $resultSet 数据集
|
||||||
|
* @param string $relation 当前关联名
|
||||||
|
* @param string $subRelation 子关联名
|
||||||
|
* @param \Closure $closure 闭包
|
||||||
|
* @param string $class 数据集对象名 为空表示数组
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
protected function eagerlySet(&$resultSet, $relation, $subRelation, $closure, $class)
|
||||||
|
{
|
||||||
|
$localKey = $this->localKey;
|
||||||
|
$foreignKey = $this->foreignKey;
|
||||||
|
|
||||||
|
$range = [];
|
||||||
|
foreach ($resultSet as $result) {
|
||||||
|
// 获取关联外键列表
|
||||||
|
if (isset($result->$foreignKey)) {
|
||||||
|
$range[] = $result->$foreignKey;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!empty($range)) {
|
||||||
|
$this->where[$localKey] = ['in', $range];
|
||||||
|
$data = $this->eagerlyWhere($this, [
|
||||||
|
$localKey => [
|
||||||
|
'in',
|
||||||
|
$range,
|
||||||
|
],
|
||||||
|
], $localKey, $relation, $subRelation, $closure);
|
||||||
|
|
||||||
|
// 关联数据封装
|
||||||
|
foreach ($resultSet as $result) {
|
||||||
|
if (!isset($data[$result->$foreignKey])) {
|
||||||
|
$data[$result->$foreignKey] = [];
|
||||||
|
}
|
||||||
|
$result->setAttr($relation, $this->resultSetBuild($data[$result->$foreignKey], $class));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 预载入关联查询(数据)
|
||||||
|
* @access public
|
||||||
|
* @param Model $result 数据对象
|
||||||
|
* @param string $relation 当前关联名
|
||||||
|
* @param string $subRelation 子关联名
|
||||||
|
* @param \Closure $closure 闭包
|
||||||
|
* @param string $class 数据集对象名 为空表示数组
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
protected function eagerlyOne(&$result, $relation, $subRelation, $closure, $class)
|
||||||
|
{
|
||||||
|
$localKey = $this->localKey;
|
||||||
|
$foreignKey = $this->foreignKey;
|
||||||
|
$data = $this->eagerlyWhere($this, [$localKey => $result->$foreignKey], $localKey, $relation, $subRelation, $closure);
|
||||||
|
// 关联数据封装
|
||||||
|
if (!isset($data[$result->$foreignKey])) {
|
||||||
|
$data[$result->$foreignKey] = [];
|
||||||
|
}
|
||||||
|
$result->setAttr($relation, $this->resultSetBuild($data[$result->$foreignKey], $class));
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -73,4 +73,69 @@ class HasOne extends OneToOne
|
|||||||
->join($table . ' b', 'a.' . $this->localKey . '=b.' . $this->foreignKey, $this->joinType)
|
->join($table . ' b', 'a.' . $this->localKey . '=b.' . $this->foreignKey, $this->joinType)
|
||||||
->where($where);
|
->where($where);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 预载入关联查询(数据集)
|
||||||
|
* @access public
|
||||||
|
* @param array $resultSet 数据集
|
||||||
|
* @param string $relation 当前关联名
|
||||||
|
* @param string $subRelation 子关联名
|
||||||
|
* @param \Closure $closure 闭包
|
||||||
|
* @param string $class 数据集对象名 为空表示数组
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
protected function eagerlySet(&$resultSet, $relation, $subRelation, $closure, $class)
|
||||||
|
{
|
||||||
|
$localKey = $this->localKey;
|
||||||
|
$foreignKey = $this->foreignKey;
|
||||||
|
|
||||||
|
$range = [];
|
||||||
|
foreach ($resultSet as $result) {
|
||||||
|
// 获取关联外键列表
|
||||||
|
if (isset($result->$localKey)) {
|
||||||
|
$range[] = $result->$localKey;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!empty($range)) {
|
||||||
|
$this->where[$foreignKey] = ['in', $range];
|
||||||
|
$data = $this->eagerlyWhere($this, [
|
||||||
|
$foreignKey => [
|
||||||
|
'in',
|
||||||
|
$range,
|
||||||
|
],
|
||||||
|
], $foreignKey, $relation, $subRelation, $closure);
|
||||||
|
|
||||||
|
// 关联数据封装
|
||||||
|
foreach ($resultSet as $result) {
|
||||||
|
if (!isset($data[$result->$localKey])) {
|
||||||
|
$data[$result->$localKey] = [];
|
||||||
|
}
|
||||||
|
$result->setAttr($relation, $this->resultSetBuild($data[$result->$localKey], $class));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 预载入关联查询(数据)
|
||||||
|
* @access public
|
||||||
|
* @param Model $result 数据对象
|
||||||
|
* @param string $relation 当前关联名
|
||||||
|
* @param string $subRelation 子关联名
|
||||||
|
* @param \Closure $closure 闭包
|
||||||
|
* @param string $class 数据集对象名 为空表示数组
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
protected function eagerlyOne(&$result, $relation, $subRelation, $closure, $class)
|
||||||
|
{
|
||||||
|
$localKey = $this->localKey;
|
||||||
|
$foreignKey = $this->foreignKey;
|
||||||
|
$data = $this->eagerlyWhere($this, [$foreignKey => $result->$localKey], $foreignKey, $relation, $subRelation, $closure);
|
||||||
|
// 关联数据封装
|
||||||
|
if (!isset($data[$result->$localKey])) {
|
||||||
|
$data[$result->$localKey] = [];
|
||||||
|
}
|
||||||
|
$result->setAttr($relation, $this->resultSetBuild($data[$result->$localKey], $class));
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -19,8 +19,11 @@ use think\model\relation\BelongsTo;
|
|||||||
|
|
||||||
abstract class OneToOne extends Relation
|
abstract class OneToOne extends Relation
|
||||||
{
|
{
|
||||||
|
// 预载入方式
|
||||||
|
protected $eagerlyType = 0;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 预载入关联查询
|
* 预载入关联查询(JOIN方式)
|
||||||
* @access public
|
* @access public
|
||||||
* @param Query $query 查询对象
|
* @param Query $query 查询对象
|
||||||
* @param string $relation 关联名
|
* @param string $relation 关联名
|
||||||
@@ -76,7 +79,7 @@ abstract class OneToOne extends Relation
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 预载入关联查询
|
* 预载入关联查询(数据集)
|
||||||
* @access public
|
* @access public
|
||||||
* @param array $resultSet 数据集
|
* @param array $resultSet 数据集
|
||||||
* @param string $relation 当前关联名
|
* @param string $relation 当前关联名
|
||||||
@@ -85,16 +88,21 @@ abstract class OneToOne extends Relation
|
|||||||
* @param string $class 数据集对象名 为空表示数组
|
* @param string $class 数据集对象名 为空表示数组
|
||||||
* @return void
|
* @return void
|
||||||
*/
|
*/
|
||||||
public function eagerlyResultSet(&$resultSet, $relation)
|
public function eagerlyResultSet(&$resultSet, $relation, $subRelation, $closure, $class)
|
||||||
{
|
{
|
||||||
foreach ($resultSet as $result) {
|
if (1 == $this->eagerlyType) {
|
||||||
|
// IN查询
|
||||||
|
$this->eagerlySet($resultSet, $relation, $subRelation, $closure, $class);
|
||||||
|
} else {
|
||||||
// 模型关联组装
|
// 模型关联组装
|
||||||
|
foreach ($resultSet as $result) {
|
||||||
$this->match($this->model, $relation, $result);
|
$this->match($this->model, $relation, $result);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 预载入关联查询 返回模型对象
|
* 预载入关联查询(数据)
|
||||||
* @access public
|
* @access public
|
||||||
* @param Model $result 数据对象
|
* @param Model $result 数据对象
|
||||||
* @param string $relation 当前关联名
|
* @param string $relation 当前关联名
|
||||||
@@ -103,11 +111,55 @@ abstract class OneToOne extends Relation
|
|||||||
* @param string $class 数据集对象名 为空表示数组
|
* @param string $class 数据集对象名 为空表示数组
|
||||||
* @return void
|
* @return void
|
||||||
*/
|
*/
|
||||||
public function eagerlyResult(&$result, $relation)
|
public function eagerlyResult(&$result, $relation, $subRelation, $closure, $class)
|
||||||
{
|
{
|
||||||
|
if (1 == $this->eagerlyType) {
|
||||||
|
// IN查询
|
||||||
|
$this->eagerlyOne($result, $relation, $subRelation, $closure, $class);
|
||||||
|
} else {
|
||||||
// 模型关联组装
|
// 模型关联组装
|
||||||
$this->match($this->model, $relation, $result);
|
$this->match($this->model, $relation, $result);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 保存(新增)当前关联数据对象
|
||||||
|
* @access public
|
||||||
|
* @param mixed $data 数据 可以使用数组 关联模型对象 和 关联对象的主键
|
||||||
|
* @return integer
|
||||||
|
*/
|
||||||
|
public function save($data)
|
||||||
|
{
|
||||||
|
if ($data instanceof Model) {
|
||||||
|
$data = $data->getData();
|
||||||
|
}
|
||||||
|
// 保存关联表数据
|
||||||
|
$data[$this->foreignKey] = $this->parent->{$this->localKey};
|
||||||
|
$model = new $this->model;
|
||||||
|
return $model->save($data);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 设置预载入方式
|
||||||
|
* @access public
|
||||||
|
* @param integer $type 预载入方式 0 JOIN查询 1 IN查询
|
||||||
|
* @return this
|
||||||
|
*/
|
||||||
|
public function setEagerlyType($type)
|
||||||
|
{
|
||||||
|
$this->eagerlyType = $type;
|
||||||
|
return $this;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取预载入方式
|
||||||
|
* @access public
|
||||||
|
* @return integer
|
||||||
|
*/
|
||||||
|
public function getEagerlyType()
|
||||||
|
{
|
||||||
|
return $this->eagerlyType;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 一对一 关联模型预查询拼装
|
* 一对一 关联模型预查询拼装
|
||||||
@@ -134,20 +186,30 @@ abstract class OneToOne extends Relation
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 保存(新增)当前关联数据对象
|
* 一对一 关联模型预查询(IN方式)
|
||||||
* @access public
|
* @access public
|
||||||
* @param mixed $data 数据 可以使用数组 关联模型对象 和 关联对象的主键
|
* @param object $model 关联模型对象
|
||||||
* @return integer
|
* @param array $where 关联预查询条件
|
||||||
|
* @param string $key 关联键名
|
||||||
|
* @param string $relation 关联名
|
||||||
|
* @param string $subRelation 子关联
|
||||||
|
* @param bool $closure
|
||||||
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function save($data)
|
protected function eagerlyWhere($model, $where, $key, $relation, $subRelation = '', $closure = false)
|
||||||
{
|
{
|
||||||
if ($data instanceof Model) {
|
// 预载入关联查询 支持嵌套预载入
|
||||||
$data = $data->getData();
|
if ($closure) {
|
||||||
|
call_user_func_array($closure, [ & $model]);
|
||||||
}
|
}
|
||||||
// 保存关联表数据
|
$list = $model->where($where)->with($subRelation)->select();
|
||||||
$data[$this->foreignKey] = $this->parent->{$this->localKey};
|
|
||||||
$model = new $this->model;
|
// 组装模型数据
|
||||||
return $model->save($data);
|
$data = [];
|
||||||
|
foreach ($list as $set) {
|
||||||
|
$data[$set->$key][] = $set;
|
||||||
|
}
|
||||||
|
return $data;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Reference in New Issue
Block a user