Springboot+QueryDsl實現(xiàn)融合數(shù)據(jù)查詢
Springboot+QueryDsl技術(shù)
1、添加依賴
<!--基于JPA-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<!--QueryDSL支持-->
<dependency>
<groupId>com.querydsl</groupId>
<artifactId>querydsl-apt</artifactId>
<scope>provided</scope>
</dependency>
<!--QueryDSL支持-->
<dependency>
<groupId>com.querydsl</groupId>
<artifactId>querydsl-jpa</artifactId>
</dependency>2、添加配置
@Configuration
public class PeopleQueryConfig {
@Bean
public JPAQueryFactory jpaQuery(EntityManager entityManager) {
return new JPAQueryFactory(entityManager);
}
}3、添加實體類
@Data
@Entity
@Table(name = "t_msg_log")
public class MsgLog extends PkUUID implements Serializable {
private static final long serialVersionUID = -1479947068453421077L;
@Column(name = "mobile", length = 16)
private String mobile;
@Column(name = "openid", length = 64)
private String openid;
@Column(name = "tsrname", length = 64)
private String tsrname;
@Column(name = "msg_direction", length = 2)
@Convert(converter = MsgDirectionConverter.class)
private MsgDirection msgDirection;
@Column(name = "msg_type", length = 16)
@Enumerated(EnumType.STRING)
private MsgType msgType;
@Column(name = "msg_channel", length = 2)
@Convert(converter = MsgChannelConverter.class)
private MsgChannel msgChannel;
@Lob
@Column(name = "msg_content")
private String msgContent;
@Column(name = "is_passive")
private Boolean isPassive;
@Column(name = "status", length = 2)
@Convert(converter = MsgStatusConverter.class)
private MsgStatus status;
@Column(name = "send_time")
private Date sendTime;
@Column(name = "schedule_flag", length = 2)
@Convert(converter = ScheduleFlagConverter.class)
private ScheduleFlag scheduleFlag;
@Column(name = "src_msg_id")
private String srcMsgId;
/**
* enum
*/
public enum MsgType {
text, image, video, voice, news, link, template, location
}
@RequiredArgsConstructor
public enum MsgDirection implements ValuedEnum<String> {
User2Agent("0"), Agent2User("1");
@Getter
private final String value;
}
@RequiredArgsConstructor
public enum MsgChannel implements ValuedEnum<String> {
SMS("0"), WECHAT("1");
@Getter
private final String value;
}
@RequiredArgsConstructor
public enum MsgStatus implements ValuedEnum<String> {
Success("1"), Failure("-1");
@Getter
private final String value;
}
@RequiredArgsConstructor
public enum ScheduleFlag implements ValuedEnum<String> {
ScheduledMsg("0"), InstantMsg("1");
@Getter
private final String value;
}
}4、JPA-DAO類
DAO 類繼承QueryDslPredicateExecutor
@Repository
public interface MsgLogRepository extends JpaRepository<MsgLog,String>,QueryDslPredicateExecutor<MsgLog>{
}5、Controller
@RestController
@RequestMapping("/msgLog/")
public class MsgLogController {
private static final Logger LOGGER = LoggerFactory.getLogger(MsgLogController.class);
@Autowired
private MsgLogRepository msgLogRepository;
/**
* 根據(jù)條件查詢回話內(nèi)容
* @param predicate
* @return
*/
@RequestMapping(value = "list")
public List<MsgLogResp> list(@QuerydslPredicate(root = MsgLog.class) Predicate predicate){
Iterable<MsgLog> msgLogs = msgLogRepository.findAll(predicate);
LOGGER.info("msgLogs = "+ JsonUtil.toJson(msgLogs));
List<MsgLog> msgLogList = new ArrayList<>();
msgLogs.forEach((MsgLog msgLog)-> msgLogList.add(msgLog));
return msgLogList.stream().map(new Function<MsgLog, MsgLogResp>() {
@Nullable
@Override
public MsgLogResp apply(@Nullable MsgLog msgLog) {
return new MsgLogResp(msgLog);
}
}).collect(Collectors.toList());
}
}到此這篇關(guān)于Springboot+QueryDsl實現(xiàn)融合數(shù)據(jù)查詢的文章就介紹到這了,更多相關(guān)Springboot QueryDsl數(shù)據(jù)查詢內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
IDEA插件EasyCode及MyBatis最優(yōu)配置步驟詳解
這篇文章主要介紹了IDEA插件EasyCode MyBatis最優(yōu)配置步驟詳解,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-12-12
SpringBoot集成Beetl后統(tǒng)一處理頁面異常的方法
這篇文章主要介紹了SpringBoot集成Beetl后統(tǒng)一處理頁面異常的方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-08-08
java中continue和break區(qū)別詳細(xì)解析
break和continue都是跳轉(zhuǎn)語句,它們將程序的控制權(quán)轉(zhuǎn)移到程序的另一部分,下面這篇文章主要給大家介紹了關(guān)于java中continue和break區(qū)別的相關(guān)資料,需要的朋友可以參考下2022-11-11
SpringSecurity構(gòu)建基于JWT的登錄認(rèn)證實現(xiàn)
這篇文章主要介紹了SpringSecurity構(gòu)建基于JWT的登錄認(rèn)證實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-02-02
利用Java實現(xiàn)和可被K整除的子數(shù)組完整實例
這篇文章主要給大家介紹了關(guān)于利用Java實現(xiàn)和可被K整除的子數(shù)組的相關(guān)資料,這道題來自力扣,通過學(xué)習(xí)這道題的解題思路以及代碼對大家的學(xué)習(xí)或者工作具有一定的參考借鑒價值,需要的朋友可以參考下2024-01-01

