SpringBoot整合oceanbase,实现oracle无缝切换到oceanbase
wptr33 2024-12-15 17:13 41 浏览
前言
??随着去“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
相关推荐
- redis的八种使用场景
-
前言:redis是我们工作开发中,经常要打交道的,下面对redis的使用场景做总结介绍也是对redis举报的功能做梳理。缓存Redis最常见的用途是作为缓存,用于加速应用程序的响应速度。...
- 基于Redis的3种分布式ID生成策略
-
在分布式系统设计中,全局唯一ID是一个基础而关键的组件。随着业务规模扩大和系统架构向微服务演进,传统的单机自增ID已无法满足需求。高并发、高可用的分布式ID生成方案成为构建可靠分布式系统的必要条件。R...
- 基于OpenWrt系统路由器的模式切换与网页设计
-
摘要:目前商用WiFi路由器已应用到多个领域,商家通过给用户提供一个稳定免费WiFi热点达到吸引客户、提升服务的目标。传统路由器自带的Luci界面提供了工厂模式的Web界面,用户可通过该界面配置路...
- 这篇文章教你看明白 nginx-ingress 控制器
-
主机nginx一般nginx做主机反向代理(网关)有以下配置...
- 如何用redis实现注册中心
-
一句话总结使用Redis实现注册中心:服务注册...
- 爱可可老师24小时热门分享(2020.5.10)
-
No1.看自己以前写的代码是种什么体验?No2.DooM-chip!国外网友SylvainLefebvre自制的无CPU、无操作码、无指令计数器...No3.我认为CS学位可以更好,如...
- Apportable:拯救程序员,IOS一秒变安卓
-
摘要:还在为了跨平台使用cocos2d-x吗,拯救objc程序员的奇葩来了,ApportableSDK:FreeAndroidsupportforcocos2d-iPhone。App...
- JAVA实现超买超卖方案汇总,那个最适合你,一篇文章彻底讲透
-
以下是几种Java实现超买超卖问题的核心解决方案及代码示例,针对高并发场景下的库存扣减问题:方案一:Redis原子操作+Lua脚本(推荐)//使用Redis+Lua保证原子性publicbo...
- 3月26日更新 快速施法自动施法可独立设置
-
2016年3月26日DOTA2有一个79.6MB的更新主要是针对自动施法和快速施法的调整本来内容不多不少朋友都有自动施法和快速施法的困扰英文更新日志一些视觉BUG修复就不翻译了主要翻译自动施...
- Redis 是如何提供服务的
-
在刚刚接触Redis的时候,最想要知道的是一个’setnameJhon’命令到达Redis服务器的时候,它是如何返回’OK’的?里面命令处理的流程如何,具体细节怎么样?你一定有问过自己...
- lua _G、_VERSION使用
-
到这里我们已经把lua基础库中的函数介绍完了,除了函数外基础库中还有两个常量,一个是_G,另一个是_VERSION。_G是基础库本身,指向自己,这个变量很有意思,可以无限引用自己,最后得到的还是自己,...
- China's top diplomat to chair third China-Pacific Island countries foreign ministers' meeting
-
BEIJING,May21(Xinhua)--ChineseForeignMinisterWangYi,alsoamemberofthePoliticalBureau...
- 移动工作交流工具Lua推出Insights数据分析产品
-
Lua是一个适用于各种职业人士的移动交流平台,它在今天推出了一项叫做Insights的全新功能。Insights是一个数据平台,客户可以在上面实时看到员工之间的交流情况,并分析这些情况对公司发展的影响...
- Redis 7新武器:用Redis Stack实现向量搜索的极限压测
-
当传统关系型数据库还在为向量相似度搜索的性能挣扎时,Redis7的RedisStack...
- Nginx/OpenResty详解,Nginx Lua编程,重定向与内部子请求
-
重定向与内部子请求Nginx的rewrite指令不仅可以在Nginx内部的server、location之间进行跳转,还可以进行外部链接的重定向。通过ngx_lua模块的Lua函数除了能实现Nginx...
- 一周热门
-
-
C# 13 和 .NET 9 全知道 :13 使用 ASP.NET Core 构建网站 (1)
-
因果推断Matching方式实现代码 因果推断模型
-
git pull命令使用实例 git pull--rebase
-
git pull 和git fetch 命令分别有什么作用?二者有什么区别?
-
面试官:git pull是哪两个指令的组合?
-
git 执行pull错误如何撤销 git pull fail
-
git fetch 和git pull 的异同 git中fetch和pull的区别
-
git pull 之后本地代码被覆盖 解决方案
-
还可以这样玩?Git基本原理及各种骚操作,涨知识了
-
git命令之pull git.pull
-
- 最近发表
- 标签列表
-
- git pull (33)
- git fetch (35)
- mysql insert (35)
- mysql distinct (37)
- concat_ws (36)
- java continue (36)
- jenkins官网 (37)
- mysql 子查询 (37)
- python元组 (33)
- mybatis 分页 (35)
- vba split (37)
- redis watch (34)
- python list sort (37)
- nvarchar2 (34)
- mysql not null (36)
- hmset (35)
- python telnet (35)
- python readlines() 方法 (36)
- munmap (35)
- docker network create (35)
- redis 集合 (37)
- python sftp (37)
- setpriority (34)
- c语言 switch (34)
- git commit (34)