详解spring boot jpa整合QueryDSL来简化复杂操作

下面我来为你详细讲解“详解spring boot jpa整合QueryDSL来简化复杂操作”的完整攻略。

什么是QueryDSL

QueryDSL 是一个DSL query 框架，基于类型安全，可以使用 Java而非 SQL 来查询数据。它支持多种后端数据库，包括 MySQL，PostgreSQL 和 SQL Server。QueryDSL提供了一种比直接写SQL更简单和更加类型化的方式来构建查询语句，而且非常灵活，能够非常方便的处理复杂的查询逻辑。

整合Spring Boot JPA

要使用QueryDSL，需要整合Spring Boot JPA。下面是整合的过程。

首先，在 pom.xml 中引入 QueryDSL 依赖：

<dependency>
    <groupId>com.querydsl</groupId>
    <artifactId>querydsl-core</artifactId>
    <version>${querydsl.version}</version>
</dependency>

<dependency>
    <groupId>com.querydsl</groupId>
    <artifactId>querydsl-jpa</artifactId>
    <version>${querydsl.version}</version>
</dependency>

配置 QuerydslPredicateExecutor，它是 Spring Data JPA 提供的一个接口，能够接受 QueryDSL 的 Predicate，并且可以根据 Predicate 自动构建 SQL 语句，从而完成数据库查询操作。它的使用非常简单，只需要让相应接口继承 QuerydslPredicateExecutor 接口即可。例如：

public interface UserRepository extends JpaRepository<User, Long>, QuerydslPredicateExecutor<User> {
}

使用QueryDSL进行复杂操作

QueryDSL 能够非常方便的处理复杂的查询逻辑，下面是一些常见的操作示例：

1. 查询所有

查询所有的User记录：

QUser qUser = QUser.user;
JPAQuery<User> query = new JPAQuery<>(entityManager);
List<User> users = query.select(qUser).from(qUser).fetch();

2. 条件查询

查询指定条件的User记录：

QUser qUser = QUser.user;
JPAQuery<User> query = new JPAQuery<>(entityManager);
List<User> users = query.select(qUser).from(qUser)
    .where(qUser.name.eq("Tom").and(qUser.age.gt(18))).fetch();

3. 模糊查询

根据模糊条件查询指定User记录：

QUser qUser = QUser.user;
JPAQuery<User> query = new JPAQuery<>(entityManager);
List<User> users = query.select(qUser).from(qUser)
    .where(qUser.name.like("%Tom%")).fetch();

4. 分页查询

查询指定页码和每页大小的User记录：

QUser qUser = QUser.user;
JPAQuery<User> query = new JPAQuery<>(entityManager);
List<User> users = query.select(qUser).from(qUser)
    .offset(10).limit(20).fetch();

以上是使用 QueryDSL 进行复杂操作的一些常用示例。

示例

下面是一个完整的示例，使用 spring boot jpa 整合 QueryDSL 完成用户信息的增删改查操作。

1. 配置 pom.xml

在 pom.xml 中引入 QueryDSL 依赖：

<dependency>
    <groupId>com.querydsl</groupId>
    <artifactId>querydsl-core</artifactId>
    <version>${querydsl.version}</version>
</dependency>

<dependency>
    <groupId>com.querydsl</groupId>
    <artifactId>querydsl-jpa</artifactId>
    <version>${querydsl.version}</version>
</dependency>

2. 创建实体类

创建 User 实体类：

@Entity
@Table(name = "user")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "name")
    private String name;

    @Column(name = "age")
    private Integer age;

    // 省略 getter、setter 方法
}

3. 创建查询类

创建 QUser 查询类，代码如下：

public class QUser extends EntityPathBase<User> {

    private static final long serialVersionUID = 8104612224838824825L;

    public static final QUser user = new QUser("user");

    public final NumberPath<Long> id = createNumber("id", Long.class);
    public final StringPath name = createString("name");
    public final NumberPath<Integer> age = createNumber("age", Integer.class);

    public QUser(String variable) {
        super(User.class, variable);
    }

}

4. 创建DAO层

创建 UserRepository 接口，继承 JpaRepository 和 QuerydslPredicateExecutor 接口：

public interface UserRepository extends JpaRepository<User, Long>, QuerydslPredicateExecutor<User> {
}

创建用户DAO，代码如下：

@Repository
public class UserDao {

    @Autowired
    private UserRepository userRepository;

    @PersistenceContext
    private EntityManager entityManager;

    /**
     * 添加用户
     */
    public void addUser(User user) {
        userRepository.save(user);
    }

    /**
     * 删除用户
     */
    public void deleteUser(Long id) {
        userRepository.deleteById(id);
    }

    /**
     * 更新用户
     */
    public void updateUser(User user) {
        userRepository.save(user);
    }

    /**
     * 根据条件查询用户
     */
    public List<User> findUserByName(String name) {
        QUser qUser = QUser.user;
        JPAQuery<User> query = new JPAQuery<>(entityManager);
        return query.select(qUser).from(qUser).where(qUser.name.eq(name)).fetch();
    }

}

5. 测试

编写 UserController 测试类，代码如下：

@RunWith(SpringRunner.class)
@SpringBootTest
public class UserControllerTest {

    @Autowired
    private UserDao userDao;

    @Test
    public void testAddUser() {
        User user = new User();
        user.setName("Tom");
        user.setAge(21);
        userDao.addUser(user);
    }

    @Test
    public void testDeleteUser() {
        userDao.deleteUser(1L);
    }

    @Test
    public void testUpdateUser() {
        User user = new User();
        user.setId(1L);
        user.setName("Jerry");
        user.setAge(25);
        userDao.updateUser(user);
    }

    @Test
    public void testFindUserByName() {
        List<User> users = userDao.findUserByName("Tom");
        Assert.assertNotNull(users);
        Assert.assertEquals(users.size(), 1);
        Assert.assertEquals(users.get(0).getName(), "Tom");
    }

}

以上就是使用 spring boot jpa 整合 QueryDSL 完成用户信息的增删改查操作的完整攻略，示例中包含两个测试方法，分别测试了添加、删除、修改和查询用户信息的操作。