Mybatis 和 Solon 勾搭在一起，也是个漂亮组合

时间：2024-09-15 00:03:14

故事相关的源码

https://gitee.com/noear/solon_demo/tree/master/demo08.solon_mybatis

故事开讲

Solon 是Java世界里一个新的极易上手的Web框架，像是个清秀的年轻小伙。。。

Mybatis 是个资深的前辈，好像阿里系挺喜欢这前辈，说是喜欢它的SQL透明性（Xml sql 确实有透明性）。

以住的历史上，Mybatis 基本上是在 Spring 家族合作搞工程的。

今天主要是让 Mybatis 和 Solon 搭伙过日子试试，看看是不是合得来。

本次搭伙主要有这些挑点：

  1. 简单的配置
  2. 多数据源支持（分区模式 和 注解模式）
  3. 事务支持（solon 是不支持注解事务的）
  4. 支持分页组件（这个，其实破坏了SQL的透明性......但业务很流行）

开始...

一、环境说明

环境 版本
IDEA 2020.2
Maven 4.0
Solon 1.0.10
mybatis-solon-plugin 1.0.10 （本例用到的关键框架）
mybatis-sqlhelper-solon-plugin 1.0.10
Mybatis 5.3.3
JDK 1.8

二、代码

新建个空白的Maven项目：solon_mybatis，下面开始操作：

  • （一）在 pom.xml 文件里添加依赖
<parent>

    <groupId>org.noear</groupId>

    <artifactId>solon-parent</artifactId>

    <version>1.0.10</version>

    <relativePath />

</parent>

<dependencies>

    <dependency>

        <groupId>org.noear</groupId>

        <artifactId>solon-web</artifactId>

        <type>pom</type>

    </dependency>

    <dependency>

        <groupId>org.noear</groupId>

        <artifactId>mybatis-solon-plugin</artifactId>

    </dependency>

    <dependency>

        <groupId>org.noear</groupId>

        <artifactId>mybatis-sqlhelper-solon-plugin</artifactId>

    </dependency>

    <!-- 其它依赖参考源码，不然占板面太多了  -->

</dependencies>
  • （二）修改属性文件 application.yml （添加多数据源和分布组件的配置）

Solon 没有特定的数据源配置，所以随便自己起个头就可以；配置项与使用的数据源匹配即可。本例用的是HikariCP：

#数据库1的配置

test.db1:

    schema: rock

    jdbcUrl: jdbc:mysql://localdb:3306/rock?useUnicode=true&characterEncoding=utf8&autoReconnect=true&rewriteBatchedStatements=true

    driverClassName: com.mysql.cj.jdbc.Driver

    username: demo

    password: UL0hHlg0Ybq60xyb

#数据库2的配置（其实我用的是同一个库）

test.db2:

    schema: rock

    jdbcUrl: jdbc:mysql://localdb:3306/rock?useUnicode=true&characterEncoding=utf8&autoReconnect=true&rewriteBatchedStatements=true

    driverClassName: com.mysql.cj.jdbc.Driver

    username: demo

    password: UL0hHlg0Ybq60xyb

#默认

mybatis:

    typeAliases:    #支持包名 或 类名（.class 结尾）

        - "webapp.model"

    mappers:        #支持包名 或 类名（.class 结尾）或 xml（.xml结尾）

        - "webapp.dso.mapper.AppxMapper.class"

#再定义个新配置（为了体现多数据源性 - 应该简单吧?）

mybatis.db2f:

    typeAliases:

        - "webapp.model"

    mappers:

        - "webapp.dso.mapper.Appx2Mapper.class"

#分页组件的配置

sqlhelper:

    mybatis:

        instrumentor:

            dialect: "mysql"

            cache-instrumented-sql: true

            subquery-paging-start-flag: "[PAGING_StART]"

            subquery-paging-end-flag: "[PAGING_END]"

        pagination:

            count: true

            default-page-size: 10

            use-last-page-if-page-no-out: true

            count-suffix: _COUNT
  • （三）添加配置器（完成会话工厂的构建 及 Mapper 的描述与关联；看上去，挺简洁的）

基于 Spring 的@MapperScan实现，需要多个配置器才可以完成；mybatis-solon-plugin把它调整为一个函数，故多个数据源可以整到一个配置器里：

@XConfiguration

public class Config {

    @XBean("db1f")

    public SqlSessionFactory db1f(@XInject("${test.db1}") HikariDataSource dataSource) {

        //

        //可以用默认的配置

        //

        return new MybatisAdapter(dataSource)

                .mapperScan()   //完成Spring 的 @MapperScan注解的功能（相对来说，改成函数可以把多个 mapperScan 安排在一个 Config里）

                .getFactory();

    }

    @XBean("db2f")

    public SqlSessionFactory db2f(

            @XInject("${test.db2}") HikariDataSource dataSource,

            @XInject("${mybatis.db2f}") Properties props) {

        //

        //可以指定配置 ${mybatis.db2f}

        //

        return new MybatisAdapter(dataSource, props)

                .mapperScan()

                .getFactory();

    }

}
  • （四）添加控制器

关于多数据源的分包模式示例：

/**

 * 分包模式，一开始就被会话工厂mapperScan()并关联好了

 * */

@XMapping("/demo/")

@XController

public class DemoController {

    @XInject

    AppxMapper appxMapper;      //已被db1f mapperScan 了，可直接注入

    @XInject

    Appx2Mapper appxMapper2;    //已被db2f mapperScan 了，可直接注入

    @XMapping("test")

    public AppxModel test(){

        return appxMapper.appx_get();

    }

    @XMapping("test2")

    public AppxModel test2(){

        return appxMapper2.appx_get2(48);

    }

}

关于多数据源的注解模式示例：

/**

 * 注解模式，通过@Db注入，并指定具体的会话工厂

 *

 * @Df 可注入 Mapper, SqlSession, SqlSessionFactory, MybatisProxy

 * */

@XMapping("/demo2/")

@XController

public class Demo2Controller {

    @Df("db1f")

    AppxMapper appxMapper;     //使用@Db 指定会话工厂并注入

    @Df("db2f")

    Appx2Mapper appxMapper2;

    @XMapping("test")

    public AppxModel test(){

        return appxMapper.appx_get();

    }

    @XMapping("test2")

    public AppxModel test2(){

        return appxMapper2.appx_get2(48);

    }

}

关于事务的示例：（分布式环境下，尽量用消息代理JDBC事务）

/**

 * 事务演示

 *

 * @Df 可注入 Mapper, SqlSession, SqlSessionFactory, MybatisProxy

 * */

@XMapping("/tran/")

@XController

public class TranController {

    @XInject

    AppxMapper appxMapper;

    /**

     * mybatis-solon-plugin 的事务，需要通过 MybatisProxy 发起

     *

     * solon 不目前支持注解事务，说是出于性能和细颗粒度的考虑；以及现在都流行引入消息处理事务了。

     * */

    @Df("db1f")

    MybatisProxy proxy;

    @XMapping("test")

    public Object test() throws Throwable{

        return proxy.tran((s)->{

            s.result = appxMapper.appx_get();

        });

    }

}

关于分页的示例：（本案用的是sqlhelper）

@XMapping("/page/")

@XController

public class PageController {

    @XInject

    AppxMapper appxMapper;

    @XMapping("test")

    public Object test() throws Throwable{

        SqlPaginations.preparePagination(2,2);

       return appxMapper.appx_get_page();

    }

}
  • （五）略过的代码文件（看开头的相关源码）
//这几个文件不是重点，可以直接看源码

//Appx2Mapper.java

//AppxMapper.java

//Appx2Mapper.xml

//AppxMapper.xml

这里只测试了查询的方法，当然如果需要别的，可以自行添加试试。

故事结尾

所有搭伙挑战完成，OY...

相关文章