mirror-fastadminnet/framework
1
0
Fork 0
mirror of https://gitee.com/fastadminnet/framework.git synced 2026-07-01 20:52:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update model.php

Browse Source 
改进的join方法，由两个参数改成三个参数，同时兼容了原来两个参数的用法。
调用方式：
M('user')->alias('u')->join('goods as g', 'u.id=g.u_id')->select();
生成sql时自动给goods补上默认的表前缀； 当第一个参数以系统默认的表前缀开头或者含有括号时就不再加上默认的表前缀。

M('user')->alias('u')->join(array('goods'=>'g', 'think_'), 'u.id=g.u_id')->select();
生成sql时就会以think_做为goods表的前缀，g为别名。
This commit is contained in:
oldrind
2015-12-10 02:08:29 +08:00
parent e970a2974a
commit dd065dfdb8
1 changed files with 67 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
library/think/model.php
View File

@@ -983,7 +983,7 @@ class Model
* @param string $type JOIN类型
* @return Model
*/
public function join($join, $type = 'INNER')
public function _join($join, $type = 'INNER')
{
$prefix = $this->tablePrefix;
if (is_array($join)) {
@@ -999,6 +999,72 @@ class Model
}
return $this;
}
/**
* 查询SQL组装 join
* @access public
* @param mixed $join 关联的表名
* @param mixed $condition 条件
* @param string $type JOIN类型
* @return Model
*/
public function join($join, $condition = null, $type = 'INNER')
{
if (empty($join)) return $this;
if (empty($condition)) {
if (is_array($join) && is_array($join[0])) {
// 如果为组数，则循环调用join
foreach ($join as $key => $value) {
if (is_array($value) && 2 <= count($value)) {
$this->join($value[0], $value[1], isset($value[2]) ? $value[2] : $type);
}
}
} else {
$this->_join($join, $condition); // 兼容原来的join写法
}
} elseif (in_array(strtoupper($condition), array('INNER', 'LEFT', 'RIGHT', 'ALL'))) {
$this->_join($join, $condition); // 兼容原来的join写法
} else {
$prefix = $this->tablePrefix;
// 传入的表名为数组
if (is_array($join)) {
if (0 !== key($join)) {
// 键名为表名，键值作为表的别名
$table = key($join) . ' ' . current($join);
} else {
$table = current($join);
}
if (isset($join[1])) {
// 第二个元素为字符串则把第二元素作为表前缀
if (is_string($join[1])) {
$table = $join[1] . $table;
}
} else {
// 加上默认的表前缀
$table = $prefix . $table;
}
} else {
$join = trim($join);
if (0 === strpos($join, '__')) {
//将__TABLE_NAME__字符串替换成带前缀的表名
$table = preg_replace_callback("/__([A-Z0-9_-]+)__/sU", function ($match) use ($prefix) {
return $prefix . strtolower($match[1]);
}, $join);
} elseif (false === strpos($join, '(') && 0 !== strpos($join, $prefix)) {
// 传入的表名中不带有'('并且不以默认的表前缀开头时加上默认的表前缀
$table = $prefix . $join;
} else {
$table = $join;
}
}
if (is_array($condition)) {
$condition = implode(' AND ', $condition);
}
$this->options['join'][] = strtoupper($type) . ' JOIN ' . $table . ' ON ' . $condition;
}
return $this;
}
/**
* 查询SQL组装 union