跳至主要內容

用户相关查询

xuejmnet2025/8/6大约 14 分钟

用户相关查询

用户查询以用户为主题的查询在当前模型下主要以OLAP为主，本章节会完美的暂时eq在OLAP下如何秒杀复杂查询

查询用户信息筛选要求今日发布过帖子的并且要求返回用户帖子数量,今日发帖数，评论数量和点赞数，并且要求返回刚刚发布的帖子标题和id
按点赞数对用户进行排序

建模

创建用户和帖子，用户和评论，用户和点赞的关系模型

因为我们之前已经创建了Post下的导航属性User,所以如果我们希望创建User下的Post反向导航属性只需要将光标放到已存在的导航属性上,通过快捷键alt+insert(windows)或者command+n(mac)呼出快捷菜单选择MappedBy

请求响应参数

创建用户请求参数和响应

编写接口


    @PostMapping("/page")
    public EasyPageResult<UserPageResponse> page(@RequestBody UserPageRequest request) {
        LocalDateTime today = LocalDateTime.now().toLocalDate().atStartOfDay();
        LocalDateTime nextDay = today.plusDays(1);
        return easyEntityQuery.queryable(User.class)
                .where(t_user -> {
                    //要求用户必须存在一个帖子是这个时间段发布的
                    t_user.posts().any(t_post -> {
                        t_post.publishAt().rangeClosed(request.getPostPublishTimeBegin(), request.getPostPublishTimeEnd());
                    });
                })
                .select(t_user -> {
                    return new UserPageResponseProxy()
                            .id().set(t_user.id())
                            .name().set(t_user.name())
                            .postCount().set(t_user.posts().count()) // 发帖数
                            .todayPostCount().set(t_user.posts().where(p -> p.publishAt().rangeClosedOpen(today, nextDay)).count()) // 今日发帖数
                            .commentCount().set(t_user.comments().count()) // 评论数
                            .likeCount().set(t_user.likes().count()) // 点赞数
                            .recentlyPostId().set(t_user.posts().orderBy(p->p.publishAt().desc()).first().id()) // 最近发布的帖子id
                            .recentlyPostTitle().set(t_user.posts().orderBy(p->p.publishAt().desc()).first().title()); // 最近发布的帖子标题

                })
                .orderBy(t_user -> t_user.likeCount().desc())
                .toPageResult(request.getPageIndex(), request.getPageSize());
    }

查看返回结果

查看生成的sql

该sql默认使用子查询模式返回，性能而言如果存在多个子查询那么性能将是非常低下的,如果您需要可以将子查询转成groupJoin

通过sql我们发现这个sql使用4个子查询加一个隐式partition

分析sql我们发现eq智能的将两个partition by的也就是最近发帖的id和最近发帖的title返回了出来

但是整体性能因为子查询过多导致性能不理想我们可以通过eq的subQueryToGroupJoin将子查询转成groupJoin来提高性能

groupJoin

那么我们该如何开启这个功能呢

.configure(s->s.getBehavior().add(EasyBehaviorEnum.ALL_SUB_QUERY_GROUP_JOIN))通过添加这一行代码让表达式子查询转成groupJoin


    @PostMapping("/page")
    public EasyPageResult<UserPageResponse> page(@RequestBody UserPageRequest request) {
        LocalDateTime today = LocalDateTime.now().toLocalDate().atStartOfDay();
        LocalDateTime nextDay = today.plusDays(1);
        return easyEntityQuery.queryable(User.class)
                //添加这一行使用subQueryToGroupJoin
                .configure(s->s.getBehavior().add(EasyBehaviorEnum.ALL_SUB_QUERY_GROUP_JOIN))
                .where(t_user -> {
                    //要求用户必须存在一个帖子是这个时间段发布的
                    t_user.posts().any(t_post -> {
                        t_post.publishAt().rangeClosed(request.getPostPublishTimeBegin(), request.getPostPublishTimeEnd());
                    });
                })
                .select(t_user -> {
                    return new UserPageResponseProxy()
                            .id().set(t_user.id())
                            .name().set(t_user.name())
                            .postCount().set(t_user.posts().count()) // 发帖数
                            .todayPostCount().set(t_user.posts().where(p -> p.publishAt().rangeClosedOpen(today, nextDay)).count()) // 今日发帖数
                            .commentCount().set(t_user.comments().count()) // 评论数
                            .likeCount().set(t_user.likes().count()) // 点赞数
                            .recentlyPostId().set(t_user.posts().orderBy(p->p.publishAt().desc()).first().id()) // 最近发布的帖子id
                            .recentlyPostTitle().set(t_user.posts().orderBy(p->p.publishAt().desc()).first().title()); // 最近发布的帖子标题

                })
                .orderBy(t_user -> t_user.likeCount().desc())
                .toPageResult(request.getPageIndex(), request.getPageSize());
    }

之后我们再来看我们的sql

分批查询返回

上一部分内容我们讲解了如果通过一条sql来实现包括主表在内的OLAP查询

查询用户要求返回用户包含用户id，用户姓名，并且要求返回今天发布的前三篇和java相关的帖子，每篇要求返回前三个评论并且返回是由谁评论的(前三个评论是住楼层评论)

构建评论和用户模型


@Data
@Table("t_comment")
@EntityProxy
@EasyAlias("t_comment")
@EasyAssertMessage("未找到对应的评论信息")
public class Comment implements ProxyEntityAvailable<Comment, CommentProxy> {
    @Column(primaryKey = true, comment = "评论id")
    private String id;
    @Column(comment = "父id")
    private String parentId;
    @Column(comment = "帖子内容")
    private String content;
    @Column(comment = "用户id", nullable = false)
    private String userId;
    @Column(comment = "帖子id", nullable = false)
    private String postId;
    @Column(comment = "回复时间")
    private LocalDateTime createAt;

    /**
     * 评论人
     **/
    @Navigate(value = RelationTypeEnum.ManyToOne, selfProperty = {CommentProxy.Fields.userId}, targetProperty = {UserProxy.Fields.id})
    private User user;
}

这边构建了评论和用户表建模

构建响应结果

通过插件勾选要返回的属性

查询接口


    @PostMapping("/list")
    public List<UserWithPostResponse> list() {
        return easyEntityQuery.queryable(User.class)
                .selectAutoInclude(UserWithPostResponse.class)
                .toList();
    }

当我们构建好一个返回结构和可以非常简单的通过selectAutoInclude将dto结果查询出来

我们非常简单的实现了这一功能

一共生成了多条sql

说明!!!

eq提供高效的快速组装没有n+1烦恼,可以非常灵活方便的拉取需要的数据并且可以对数据进行非常方便的筛选和额外字段填充

额外筛选

虽然我们对每个用户的帖子进行了前三个的返回,但是我们需要对帖子进行倒序排序并且是进入的帖子返回，评论也是如此需要是正序前三个并且是一级评论，因为之前的查询我们返回的评论是任意前3个所以我们对返回结果进行如下改造

  • ① 第一点我们对用户需要关联返回的posts属性增加限制,要求他是按publishAt倒序返回
  • ②t_post.publishAt().rangeClosedOpen(today,nextDay);我们对返回的帖子进行限制只能是今年的
  • ③ 我们对每个帖子返回的commentList进行了限制要求按评论时间正序返回
  • ④t_comment.parentId().eq("0");我们设置了第一级目录必须是"0"所以这边进行限制返回的评论只能是第一评论

接下来我们对这个结构进行查询


    @PostMapping("/list2")
    public List<UserWithPost2Response> list2() {
        return easyEntityQuery.queryable(User.class)
                .selectAutoInclude(UserWithPost2Response.class)
                .toList();
    }

    {
        "id": "2e509ef4-0282-448f-ace0-43501d46ccf4",
        "name": "用户C",
        "posts": [
            {
                "id": "669ce2a5-abaf-49e8-bb7e-e498f7377b15",
                "title": "健身计划分享",
                "publishAt": "2025-08-03T10:42:43.525",
                "commentList": [
                    {
                        "id": "1a1be377-a5f6-4d22-a1f8-8f025060a5c2",
                        "content": "完全同意你的观点",
                        "createAt": "2025-08-07T02:42:43.526",
                        "user": {
                            "name": "用户E"
                        }
                    },
                    //.....
                ]
            }
        ]
    },
    //.....

我们来查看sql

一共生成了4条sql

  • 第一条sql没什么好讲就是返回用户信息
  • 第二条sql是将帖子按用户分组分区并且按发布时间倒序并且只筛选今年的然后返回前三个
  • 第三条sql是将评论信息按帖子分组分区并且按评论时间正序返回前三个
  • 第四条sql是获取评论对应的用户信息

平铺用户

我们如果希望评论的user并不是一个对象而是一个平铺到评论表上的数据那应该怎么处理

展开用户id和用户姓名

  • ①我们这边对userId添加了NavigateFlat注解查询返回评论相关的用户的id，其实我们评论表里面本身就自带userId所以可以不用这么写这边只是做一下演示
  • ②获取评论关联的用户表的用户姓名
-- ......略过前面3条sql
-- 第4条sql数据
SELECT `id`, `name`
FROM `t_user`
WHERE `id` IN ('2e509ef4-0282-448f-ace0-43501d46ccf4', 'eda79345-6fbf-4ca6-b9bf-4743a3f991e4', 'f2bf383e-ee8d-44c5-968d-263191ab058e', '3b63ddd9-b038-4c24-969e-8b478fe862a5', '70ec5f9f-7e9b-4f57-b2a4-9a35a163bd3e')

我们可以通过sql清晰地看到虽然我们是针对两个属性进行分别的@NavigateFlat的定义但是eq会很智能的将这两部分进行合并

到此为止我感觉用户相关查询应该已经结束了接下来就是评论相关的递归树形查询案例

贡献者

xuejiaming
默认页脚
Copyright © 2025 xuejmnet