SpringBoot整合oceanbase，实现oracle无缝切换到oceanbase

2年前 (2022) 程序员胖胖胖虎阿

208 0 0

文章目录

随着去“IOE”化的潮流，近些年来，许多与国家相关的项目不约而同地往”国产化“方向靠拢，不可避免地，一些项目可能需要进行数据库迁移。

Oceanbase作为蚂蚁集团完全自主研发的国产原生分布式数据库，在TPC-C核TPC-H的测试上有过刷新世界纪录的辉煌成就，已连续 9 年稳定支撑双 11，在阿里集团中多个领域如淘宝、花呗、芝麻信用等投入使用，它具有云原生、强一致性、高度兼容mysql和oracle等特性，非常适合一些需要往国产化数据库迁移的项目。

本文以Springboot+Mybatis-plus为技术栈，通过实战讲解oracle迁移到oceanbase流程，希望能够帮助到有需要的朋友。

Springboot整合Oceanbase

前提：Oceanbase数据库高度兼容Oracle数据库，可以通过Oracle租户的方式近乎无成本地进行数据库迁移。

一、引入依赖

因为Oceanbase的数据库驱动包还没有上传到maven的中央仓库mvnrepository中，因此需要跟Oceanbase官方获取，获取方式如下：

方式一、到 Oceanbase官方网站，然后联系官方人员获取
方式二、直接下载博主上传到百度云的依赖包(推荐)： Oceanbase依赖包下载

在项目中引入依赖，可以通过本地引入的方式或者将获取到的jar包上传到公司私服上，然后使用坐标引用， 本文案例是通过本地引入的方式进行 ：

<dependency>  <groupId>com.alipay.oceanbase</groupId>  <artifactId>oceanbase-client</artifactId>  <version>2.2.7.2</version>  <scope>system</scope>  <systemPath>${ basedir}/src/main/resources/lib/oceanbase-client-2.2.7.2.jar</systemPath>  </dependency>

二、添加数据库连接配置

配置信息如下：

url: jdbc:oceanbase://ip:端口/scheme名
    username: 用户名@租户名#集群名 或者 集群名:租户名:用户名
    password: 密码
    driver-class-name: com.alipay.oceanbase.jdbc.Driver

参数详解，oceanbase的username组成相比于其他数据库连接较特别，支持两种写法即：用户名@租户名#集群名或者集群名:租户名:用户名。如果想用使用obclient命令行的方式连接oceanbase，可以参考：使用obclient连接oceabase数据库

三、处理异常Mybatis-plus框架异常

完成上面两个步骤后，正常情况下就可以跟使用其他数据库一样使用Mybatis等持久层框架对数据库进行增删改查等操作，但是，如果在项目中使用到了Mybatis-Plus框架，则还需要额外进行处理以下问题。

场景复现:项目在迁移之前，使用的是Mybatis-Plus框架中的API操作Oracle数据完成分页功能查询，切换到Oceanbase的oracle租户后，执行原来的功能会出现语法问题，提示信息因为使用了oceanbase的oracle租户不支持的limit语法。

SpringBoot整合oceanbase，实现oracle无缝切换到oceanbase

问题排查：

经过跟踪Mybatis-plus源码发现，其在获取数据库方言时是根据配置文件中连接数据库url中的协议进行匹配的，这样导致即使使用了oceanbase的oracle组合，在设置方言时也会匹配成oceanbase方言，而不是oracle的方言，从而出现的语法问题。

SpringBoot整合oceanbase，实现oracle无缝切换到oceanbase

解决方案：

Mybatis-plus的分页依赖于PaginationInnerInterceptor插件，可以继承该类重写数据库的查找方言方法，使得在数据库连接url为oceanbase协议时返回的的方言为oracle，这样就可以支持项目由oracle数据库无缝切换到oceanbase的oracle租户，重写代码如下：

@Slf4j
@Configuration(value = "PaginationInnerInterceptor")
public class  PaginationInnerInterceptorConfig  extends  PaginationInnerInterceptor  { 

    /**
     * 数据库类型
     */
    private DbType dbType;
    /**
     * 方言实现类
     */
    private IDialect dialect;

    /**
     * 重写获取分页方言类的逻辑，使得oceanbase的oracle租户时能够走oracle方言
     * @return 分页方言类
     */
    @Override
    protected IDialect findIDialect(Executor executor) { 
        String jdbcUrl = null;
        try { 
            Connection conn = executor.getTransaction().getConnection();
            jdbcUrl = conn.getMetaData().getURL();
            // 项目使用的是oceanbase的oracle租户,方言要使用oracle的，否则会有语法问题
            if (jdbcUrl.contains(":oceanbase:") || jdbcUrl.contains(":oracle:")) { 
                IDialect tempDialect = DialectFactory.getDialect(DbType.ORACLE);
                return tempDialect;
            }
            if (dialect != null) { 
                return dialect;
            }
            if (dbType != null) { 
                dialect = DialectFactory.getDialect(dbType);
                return dialect;
            }
            return DialectFactory.getDialect(JdbcUtils.getDbType(executor));
        } catch (Exception e) { 
            return DialectFactory.getDialect(DbType.OTHER);
        }

    }

}