支持连表查询的mybatis-plus

package com.github.yulichang.test.join; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.test.join.dto.AddressDTO; import com.github.yulichang.test.join.dto.UserDTO; import com.github.yulichang.test.join.entity.AddressDO; import com.github.yulichang.test.join.entity.AreaDO; import com.github.yulichang.test.join.entity.UserDO; import com.github.yulichang.test.join.entity.UserDto; import com.github.yulichang.test.join.mapper.AddressMapper; import com.github.yulichang.test.join.mapper.UserDTOMapper; import com.github.yulichang.test.join.mapper.UserMapper; import com.github.yulichang.test.util.ThreadLocalUtils; import com.github.yulichang.toolkit.JoinWrappers; import com.github.yulichang.toolkit.MPJWrappers; import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.jdbc.BadSqlGrammarException; import java.sql.Timestamp; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Objects; /** * 连表测试类 * <p> * 支持mybatis-plus 查询枚举字段 * 支持mybatis-plus typeHandle功能 * <p> * 移除了mybatis-plus 逻辑删除支持，逻辑删除需要在连表查询时自己添加对应的条件 */ @SuppressWarnings("unused") @SpringBootTest class LambdaWrapperTest { @Autowired private UserMapper userMapper; @Autowired private UserDTOMapper userDTOMapper; @Autowired private AddressMapper addressMapper; @Test void testJoin() { ThreadLocalUtils.set("SELECT t.id,\n" + " t.pid,\n" + " t.`name`,\n" + " t.`json`,\n" + " t.sex,\n" + " t.head_img,\n" + " t.create_time,\n" + " t.address_id,\n" + " t.address_id2,\n" + " t.del,\n" + " t.create_by,\n" + " t.update_by,\n" + " t1.id AS joina_id,\n" + " t1.user_id,\n" + " t1.area_id,\n" + " t1.tel,\n" + " t1.address,\n" + " t1.del AS joina_del,\n" + " t2.id AS joinb_id,\n" + " t2.province,\n" + " t2.city,\n" + " t2.area,\n" + " t2.postcode,\n" + " t2.del AS joinb_del\n" + "FROM `user` t\n" + " LEFT JOIN address t1 ON (t1.user_id = t.id)\n" + " LEFT JOIN area t2 ON (t2.id = t1.area_id)\n" + "WHERE t.del = false\n" + " AND t1.del = false\n" + " AND t2.del = false\n" + " AND (t.id <= ?)\n" + "ORDER BY t.id DESC"); MPJLambdaWrapper<UserDO> wrapper = new MPJLambdaWrapper<UserDO>() .selectAll(UserDO.class) .selectCollection(AddressDO.class, UserDTO::getAddressList, addr -> addr .association(AreaDO.class, AddressDTO::getArea)) .leftJoin(AddressDO.class, AddressDO::getUserId, UserDO::getId) .leftJoin(AreaDO.class, AreaDO::getId, AddressDO::getAreaId) .le(UserDO::getId, 10000) .orderByDesc(UserDO::getId); List<UserDTO> list = userMapper.selectJoinList(UserDTO.class, wrapper); assert list.get(0).getAddressList() != null && list.get(0).getAddressList().get(0).getId() != null; list.forEach(System.out::println); } @Test void testJoinField() { ThreadLocalUtils.set("SELECT t.id,\n" + " t.pid,\n" + " t.`name`,\n" + " t.`json`,\n" + " t.sex,\n" + " t.head_img,\n" + " t.create_time,\n" + " t.address_id,\n" + " t.address_id2,\n" + " t.del,\n" + " t.create_by,\n" + " t.update_by,\n" + " t1.id AS joina_id\n" + "FROM `user` t\n" + " LEFT JOIN address t1 ON (t1.user_id = t.id)\n" + "WHERE t.del = false\n" + " AND t1.del = false\n" + " AND (t.id <= ?)\n" + "ORDER BY t.id DESC"); MPJLambdaWrapper<UserDO> wrapper = new MPJLambdaWrapper<UserDO>() .selectAll(UserDO.class) .selectCollection(AddressDO.class, UserDTO::getAddressIds, e -> e .id(AddressDO::getId)) .leftJoin(AddressDO.class, AddressDO::getUserId, UserDO::getId) .le(UserDO::getId, 10000) .orderByDesc(UserDO::getId); List<UserDTO> list = userMapper.selectJoinList(UserDTO.class, wrapper); assert list.get(0).getAddressIds() != null; list.forEach(System.out::println); } @Test void testJoin1() { ThreadLocalUtils.set("SELECT t.id,\n" + " t.pid,\n" + " t.`name`,\n" + " t.`json`,\n" + " t.sex,\n" + " t.head_img,\n" + " t.create_time,\n" + " t.address_id,\n" + " t.address_id2,\n" + " t.del,\n" + " t.create_by,\n" + " t.update_by,\n" + " t1.id AS joina_id,\n" + " t1.user_id,\n" + " t1.area_id,\n" + " t1.tel,\n" + " t1.address,\n" + " t1.del AS joina_del,\n" + " t2.id AS joinb_id,\n" + " t2.province,\n" + " t2.city,\n" + " t2.area,\n" + " t2.postcode,\n" + " t2.del AS joinb_del\n" + "FROM `user` t\n" + " LEFT JOIN address t1 ON (t1.user_id = t.id)\n" + " LEFT JOIN area t2 ON (t2.id = t1.area_id)\n" + "WHERE t.del = false\n" + " AND t1.del = false\n" + " AND t2.del = false\n" + "ORDER BY t.id DESC"); MPJLambdaWrapper<UserDO> wrapper = new MPJLambdaWrapper<UserDO>() .selectAll(UserDO.class) .selectCollection(AddressDO.class, UserDTO::getAddressList, addr -> addr .association(AreaDO.class, AddressDTO::getArea)) .leftJoin(AddressDO.class, AddressDO::getUserId, UserDO::getId) .leftJoin(AreaDO.class, AreaDO::getId, AddressDO::getAreaId) .orderByDesc(UserDO::getId); List<UserDTO> list = userMapper.selectJoinList(UserDTO.class, wrapper); assert list.get(0).getAddressList().get(0).getId() != null; list.forEach(System.out::println); } /** * 基本数据类型测试 */ @Test void testWrapper() { ThreadLocalUtils.set("SELECT t.id\n" + "FROM `user` t\n" + " LEFT JOIN address t1 ON (t1.user_id = t.id)\n" + " LEFT JOIN area t2 ON (t2.id = t1.area_id)\n" + "WHERE t.del = false\n" + " AND t1.del = false\n" + " AND t2.del = false"); //基本数据类型 和 String