1. 程式人生 > >spring boot JPA Kotlin 使用QueryDsl 分頁查詢

spring boot JPA Kotlin 使用QueryDsl 分頁查詢

介紹

QueryDsl 是一個針對Java的面向物件查詢的工具,支援的模組有JPA,SQL,Mongodb,JDO,Lucense,集合。

sample

List<Person> persons = queryFactory.selectFrom(person) //person 是querydsl 的域物件
  .where(
    person.firstName.eq("John"),
    person.lastName.eq("Doe"))
  .fetch();

Gradle 配置 Kotlin使用QueryDsl

直接把配置檔案放出來,這個配置是ok的

buildscript {
  ext.kotlin_version = '1.1.2-5'

  repositories {
    mavenCentral()
  }

  dependencies {
    classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
  }
}

apply plugin: 'java'
apply plugin: 'kotlin'
apply plugin: 'kotlin-kapt'
apply plugin: 'idea'

dependencies {
  ...
.. compile 'com.querydsl:querydsl-jpa:4.2.1' kapt "com.querydsl:querydsl-apt:4.2.1:jpa" // 使用kapt 啟用querydsl apt工具 .... } repositories { jcenter() }

生成QxxModel檔案

使用gradle build 一下就自動會在build資料夾下自動生成QxxModel檔案。

QueryDsl Spring Boot JPA 分頁查詢

主要是在 service 和 dao 上做修改

ServiceImpl.kt

@Service
class CheckInfoServiceImpl : CheckInfoService {

    //實體管理
    @Autowired
    private lateinit var entityManager : Provider<EntityManager>

    //查詢工廠
    private  lateinit var queryFactory: JPAQueryFactory

    //初始化查詢工廠
    @PostConstruct
    fun init()
    {
        queryFactory = JPAQueryFactory(entityManager);
} override fun findPositive(searchCheckDto: SearchCheckDto, pageable: Pageable): PageImpl<Map<String, String>> { val qm = QCheckInfoModel.checkInfoModel //動態條件 val predicate = qm.pass.eq("0").and(qm.orgCode.like(OrgCodeUtils.getSQLCondition(searchCheckDto.orgCode))) if (searchCheckDto.name.isNotEmpty()) { predicate.and(qm.name.like("%${searchCheckDto.name}%")) } val list = mutableListOf<Map<String,String>>() val fetch = queryFactory.select( // 查詢指定列 qm.id, qm.name, qm.idCardNo, qm.nation, qm.sex, qm.score) .from(qm) .where(predicate) .orderBy(qm.createDate.desc()) .offset(pageable.getOffset().toLong()) .limit(pageable.getPageSize().toLong()) .fetch() fetch.forEach { val data = mutableMapOf<String,String>() data.put("id" , it.get(qm.id).toString()) data.put("name" , it[qm.name]?:"") data.put("idcard", it[qm.idCardNo]?:"") data.put("nation", it[qm.nation]?:"") data.put("sex", it[qm.sex].toString()?:"") data.put("score", it[qm.score]?:"") list.add(data) } val count = queryFactory.select(qm.id) .from(qm) .where(predicate) .fetchCount() return PageImpl(list,pageable ,count) } }

Dao.kt

@Repository
interface CheckInfoDao : JpaRepository<CheckInfoModel, Long>,QueryDslPredicateExecutor<CheckInfoModel> //增加 QueryDslPredicateExecutor