百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

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

wptr33 2024-12-15 17:13 34 浏览

前言

??随着去“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语法。

??问题排查:

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

??解决方案:

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

@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作为完全自主研发的国产化分布式数据库,对于想要往国产化迁移的项目以及想要实现完全国产化的公司,确实是一个能够进行参考的选项。

作者:IT学习日记v
链接:https://juejin.cn/post/7119692256184893471

相关推荐

MYSQL术语介绍:dynamic row format

InnoDB行格式。因为可变长度列值存储在保存行数据的页面之外,所以对于包含大对象的行非常有效。由于通常不会访问大字段来评估查询条件,因此不会经常将它们带入缓冲池,从而减少I/O操作并更好地利用缓...

阿里面试:MySQL Binlog有哪些格式?底层原理?优缺点?

binlog的格式也有三种:STATEMENT、ROW、MIXED,下面我详解binlog三种模式@mikechenStatement模式Statement模式:是基于SQL语句的复制(statem...

Mysql日期格式化显示“年月”(mysql日期格式化)

数据库中存储格式为DATE,如果只显示年月,就需要将日期数据格式化。下面通过两种方式对其格式化显示:...

看完这篇还不懂 MySQL 主从复制,可以回家躺平了

我们在平时工作中,使用最多的数据库就是MySQL...

MySQL binlog format (Statement、Row、Mixed) 二进制日志格式

MySQL的binlog日志作用是用来记录MySQL内部增删改查等对MySQL数据库有更新的内容的记录(对数据库的改动),对数据库的查询select或show等不会被binlog日志记录,主要用于数据...

性能优化-界面卡顿和丢帧(Choreographer 代码检测)

标签:ChoreographerUI卡顿UI丢帧本文将介绍3个知识点:获取系统UI刷新频率检测UI丢帧和卡顿输出UI丢帧和卡顿堆栈信息...

使用Java分析器优化代码性能,解决OOM问题

背景最近我一直在做性能优化,对一个单机应用做性能优化。主要是涉及到解析和导入导出相关的业务。大致说一下这个单机应用干嘛的:制作票样,类似于答题卡。发给某些人填写,然后通过单机python图像识别存到数...

面试必问的HashCode技术内幕(hashmap面试题原理)

3hashCode的内幕tips:面试常问/常用/常出错...

实战Netty!基于私有协议,怎样快速开发网络通信服务

私有协议编写目的本文档用于描述边缘计算单元(以下简称边缘盒)与上位机配置软件(以下简称上位机)之间进行的数据交互通信协议。通信方式...

C#工控上位机系列(2)- 串口通信/监控工具

工控机通常都带有很多串口(10个),而且可以通过Moxa卡扩展串口.但Moxa的串口和电脑自带的串口还是有点区别C#里面没区别,但之前VB6的MSComm控件有时就会有不一样的地方.支持串口通讯...

Java加密与解密之消息摘要算法1(消息摘要(hash函数编码法),又称数字指纹 ( ))

消息摘要算法有3大类,分别是:MD、SHA、MAC,通常用于数据完整性的验证。MD:MessageDigest消息摘要算法。包括:MD2,MD4,MD53种算法。SHA:SecureHashA...

zookeeper的Leader选举源码解析(zookeeper角色选举角色包括)

作者:京东物流梁吉超zookeeper是一个分布式服务框架,主要解决分布式应用中常见的多种数据问题,例如集群管理,状态同步等。为解决这些问题zookeeper需要Leader选举进行保障数据的强一致...

Java 中五种最常见加密算法:原理、应用与代码实现

引言在现代软件开发中,数据安全至关重要。无论是用户密码存储、敏感信息传输,还是系统间的通信,加密技术都扮演着核心角色。Java作为广泛使用的编程语言,通过javax.crypto和java.s...

干货|6招学会调用NFC的各个功能(调出nfc)

现在越来越多的手机支持NFC功能,这种轻松、安全、迅速的通信的无线连接技术,能够让我们的手机替代门禁卡、公交卡、银行卡甚至是车钥匙,那么怎么让APP中能够调用这个功能呢?今天小编就来教给大家!...

一文读懂流媒体协议之RTP 协议(rtp流媒体服务器)

一、简介1.1RTPRTP全名是Real-timeTransportProtocol(实时传输协议)。它是IETF提出的一个标准,对应的RFC文档为RFC3550(RFC1889为其过期版本)。...