数据库

    • 描述
    • 基本增删改查
    • 关联查询
    • 分页查询
    • 批量插入
    • 事务操作
    • 读写分离
    • 分库分表
    • 分布式事务

    Jboot 的数据库是依赖 JFinal 的 ORM 做基本的数据库操作，同时依赖 apahce-sphere 来做分库、分表和分布式事务。

    因此，在使用 Jboot 操作数据库的时候，建议对 JFinal 的 ORM 功能和 Apache Sharding-Sphere 有所了解。

    JFinal 操作数据库，提供了两种方式对数据库进行操作，他们分别是：

    • Model 映射方式

    Db 可以理解为一个工具类，而 Record 是一个类似 Map 的数据结构（其实内部就是通过 Map 来实现的），Db 查询的返回的数据是一个 或者是 List<Record> , Db 提供了如下操作数据库的系列方法：

    以下是 Db + Record 模式的一些示例：

    1. boolean succeed = Db.tx(() -> {
    2.     int count = Db.update("update account set cash = cash - ? where id = ?", 100, 123);
    3.     int count2 = Db.update("update account set cash = cash + ? where id = ?", 100, 456);
    4.     return count == 1 && count2 == 1;
    5. });

    以上两次数据库更新操作在一个事务中执行，如果执行过程中发生异常或者return false，则自动回滚事务。

    Model 映射方式

    Model是 MVC 模式中的 M 部分。以下是 Model 定义示例代码：

    BaseUser：

    1. public abstract class BaseUser<M extends BaseUser<M>> extends JbootModel<M> implements IBean {
    3.     public void setId(java.lang.Long id) {
    4.         set("id", id);
    5.     }
    7.     public java.lang.Long getId() {
    8.         return getLong("id");
    9.     }
    11.     // other getter setter ...

    需要注意的是：

    • 以上的 User 和 BaseUser 都是通过代码生成器自动生成的，无需手写。
    • 多次执行代码生成器，User 代码不会被覆盖，但是 BaseUser 会被重新覆盖，因此，请不要在 BaseUser 手写任何代码。

    一般情况下，在正式的项目里，代码分层还需要 Service 层来对业务逻辑进行处理。

    以上的 UserService , 只需要继承 JbootServiceBase<User> ,我们不需要编写任何实现代码，就可以拥有基本的增删改查的功能。

    以下是示例代码：

    1. //创建 UserService
    2. UserService userService = new UserService();
    4. // 创建name属性为James,age属性为25的User对象并添加到数据库
    5. User user = new User().set("name", "James").set("age", 25);
    6. userService.save(user); 
    8. // 删除id值为25的User
    11. // 查询id值为25的User将其name属性改为James并更新到数据库
    12. User user = userService.findById(25);
    13. user.set("name", "James");
    14. userService.update(user);
    16. // 分页查询user,当前页号为1,每页10个user

    在 Jboot 应用中，读写分离建议使用两个数据源，分别是读的数据源和写的数据源，写的数据源必须支持可读可写。

    在应用中，在某些场景下我们需要从只读数据源读取数据的时候，通过 DAO.use('只读数据源的名称').find(...) 就可以。

    Jboot 的分库分表功能使用了 Sharding-jdbc 实现的，若在 Jboot 应用在需要用到分库分表功能，需要添加 jboot.datasource.shardingConfigYaml = xxx.yaml 的配置，其中 xxx.yaml 配置需要放在 classpath 目录下，配置内容参考：