Spring Boot整合QueryDSL的实现示例
之前研究Jooq,今天来研究一下搭配JPA的QueryDSL吧。
简介
Querydsl是一个Java开源框架用于构建类型安全的SQL查询语句。它采用API代替拼凑字符串来构造查询语句。可跟Hibernate和JPA等框架结合使用。
新建SpringBoot项目
。。。还说啥?
1.pom.xml
org.springframework.boot spring-boot-starter-data-jpa org.springframework.boot spring-boot-starter-web mysql mysql-connector-java runtime com.querydsl querydsl-apt provided com.querydsl querydsl-jpa org.springframework.boot spring-boot-starter-test test org.junit.vintage junit-vintage-engine org.springframework.boot spring-boot-maven-plugin com.mysema.maven apt-maven-plugin 1.1.3 process target/generated-sources/java com.querydsl.apt.jpa.JPAAnnotationProcessor
2.application.yml
server: port:8888 spring: datasource: url:jdbc:mysql://IP地址:3306/querydsl?characterEncoding=UTF-8 username:用户名 password:密码 jpa: show-sql:true#控制台打印SQL hibernate: ddl-auto:update
3.JPAQueryFactoryBean
/**
*JPAQueryFactoryBean
*@authorzhouzhaodong
*/
@Configuration
publicclassPeopleQueryConfig{
@Bean
publicJPAQueryFactoryjpaQuery(EntityManagerentityManager){
returnnewJPAQueryFactory(entityManager);
}
}
4.新建实体类
/**
*实体类
*@authorzhouzhaodong
*/
@Entity
@Table(name="people")
publicclassPeople{
@Id
@Column(name="id")
@GeneratedValue
privateIntegerid;
@Column(name="name")
privateStringname;
@Column(name="age")
privateIntegerage;
@Column(name="address")
privateStringaddress;
publicIntegergetId(){
returnid;
}
publicvoidsetId(Integerid){
this.id=id;
}
publicStringgetName(){
returnname;
}
publicvoidsetName(Stringname){
this.name=name;
}
publicIntegergetAge(){
returnage;
}
publicvoidsetAge(Integerage){
this.age=age;
}
publicStringgetAddress(){
returnaddress;
}
publicvoidsetAddress(Stringaddress){
this.address=address;
}
}
5.新建service
/**
*service
*@authorzhouzhaodong
*/
publicinterfacePeopleService{
/**
*根据id查询
*@paramid
*@return
*/
PeopleselectOne(Integerid);
}
6.新建serviceImpl
/**
*serviceImpl
*@authorzhouzhaodong
*/
@Service
publicclassPeopleServiceImplimplementsPeopleService{
@Resource
JPAQueryFactoryqueryFactory;
@Override
publicPeopleselectOne(Integerid){
QPeoplepeople=QPeople.people;
returnqueryFactory.selectFrom(people).where(people.id.eq(id)).fetchOne();
}
}
7.新建controller
/**
*controller
*@authorzhouzhaodong
*/
@RestController
publicclassPeopleController{
@Resource
PeopleServicepeopleService;
@RequestMapping("/selectById")
publicPeopleselectById(){
returnpeopleService.selectOne(0);
}
}
8.新建repository,可以使用JPA原有的功能
/** *实现jpaRepository *@authorzhouzhaodong */ publicinterfacePeopleRepositoryextendsJpaRepository{ }
9.postman测试
数据库数据如下:
请求结果:
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。