快捷導(dǎo)航

簡(jiǎn)單了解java ORM框架JOOQ

更新時(shí)間：2019年12月05日 09:04:10 作者：wx5d9ed7c8443c3

這篇文章主要介紹了簡(jiǎn)單了解java ORM框架JOOQ,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

前言

今天給大家介紹一個(gè)新的ORM框架->JOOQ，可能很多朋友還沒(méi)有聽(tīng)說(shuō)過(guò)這個(gè)框架，碼農(nóng)哥之前也是一直在使用Mybatis框架作為Java工程中的持久層訪問(wèn)框架，但是最近的一些項(xiàng)目采用JOOQ框架開(kāi)發(fā)后，碼農(nóng)哥表示再也不想用Mybatis了！

為什么這么說(shuō)呢？因?yàn)镴OOQ在代碼層面要比Mybatis簡(jiǎn)潔得多，而且性能也非常優(yōu)異。相信大家都有過(guò)這樣的體會(huì)，我們?cè)陧?xiàng)目工程中使用Mybatis進(jìn)行數(shù)據(jù)庫(kù)相關(guān)代碼的編寫(xiě)時(shí)，為了提高工程效率，一般會(huì)在數(shù)據(jù)庫(kù)模型設(shè)計(jì)完成后，一次性使用Mybatis代碼插件（如:mybatis-generator），來(lái)生成Mybatis數(shù)據(jù)庫(kù)訪問(wèn)的實(shí)體類代碼以及XML、Mapper等映射代碼，從而盡量以面向?qū)ο蟮姆绞絹?lái)操作和訪問(wèn)數(shù)據(jù)庫(kù)。而通過(guò)這樣的方式，雖然在工程效率上提高了很多，但是從代碼的簡(jiǎn)潔和優(yōu)雅性上來(lái)說(shuō)就會(huì)讓人感覺(jué)特別的啰嗦，因?yàn)樽詣?dòng)生成的代碼并不完全都是你在項(xiàng)目中能夠用得到的。

所以，有些對(duì)代碼有追求的同學(xué)就會(huì)以比較簡(jiǎn)潔的方式來(lái)手寫(xiě)SQL代碼。如在@Mapper接口中編寫(xiě)這樣的代碼：

@Select("select max(t.balance_id) from balance t where t.country=#{country}\n")
String selectMaxId(Map<String, String> paramMap);

而雖然這種方式可以減少很多無(wú)用的代碼量，但是在業(yè)務(wù)邏輯比較復(fù)雜的場(chǎng)景下這種方式顯然又會(huì)大大降低開(kāi)發(fā)的效率，因?yàn)橥ㄟ^(guò)這樣的方式不僅SQL編寫(xiě)的通用層度需要我們花費(fèi)額外的時(shí)間去考慮，而且由于Java面向?qū)ο蟮木幊谭绞?，我們還需要花費(fèi)很多的時(shí)間來(lái)將數(shù)據(jù)庫(kù)查詢結(jié)果映射成為實(shí)體對(duì)象，所以使用Mybatis進(jìn)行持久層開(kāi)發(fā)時(shí)有時(shí)候真的是讓人又愛(ài)又恨！

那么有沒(méi)有一種新的ORM框架既能夠保持Mybatis的靈活性又不像Hibernate那樣重呢？畢竟大家也都是從Hibernate的魔爪中逃離出來(lái)后才選擇使用Mybatis直到今天的！在軟件工程領(lǐng)域就是這樣，有痛點(diǎn)的地方就一定會(huì)有人提供解決方案，JOOQ就是這樣一個(gè)產(chǎn)物！

JOOQ簡(jiǎn)介

JOOQ是基于Java訪問(wèn)關(guān)系型數(shù)據(jù)庫(kù)的工具包，它具有輕量、簡(jiǎn)單、并且足夠靈活的特點(diǎn)，通過(guò)JOOQ我們可以輕松的使用Java面向?qū)ο蟮恼Z(yǔ)法來(lái)實(shí)現(xiàn)各種復(fù)雜的SQL。相比于傳統(tǒng)ORM框架，如Hibernate、Mybatis來(lái)說(shuō)，JOOQ汲取了即汲取了它們操作數(shù)據(jù)的簡(jiǎn)單性和安全性、同時(shí)也保留了原生SQL的靈活性，從某種程度上說(shuō)JOOQ更像是介于ORM和JDBC的中間層。

JOOQ目前在國(guó)內(nèi)相對(duì)來(lái)說(shuō)還比較小眾，對(duì)于大部分從SSH或者SSM成長(zhǎng)起來(lái)的碼農(nóng)朋友們來(lái)說(shuō)，心里估計(jì)會(huì)質(zhì)疑“這玩意用的這么少，到底靠不靠譜？”。在這里碼農(nóng)哥可以很負(fù)責(zé)任的說(shuō)JOOQ是靠譜的！因?yàn)榇a農(nóng)哥已經(jīng)在好幾個(gè)生產(chǎn)項(xiàng)目上實(shí)踐過(guò)了，而且是在比較核心的支付系統(tǒng)上完全使用了JOOQ來(lái)替代Mybatis作為持久層框架，并且這個(gè)支付系統(tǒng)的并發(fā)量也是非常高的，所以JOOQ框架本身是能夠經(jīng)受住真實(shí)業(yè)務(wù)場(chǎng)景的考驗(yàn)的！

SpringBoot項(xiàng)目集成JOOQ

接下來(lái)我們就來(lái)一起看看，如何在SpringBoot的項(xiàng)目中集成和使用JOOQ吧！首先，我們?cè)陧?xiàng)目中引入JOOQ的stater依賴包，如下：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-jooq</artifactId>
</dependency>

因?yàn)镴OOQ對(duì)Spring Boot有很好的支持，所以我們只需要引入相應(yīng)的starter依賴即可，而具體的版本則是與Spring Boot的版本關(guān)聯(lián)的，這里并不需要我們?nèi)ブ付ā?/p>

其次，我們需要在項(xiàng)目中配置JOOQ的代碼生成插件，這樣JOOQ就可以自動(dòng)在項(xiàng)目編譯的時(shí)候?yàn)槲覀兩伤枰臄?shù)據(jù)庫(kù)以來(lái)對(duì)象了，在項(xiàng)目的pom.xml中配置Maven插件，如下：

<plugin>
<groupId>org.jooq</groupId>
<artifactId>jooq-codegen-maven</artifactId>
<executions>
  <execution>
    <id>default</id>
    <phase>generate-sources</phase>
    <goals>
      <goal>generate</goal>
    </goals>
    <configuration>
      <jdbc>
        <driver>com.mysql.jdbc.Driver</driver>
        <url>jdbc:mysql://127.0.0.1:3306</url>
        <user>root</user>
        <password><![CDATA[123456]]></password>
      </jdbc>
      <generator>
        <name>org.jooq.util.DefaultGenerator</name>
        <generate>
          <instanceFields>true</instanceFields>
          <pojos>true</pojos>
          <daos>true</daos>
        </generate>
        <database>
          <inputSchema>jets</inputSchema>
          <name>org.jooq.util.mysql.MySQLDatabase</name>
          <includes>.*</includes>
          <excludes>schema_version</excludes>
        </database>
        <target>
          <packageName>${app.package}</packageName>
          <directory>target/generated-sources/jooq</directory>
        </target>
      </generator>
    </configuration>
  </execution>
</executions>
</plugin>

配置完成這個(gè)Maven插件后，基本上JOOQ就算差不多與SpringBoot集成完成了，如果此時(shí)編譯項(xiàng)目JOOQ代碼插件就會(huì)在target/generated-sources/jooq目錄下根據(jù)數(shù)據(jù)庫(kù)中的表結(jié)構(gòu)生成相應(yīng)的數(shù)據(jù)庫(kù)操作對(duì)象，而這個(gè)過(guò)程則完成對(duì)開(kāi)發(fā)人員透明，我們并不需要做額外的事情。

而在具體的業(yè)務(wù)邏輯中，需要操作數(shù)據(jù)庫(kù)時(shí)我們就可以很方便的使用這些自動(dòng)生成的代碼來(lái)進(jìn)行操作，例如，我們需要在業(yè)務(wù)代碼中執(zhí)行insert操作，代碼如下：

@Slf4j
@Service
public class OpenServiceImpl implements OpenService {

  @Autowired
  protected DSLContext dslContext;

  @Override
  public BalanceChargeTradeResVo balanceChargeTrade(BalanceChargeTradeReqVo balanceChargeTradeReqVo)
      throws VerifyDataException, BalanceCreateOrderException {
    BalanceChargeTradeResVo balanceChargeTradeResVo;
    try {
      WalletUserBalanceOrderRecord walletUserBalanceOrderRecord = createBalanceChargeOrder(
          balanceChargeTradeReqVo);
      dslContext.executeInsert(walletUserBalanceOrderRecord);
      balanceChargeTradeResVo = BalanceChargeTradeResVo.builder().userId(balanceChargeTradeReqVo.getUserId())
          .amount(balanceChargeTradeReqVo.getAmount()).currency(balanceChargeTradeReqVo.getCurrency())
          .orderId(walletUserBalanceOrderRecord.getOrderId()).businessType(BusinessType.TOP_UP.getCode())
          .build();
      return balanceChargeTradeResVo;
    } catch (Exception e) {
      throw new BalanceCreateOrderException(ErrorCode.BALANCE_CHARGE_ORDER_ERROR.getCode(),
          ErrorCode.BALANCE_CHARGE_ORDER_ERROR.getDesc());
    }
  }

在以上代碼中，我們只需要在service業(yè)務(wù)類中注入DSLContext對(duì)象，并在組裝完自動(dòng)生成的數(shù)據(jù)庫(kù)類的對(duì)象后執(zhí)行executeInsert方法就可以完成insert操作了。而如果我們要完成查詢操作，也可以很簡(jiǎn)單的實(shí)現(xiàn)，代碼如下：

@Slf4j
@Service
public class OpenServiceImpl implements OpenService {

  @Autowired
  protected DSLContext dslContext;

  @Override
  public BalanceQueryResVo balanceQuery(long userId) throws AccountNoExistException {
    List<WalletUserBalanceRecord> walletUserBalanceRecordList = dslContext
        .selectFrom(WalletUserBalance.WALLET_USER_BALANCE)
        .where(WalletUserBalance.WALLET_USER_BALANCE.USER_ID
            .eq(String.valueOf(userId))).fetchInto(WalletUserBalanceRecord.class);
    if (walletUserBalanceRecordList == null || walletUserBalanceRecordList.size() <= 0) {
      throw new AccountNoExistException(ErrorCode.ACCOUNT_NO_EXIST_ERROR.getCode(),
          ErrorCode.ACCOUNT_NO_EXIST_ERROR.getDesc());
    }
    Optional<WalletUserBalanceRecord> walletUserBalanceRecord = walletUserBalanceRecordList.stream()
        .filter(o -> o.getAccType().equals(String.valueOf(AccType.CASH_ACCOUNT.getCode()))).findFirst();
    BalanceQueryResVo balanceQueryResVo = BalanceQueryResVo.builder().userId(userId)
        .balance(walletUserBalanceRecordList.stream().mapToInt(o -> o.getBalance().intValue()).sum())
        .currency(walletUserBalanceRecord.get().getCurrency()).build();
    return balanceQueryResVo;
  }

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: