- Created by 郭强, last modified by 王仁义 on Sep 24, 2023
LeftJoin/RightJoin/InnerJoin
LeftJoin
左关联查询;RightJoin
右关联查询;InnerJoin
内关联查询;
其实我们并不推荐使用Join
进行联表查询,特别是在数据量比较大、并发请求量比较高的场景中,容易产生性能问题,也容易提高维护的复杂度。建议您在确定有此必要的场景下使用。此外,您也可以参考 ORM链式操作-模型关联 章节,数据库只负责存储数据和简单的单表操作,通过ORM
提供的功能在代码层面实现数据聚合。
使用示例:
// 查询符合条件的单条记录(第一条) // SELECT u.*,ud.site FROM user u LEFT JOIN user_detail ud ON u.uid=ud.uid WHERE u.uid=1 LIMIT 1 g.Model("user u").LeftJoin("user_detail ud", "u.uid=ud.uid").Fields("u.*,ud.site").Where("u.uid", 1).One() // 查询指定字段值 // SELECT ud.site FROM user u RIGHT JOIN user_detail ud ON u.uid=ud.uid WHERE u.uid=1 LIMIT 1 g.Model("user u").RightJoin("user_detail ud", "u.uid=ud.uid").Fields("ud.site").Where("u.uid", 1).Value() // 分组及排序 // SELECT u.*,ud.city FROM user u INNER JOIN user_detail ud ON u.uid=ud.uid GROUP BY city ORDER BY register_time asc g.Model("user u").InnerJoin("user_detail ud", "u.uid=ud.uid").Fields("u.*,ud.city").Group("city").Order("register_time asc").All() // 不使用join的联表查询 // SELECT u.*,ud.city FROM user u,user_detail ud WHERE u.uid=ud.uid g.Model("user u,user_detail ud").Where("u.uid=ud.uid").Fields("u.*,ud.city").All()
自定义数据表别名
// SELECT * FROM `user` AS u LEFT JOIN `user_detail` as ud ON(ud.id=u.id) WHERE u.id=1 LIMIT 1 g.Model("user", "u").LeftJoin("user_detail", "ud", "ud.id=u.id").Where("u.id", 1).One() g.Model("user").As("u").LeftJoin("user_detail", "ud", "ud.id=u.id").Where("u.id", 1).One()
LeftJoinOnFields/RightJoinOnFields/InnerJoinOnFields
LeftJoinOnFields/RightJoinOnFields/InnerJoinOnFields 这三个方法可以指定字段和操作符进行 join 查询,使用示例:
// 查询符合条件的单条记录(第一条) // SELECT user.*,user_detail.address FROM user LEFT JOIN user_detail ON (user.id = user_detail.uid) WHERE user.id=1 LIMIT 1 g.Model("user").LeftJoinOnFields("user_detail", "id", "=", "uid").Fields("user.*,user_detail.address").Where("id", 1).One() // 查询多条记录 // SELECT user.*,user_detail.address FROM user RIGHT JOIN user_detail ON (user.id = user_detail.uid) g.Model("user").RightJoinOnFields("user_detail", "id", "=", "uid").Fields("user.*,user_detail.address").All()
结合dao
使用示例
// SELECT resource_task_schedule.id,...,time_window.time_window // FROM `resource_task_schedule` // LEFT JOIN `time_window` ON (`resource_task_schedule`.`resource_id`=`time_window`.`resource_id`) // WHERE (time_window.`status`="valid") AND (`time_window`.`start_time` <= 3600) var ( orm = dao.ResourceTaskSchedule.Ctx(ctx) tsTable = dao.ResourceTaskSchedule.Table() tsCls = dao.ResourceTaskSchedule.Columns() twTable = dao.TimeWindow.Table() twCls = dao.TimeWindow.Columns() scheduleItems []scheduleItem ) orm = orm.FieldsPrefix(tsTable, tsCls) orm = orm.FieldsPrefix(twTable, twCls.TimeWindow) orm = orm.LeftJoinOnField(twTable, twCls.ResourceId) orm = orm.WherePrefix(twTable, twCls.Status, "valid") orm = orm.WherePrefixLTE(twTable, twCls.StartTime, 3600) err = orm.Scan(&scheduleItems)
// SELECT DISTINCT resource_info.* FROM `resource_info` // LEFT JOIN `resource_network` ON (`resource_info`.`resource_id`=`resource_network`.`resource_id`) // WHERE (`resource_info`.`resource_id` like '%10.0.1.3%') // or (`resource_info`.`resource_name` like '%10.0.1.3%') // or (`resource_network`.`vip`like '%10.0.1.3%') // ORDER BY `id` Desc LIMIT 0,2 var ( orm = dao.ResourceInfo.Ctx(ctx).OmitEmpty() rTable = dao.ResourceInfo.Table() rCls = dao.ResourceInfo.Columns() nTable = dao.ResourceNetwork.Table() nCls = dao.ResourceNetwork.Columns() ) orm = orm.LeftJoinOnField(nTable, rCls.ResourceId) orm = orm.WherePrefix(rTable, do.ResourceInfo{ AppId: req.AppIds, ResourceId: req.ResourceIds, Region: req.Regions, Zone: req.Zones, ResourceName: req.ResourceNames, Status: req.Statuses, BusinessType: req.Products, Engine: req.Engines, Version: req.Versions, }) orm = orm.WherePrefix(nTable, do.ResourceNetwork{ Vip: req.Vips, VpcId: req.VpcIds, SubnetId: req.SubnetIds, }) // Fuzzy like querying. if req.Key != "" { var ( keyLike = "%" + req.Key + "%" ) whereFormat := fmt.Sprintf( "(`%s`.`%s` like ?) or (`%s`.`%s` like ?) or (`%s`.`%s`like ?) ", rTable, rCls.ResourceId, rTable, rCls.ResourceName, nTable, nCls.Vip, ) orm = orm.Where(whereFormat, keyLike, keyLike, keyLike) } // Resource items. err = orm.Distinct().FieldsPrefix(rTable, "*").Order(req.Order, req.OrderDirection).Limit(req.Offset, req.Limit).Scan(&res.Items)
Content Menu
- No labels
15 Comments
皛心
文档这里写db.Model,我找半天db是啥,折腾半天!!!最后发现这个db.Model就是g.Model。在GoFrame里面g是全局变量,任何应用里都可以直接用。db并没有定义为全局变量。
建议将文档下面的内容更改一下:
海亮
好,我们找个时间优化一下文档中的描述。
jim
Ray
dao写法 如果 on 条件的 字段名不一样怎么写呢
海亮 郭强
大米
dao写法 如果 on 条件的 字段名不一样怎么写呢
同问,LeftJoinOnField 方法为什么只考虑相同的字段,业务中user_id=id这种不是很经常吗
郭强
杨佳佳
scheduleItems这个结构体能出一个示例吗?我想返回2个关联表的所有数据,并重命名left join右面表的ID
xiu
我想将 LeftJoin 关联表的数据像with查询一样放入一个子级中(类似PHP Yii框架的操作),有这样的方法吗?
xiu
自己写了个方法实现了
apple15634145
撸一管
apple15634145
SELECT table1.*, SUM(CASE WHEN table2.type = 1 THEN table2.amount ELSE 0 END) AS total_amount
FROM table1
LEFT JOIN table2 ON table1.uid = table2.uid
GROUP BY table1.uid;
这个sql用orm的方式怎么写呢?
小陈
其实我们并不推荐使用
Join
进行联表查询,特别是在数据量比较大、并发请求量比较高的场景中,容易产生性能问题,也容易提高维护的复杂度。建议您在确定有此必要的场景下使用。此外,您也可以参考 ORM链式操作-模型关联 章节,----------
join性能差, 用模型关联性能会更好吗, 感觉没区别吧.
郭强
数据量大的时候
Join
查询会比多条带索引的sql
查询慢。小陈
大佬. 谢谢
ae86
这就是圣经,工作十年了,没有碰到什么业务必须join才能解决的,而且使用join维护成本确实高
yitiantiandeshuo
在使用clickhouse时需要使用array join,但是orm并未提供此方法 能将doJoin方法提供出来能让用户自定义呢