JOOQ 入门（三）-- CRUD 语句

序言

上一篇关于JOOQ的随笔介绍了Springboot项目的创建以及JOOQ 代码生成器的使用。

那么在上次的项目基础上来看看实际的JOOQ怎么使用。

准备工作

先将项目的目录结构创建好

接下来CRUD的语法这篇文章会分别去写一个示例，看完之后基础的增删查改不在话下。

查询（select）

/**
     * 查询
     * @return
     */
    public Result<BkUserRecord> getAll(){
        Result<BkUserRecord> result = this.create
                .selectFrom(BkUser.BK_USER)
                .orderBy(1)
                .fetch();
        return result;
    }

更新（update）

/**
     * 更新
     */
    public void updateUser(){
        // 设置别名
        BkUser a = BkUser.BK_USER.as("a");
        BkUserRecord user = new BkUserRecord();
        this.create
                .update(a)
                .set(a.ADDRESS,user.getAddress())
                .set(a.NAME,user.getName())
                .where(a.ID.equal(user.getId()))
                .execute();
    }

删除（delete）

/**
     * 删除
     * @param userId
     */
    public void deleteUserById(Integer userId){
        this.create
                .deleteFrom(BkUser.BK_USER)
                .where(BkUser.BK_USER.ID.eq(userId))
                .execute();
    }

新增（insert）

/**
     * 新增
     */
    public void addUser(){
        byte enabled = 1;
        this.create
                .insertInto(BkUser.BK_USER)
                .columns(BkUser.BK_USER.ADDRESS,
                        BkUser.BK_USER.ENABLED,
                        BkUser.BK_USER.NAME,
                        BkUser.BK_USER.PHONE,
                        BkUser.BK_USER.PASSWORD)
                .values("后海",enabled,"小毛","10086","123456")
                .execute();
    }

完整代码

package com.bkn.breakingnews.modules.user.dao;

import com.bkn.breakingnews.model.tables.BkUser;
import com.bkn.breakingnews.model.tables.records.BkUserRecord;
import com.zaxxer.hikari.HikariDataSource;
import org.jooq.DSLContext;
import org.jooq.Result;
import org.jooq.SQLDialect;
import org.jooq.impl.DSL;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

/**
 * @author wuqi
 * @description user DAO
 * @date 2020/5/15 14:52
 */
@Repository
public class UserDao {
    // 注入Hikari的DataSource,
    @Autowired
    HikariDataSource dataSource;

    /**
     * 查询
     * @return
     */
    public Result<BkUserRecord> getAll(){
        // DSL上下文是所有数据库操作的入口，意思就是要用jooq干任何事都要先实例化这个DSLContext
        DSLContext create = DSL.using(this.dataSource,SQLDialect.MYSQL);
        Result<BkUserRecord> result = create
                .selectFrom(BkUser.BK_USER)
                .orderBy(1)
                .fetch();
        return result;
    }
    /**
     * 更新
     */
    public void updateUser(){
        // 设置别名
        BkUser a = BkUser.BK_USER.as("a");
        BkUserRecord user = new BkUserRecord();
        user.setId(5);
        user.setAddress("印度");
        user.setName("阿三哥");
        DSL.using(this.dataSource,SQLDialect.MYSQL)
                .update(a)
                .set(a.ADDRESS,user.getAddress())
                .set(a.NAME,user.getName())
                .where(a.ID.equal(user.getId()))
                .execute();
    }

    /**
     * 删除
     * @param userId
     */
    public void deleteUserById(Integer userId){
        DSL.using(this.dataSource,SQLDialect.MYSQL)
                .deleteFrom(BkUser.BK_USER)
                .where(BkUser.BK_USER.ID.eq(userId))
                .execute();
    }

    /**
     * 新增
     */
    public void addUser(){
        byte enabled = 1;
        DSL.using(this.dataSource,SQLDialect.MYSQL)
                .insertInto(BkUser.BK_USER)
                .columns(BkUser.BK_USER.ADDRESS,
                        BkUser.BK_USER.ENABLED,
                        BkUser.BK_USER.NAME,
                        BkUser.BK_USER.PHONE,
                        BkUser.BK_USER.PASSWORD)
                .values("后海",enabled,"小毛","10086","123456")
                .execute();
    }

}

测试类代码

package com.bkn.breakingnews;

import com.bkn.breakingnews.model.tables.BkUser;
import com.bkn.breakingnews.model.tables.records.BkUserRecord;
import com.bkn.breakingnews.modules.user.dao.UserDao;
import com.zaxxer.hikari.HikariDataSource;
import org.jooq.DSLContext;
import org.jooq.Result;
import org.jooq.SQLDialect;
import org.jooq.impl.DSL;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class BreakingnewsApplicationTests {

    @Autowired
    HikariDataSource dataSource;

    @Test
    void contextLoads() {
        DSLContext create = DSL.using(dataSource, SQLDialect.MYSQL);
        Result<BkUserRecord> records = create.selectFrom(BkUser.BK_USER).fetch();
        System.out.println(records);
    }

    //将userDao注入进单元测试类
    @Autowired
    UserDao userDao;

    @Test
    void testUser(){
        System.out.println("查询---");
        System.out.println(userDao.getAll());
        System.out.println("查询---");

        System.out.println("更新---");
        userDao.updateUser();
        System.out.println("更新后---");
        System.out.println(userDao.getAll());

        System.out.println("新增---");
        userDao.addUser();
        System.out.println("新增后---");
        System.out.println(userDao.getAll());

        System.out.println("删除---");
        userDao.deleteUserById(5);
        System.out.println("删除---");
        System.out.println(userDao.getAll());

    }

}

测试结果

查询---
更新---
更新后---
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+
|  id|name |phone      |telephone   |address|enabled|username|password                                          |remark|
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+
|   3|系统管理员|18568887789|029-82881234|深圳南山   |      1|admin   |$2a$10$ySG2lkvjFHY5O0./CPIE1OI8VJsuKYEzOYzqIa7A...|{null}|
|   5|阿三哥  |18568123489|029-82123434|印度     |      1|libai   |$2a$10$oE39aG10kB/rFu2vQeCJTu/V/v4n6DRR0f8WyXRi...|{null}|
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+

新增---
新增后---
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+
|  id|name |phone      |telephone   |address|enabled|username|password                                          |remark|
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+
|   3|系统管理员|18568887789|029-82881234|深圳南山   |      1|admin   |$2a$10$ySG2lkvjFHY5O0./CPIE1OI8VJsuKYEzOYzqIa7A...|{null}|
|   5|阿三哥  |18568123489|029-82123434|印度     |      1|libai   |$2a$10$oE39aG10kB/rFu2vQeCJTu/V/v4n6DRR0f8WyXRi...|{null}|
|   6|小毛   |10086      |{null}      |后海     |      1|{null}  |123456                                            |{null}|
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+

删除---
删除---
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+
|  id|name |phone      |telephone   |address|enabled|username|password                                          |remark|
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+
|   3|系统管理员|18568887789|029-82881234|深圳南山   |      1|admin   |$2a$10$ySG2lkvjFHY5O0./CPIE1OI8VJsuKYEzOYzqIa7A...|{null}|
|   6|小毛   |10086      |{null}      |后海     |      1|{null}  |123456                                            |{null}|
+----+-----+-----------+------------+-------+-------+--------+--------------------------------------------------+------+

总结

a.从代码中可以看出，java代码非常的简洁（别杠说这是因为sql逻辑简单），和Mybatis相比的话省去了配置Mapper.xml的步骤，

这一点还是比较吸引人的。

b.示例中用到的方法fetch()和execute()按照字面意思理解就可以

c.DSL上下文DSLContext就像一个入口，所有的sql相关操作都需要在上线文上执行，所以用之前都要进行实例化

d.where..and..or以及join的用法和增删改查一样都比较简单，一看就会，这里不做多介绍。写CRUD示例主要是能够让脑海中对JOOQ的语句有个印象。

e.下一篇文章会通过相对CRUD复杂一点的例子来讲讲比较常用的field()方法、with语句的用法。