正文 

当前位置： 首页 > 知识 > java教程

springboot整合oceanbase，实现oracle无缝切换到oceanbase(代码片段)

IT学习日记 IT学习日记     2023-02-17     284

关键词：


  • 💂 个人网站: IT知识小屋
  • 🤟 版权: 本文由【IT学习日记】原创、在CSDN首发、需要转载请联系博主
  • 💬 如果文章对你有帮助、欢迎关注、点赞、收藏(一键三连)和订阅专栏哦
  • 💅 开源项目:【轮子之王】

文章目录

前言

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

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

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

Springboot整合Oceanbase

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

一、引入依赖

  因为Oceanbase的数据库驱动包还没有上传到maven的中央仓库mvnrepository中，因此需要跟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语法。

  问题排查：

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

  解决方案：

  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);

四、数据库方言

  从上面的例子看到，在切换到oceanbase时，因为数据库方言的问题导致原有的项目无法无缝切换，那数据库方言到底是什么？为什么需要它呢？

  方言： 通俗的理解，方言就是具有有些地方特色的语言，它通常只能被某些地区的人能识别，不同地方可以存在不同的方言，就像广东有粤语，广西有壮语、勉语一样。

  数据库中的方言，则可以理解成遵循SQL统一规范前提下不同的拓展实现，如MySQL、Oracle等，在不同的实现中，可能存在相同或者不同的语法，如分页语法：mysql是使用Limit，oracle则使用rownum

五、设置方言的必要性

  对于ORM框架(mybatis、jpa)而言，在上层都是统一封装，无差别调用，比如分页功能，无论底层是使用哪一种类型的数据库，在ORM框架中都是调用某个特定的API接口，但是在实际的底层中，要根据使用了哪些数据库来调用不同的DBAPI，因此需要在ORM中指定使用哪种方言。

  比如上文提到的Mybatis-plus框架，则是通过数据库连接的url中的关键字进行设置数据库的方言。

  同时，数据库方言可以用来实现对查询的优化，实现分页语句以及count语句的自动生成，方言会生成适合于该特定数据库的效率较高的SQL语法。

六、数据库驱动与方言

  数据库驱动程序： 是实现用于连接数据库的协议（ODBC，JDBC）的程序。它是一个将通用接口连接到特定供应商实现的适配器，就像打印机驱动程序一样。

  方言： 数据库方言是平台无关软件（JPA，Hibernate等）的配置设置，允许此类软件将其通用SQL语句转换为供应商特定的DDL,DML。

  区别： 也就是说，“数据库驱动程序”是具有单一具体含义的公认行业术语，而“数据库方言”未被类似地识别，因此指代不同上下文中的不同概念。

写在最后

  随着世界格局动荡，为了避免关键时刻被“卡脖子”，发展自主可控的国产软件势在必行，数据库作为其中核心的一环，想要搭建健康的生态，需要更多有志之士参与。

  Oceanbase作为完全自主研发的国产化分布式数据库，对于想要往国产化迁移的项目以及想要实现完全国产化的公司，确实是一个能够进行参考的选项。

springboot整合oceanbase，实现oracle无缝切换到oceanbase(代码片段)

...订阅专栏哦💅开源项目:【轮子之王】文章目录前言Springboot整合Oceanbase一、引入依赖二、添加数据库连接配置三、处理异常Mybatis-plus框架异常四、数据库方言五、设置方言的必要性六、数据库驱动与方言写在最后前言  随... 查看详情

springboot整合oceanbase，实现oracle无缝切换到oceanbase(代码片段)

...订阅专栏哦💅开源项目:【轮子之王】文章目录前言Springboot整合Oceanbase一、引入依赖二、添加数据库连接配置三、处理异常Mybatis-plus框架异常四、数据库方言五、设置方言的必要性六、数据库驱动与方言写在最后前言  随... 查看详情

springboot整合springsecurity实现权限控制：菜单管理(代码片段)

系列文章目录《SpringBoot整合SpringSecurity实现权限控制（一）：实现原理》《SpringBoot整合SpringSecurity实现权限控制（二）：权限数据基本模型设计》《SpringBoot整合SpringSecurity实现权限控制（三）：... 查看详情

springboot整合vue实现上传下载文件(代码片段)

springboot整合vue实现上传下载文件文章目录springboot整合vue实现上传下载文件1上传下载文件api文件2.上传大文件配置3.vue前端主要部分环境springboot1.5.x完整代码下载：springboot整合vue实现上传下1上传下载文件api文件设置上传路径&... 查看详情

[springboot系列]springboot如何整合ssmp

文章目录基于SpringBoot实现SSMP整合基于SpringBoot实现SSMP整合SpringBoot之所以好用，就是它能方便快捷的整合其他技术，这里我们先介绍四种技术的整合：整合JUnit整合MyBatis整合MyBatis-Plus整合Druid整合JUnitSpringBoot技术的定位用于简化... 查看详情

springboot4.springboot整合devtools实现热部署

一、添加devtools依赖<!--Springboot热部署:此热部署会遇到java.lang.ClassCastException异常--><!--optional=true,依赖不会传递，该项目依赖devtools；之后依赖myboot项目的项目如果想要使用devtools，需要重新引入--><dependency><groupId>... 查看详情

精通springboot--整合redis实现缓存

今天我们来讲讲怎么在springboot中整合redis实现对数据库查询结果的缓存。首先第一步要做的就是在pom.xml文件添加spring-boot-starter-data-redis。要整合缓存，必不可少的就是我们要继承一个父类CachingConfigurerSupport。我们先看看这个类... 查看详情

springboot整合shiro实现权限控制(代码片段)

文章目录1、SpringBoot整合Shiro1.1、shiro简介1.2、代码的具体实现1.2.1、Maven的配置1.2.2、整合需要实现的类1.2.3、项目结构1.2.4、ShiroConfig的实现1.2.5、CustomerRealm的实现1.2.6、shiro缓存配置1.2.7、主页index.html的设置1.3、简单测试1.3.1、adm... 查看详情

springboot整合shiro实现权限控制(代码片段)

文章目录1、SpringBoot整合Shiro1.1、shiro简介1.2、代码的具体实现1.2.1、Maven的配置1.2.2、整合需要实现的类1.2.3、项目结构1.2.4、ShiroConfig的实现1.2.5、CustomerRealm的实现1.2.6、shiro缓存配置1.2.7、主页index.html的设置1.3、简单测试1.3.1、adm... 查看详情

shiro整合springboot缓存之redis实现(代码片段)

Shiro整合Springboot缓存之Redis实现Redis下载安装引入redis依赖配置redis连接启动redis服务自定义redis缓存的实现自定义shiro缓存管理器自定义salt实现实现序列化接口自定义Realm改造开启redis缓存Redis下载安装Windows系统中Redis下载安装其它... 查看详情

springboot2基于springboot实现ssmp整合(代码片段)

前言​    重头戏来了，SpringBoot之所以好用，就是它能方便快捷的整合其他技术，本文讲解一些技术的整合方式，通过这本文的学习，感受SpringBoot到底有多酷炫。本文学习如下技术的整合方式整合JUnit整... 查看详情

springboot整合redis实现缓存

...纲一、缓存的应用场景二、更新缓存的策略三、运行 springboot-mybatis-redis 工程案例四、springboot-mybatis-redis 工程代码配置详解 运行环境：MacOS10.12.xJDK8+Redis3.2.8SpringBoot1.5.1.RELEASE 一、缓存的应用场景什么是缓存？... 查看详情

springboot整合elasticsearch实现多版本的兼容

前言在上一篇学习SpringBoot中，整合了Mybatis、Druid和PageHelper并实现了多数据源的操作。本篇主要是介绍和使用目前最火的搜索引擎ElastiSearch，并和SpringBoot进行结合使用。ElasticSearch介绍ElasticSearch是一个基于Lucene的搜索服务器，其... 查看详情

springboot整合rocketmq实现入门案例

...习了Spring整合RocketMQ的第一个案例！现在我们来学习SpringBoot如何整合RocketMQ实现更加简单的使用！文章目录1创建maven项目2配置文件3生产者4消费者5测试1创建maven项目创建一个maven项目。引入sp 查看详情

springboot整合websocket

...t：在浏览器和服务器之间建立tcp连接，实现全双工通信??springboot使用websocket有两种方式，一种是实现简单的websocket，另外一种是实现STOMP协议。这一篇实现简单的webso 查看详情

springboot整合mybatis实现逆向工程

springboot整合mybatis创建逆向工程，快速的创建pojo实体,dao接口，mapperxml文件第一步添加依赖<projectxmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://mave 查看详情

shiro整合springboot之图片验证码实现(代码片段)

Shiro整合Springboot之图片验证码实现开发控制器放行验证码新增验证码工具类开发页面修改认证流程开发控制器/***验证码方法*/@RequestMapping("getImage")publicvoidgetImage(HttpSessionsession,HttpServletResponseresponse)throwsIOException//生成验... 查看详情

springboot整合rabbitmq实现死信队列(代码片段)

...bitMQ实现生产消费（7种通讯方式），本文基于SpringBoot实现RabbitMQ中的死信队列和延迟队列。概 查看详情