关联查询
优质
小牛编辑
124浏览
2023-12-01
简介
Cabal-DB 的关联数据查询主要用了两个方法：->has('table') 和->belongs('table')， 因为其实数据库关联关系只有两种，一种是拥有（has）另一种是属于（belongs），如：
- 用户拥有更多个文章
- 文章拥有多个标签
- 文章属于一个用户
- 文章标签关联记录属于一个标签和一篇文章
语法
拥有关系查询语法：
$row->has($name, $foreignKeyOrCallback = null, $callback = null, $storeKey = null)
- name 目标表名
- foreignKeyOrCallback 外键名称或者回调函数，如果不传或传入的是一个函数则外键默认为：表名+_id
user_id - callback 回调函数，可以自己追加一些查询条件
- storeKey 存储键名 默认为表明，同一个关联表多次查询但是条件不同需要自定义存储键名
属于关系查询语法：
$row->belongs($name, $foreignKeyOrCallback = null, $callback = null, $storeKey = null)
- name 目标表名
- foreignKeyOrCallback 外键名称或者回调函数，如果不传或传入的是一个函数则外键默认为：表名+_id
user_id - callback 回调函数，可以自己追加一些查询条件
- storeKey 存储键名 默认为表明，同一个关联表多次查询但是条件不同需要自定义存储键名
返回值说明：
->has('table') 方法返回的是一个 Cabal\DB\Rows 对象里，也是一个所有元素都是 Cabal\DB\Row 的数组。
->belongs('table') 方法返回的是一个 Cabal\DB\Row 对象。
示例
单个用户的文章查询示例：
$result = $db->table('user')->select(['id', 'username'])->first();
$articleList = [];
foreach ($result->has('article') as $article) {
$tagList = [];
foreach ($article->has('article_tag') as $articleTag) {
$tag = $articleTag->belongs('tag');
$tagList[] = $tag->name;
}
$article->tagList = $tagList;
$articleList[] = $article->jsonSerialize();
}
$result->articleList = $articleList;
return $result;
返回：
{
"id": 1,
"username": "Cabal",
"articleList": [
{
"id": 1,
"user_id": 1,
"status": 1,
"title": "PHP 教程",
"content": "...",
"created_at": "2018-01-02 246:01:0",
"tagList": [
"PHP",
"教程"
]
},
{
"id": 2,
"user_id": 1,
"status": 1,
"title": "PHP 简介",
"content": "...",
"created_at": "2018-01-03 199:00:0",
"tagList": [
"PHP",
"简介"
]
},
{
"id": 3,
"user_id": 1,
"status": 1,
"title": "PHP 安装",
"content": "...",
"created_at": "2018-01-04 30:00:00",
"tagList": [
"PHP",
"安装"
]
},
{
"id": 4,
"user_id": 1,
"status": 0,
"title": "草稿",
"content": "...",
"created_at": "2018-01-01 05:00:00",
"tagList": [
]
}
]
}
上面的代码调用了以下的查询语句：
[
{
"sql": "SELECT id,username FROM `user` LIMIT 1",
"params": [
]
},
{
"sql": "SELECT `article`.* FROM `article` WHERE `user_id` = ?",
"params": [
1
]
},
{
"sql": "SELECT `article_tag`.* FROM `article_tag` WHERE article_id IN (?, ?, ?, ?)",
"params": [
1,
2,
3,
4
]
},
{
"sql": "SELECT `tag`.* FROM `tag` WHERE id IN (?, ?, ?, ?)",
"params": [
1,
4,
3,
2
]
}
]
多个用户的文章查询示例：
$userList = $db->table('user')->select(['id', 'username'])->rows();
foreach ($userList as $user) {
foreach ($user->has('article') as $article) {
$tagList = [];
foreach ($article->has('article_tag') as $articleTag) {
$tag = $articleTag->belongs('tag');
$tagList[] = $tag->name;
}
$article->tagList = $tagList;
$articleList[] = $article->jsonSerialize();
}
$user->articleList = $articleList;
}
// return $userList->getRows()->getTable()->getConnection()->getQueryLogs();
return $userList;
返回：
[
{
"id": 1,
"username": "Cabal",
"articleList": [
{
"id": 1,
"user_id": 1,
"status": 1,
"title": "PHP 教程",
"content": "...",
"created_at": "2018-01-02 246:01:0",
"tagList": [
"PHP",
"教程"
]
},
{
"id": 2,
"user_id": 1,
"status": 1,
"title": "PHP 简介",
"content": "...",
"created_at": "2018-01-03 199:00:0",
"tagList": [
"PHP",
"简介"
]
},
{
"id": 3,
"user_id": 1,
"status": 1,
"title": "PHP 安装",
"content": "...",
"created_at": "2018-01-04 30:00:00",
"tagList": [
"PHP",
"安装"
]
},
{
"id": 4,
"user_id": 1,
"status": 0,
"title": "草稿",
"content": "...",
"created_at": "2018-01-01 39:00:00",
"tagList": [
]
}
]
},
{
"id": 2,
"username": "User2",
"articleList": [
{
"id": 5,
"user_id": 2,
"status": 0,
"title": "User2 的文章",
"content": "...",
"created_at": "2018-01-05 05:00:00",
"tagList": [
]
}
]
}
]
上面的代码调用了以下的查询语句：
[
{
"sql": "SELECT id,username FROM `user`",
"params": [
],
},
{
"sql": "SELECT `article`.* FROM `article` WHERE user_id IN (?, ?)",
"params": [
1,
2
],
},
{
"sql": "SELECT `article_tag`.* FROM `article_tag` WHERE article_id IN (?, ?, ?, ?, ?)",
"params": [
1,
2,
3,
4,
5
],
},
{
"sql": "SELECT `tag`.* FROM `tag` WHERE id IN (?, ?, ?, ?)",
"params": [
1,
4,
3,
2
],
}
]
总结说明
- 没有使用
JOIN查询，因为JOIN查询性能可能没有简单查询效率高，尤其是数据表大了之后， - 合并了查询，查询多篇文章的标签时，自动将多条查询转化成
WHERE IN查询，减少查询次数，提高查询效率。 - 即使多次调用
->has('table')和->belongs('table')获取关联数据也不会产生多次的数据查询！