OceanBase 数据库 Oracle 模式深度实践：从部署到迁移

OceanBase 数据库 Oracle 模式深度实践：从部署到迁移

一、为什么需要 OceanBase 的 Oracle 模式？

在数字化转型浪潮中，关系型数据库承载着企业最核心的业务数据。传统 Oracle 数据库凭借其稳定性、成熟生态和强大的 PL/SQL 能力，长期占据企业级市场。然而，随着数据量激增和云原生趋势，Oracle 的集中式架构在扩展性、成本（License 费用、硬件依赖）和运维复杂度上逐渐力不从心。

OceanBase 作为一款原生分布式数据库，由蚂蚁集团自主研发，打破了传统单机瓶颈。其独特的 Oracle 模式（即兼容 Oracle 语法与语义的租户模式）为 Oracle 用户提供了一条平滑迁移至分布式架构的路径：

• 高度兼容：支持 SQL 语法、PL/SQL、数据类型、系统包、OCI 接口等，应用几乎无需修改。
• 弹性扩展：基于 Paxos 共识协议，支持在线水平扩缩容，存储与计算分离。
• 金融级高可用：多副本数据同步，RPO=0，RTO＜30 秒。
• 混合负载：同时高效处理 OLTP 和 OLAP，引入行列混合存储引擎。

本文将带你从零开始，部署一套 OceanBase Oracle 模式集群，详细讲解管理操作、SQL 兼容性、数据迁移和性能调优，帮助你在实际项目中快速落地。

二、OceanBase 核心架构简介

在动手之前，先了解 OceanBase 的几大核心概念：

• OBServer：数据节点，每个节点运行一个 observer 进程，存储数据切片（Partition）并处理 SQL。
• RootService：集群总控服务，负责调度、负载均衡、故障恢复，通常驻留在某个 OBServer 上。
• Tenant（租户）：逻辑隔离单元，类似传统数据库实例。每个租户可选择 MySQL 或 Oracle 兼容模式。
• Zone（可用区）：由一组 OBServer 组成，通常对应一个机房，每个 Zone 存储完整数据的一份副本。
• LS（Log Stream）：每个租户在每个 Zone 内有一组日志流，负责数据同步。
• Partition：数据分片，支持 Hash、Range、List 分区，也可二级分区。

Oracle 模式租户内部呈现为“数据库（Database）→ 模式（Schema）→ 表/对象”的三层结构，与 Oracle 的“用户=模式”模型一致。

三、部署 OceanBase 集群（Oracle 模式）

3.1 环境规划

我们使用三台物理机或虚拟机（CentOS 7.9/RedHat），IP 如下：

每个节点要求至少 8C/32GB，磁盘建议 SSD，数据盘独立。

本文采用 命令行手动部署（也可以使用 OBD 自动化工具），更利于理解原理。

3.2 准备工作

所有节点执行：

# 关闭防火墙与 SELinux
systemctl stop firewalld && systemctl disable firewalld
setenforce 0
sed -i 's/SELINUX=enforcing/SELINUX=disabled/g' /etc/selinux/config

# 安装基础依赖
yum install -y wget curl libaio libtool-ltdl python3

# 创建 oceanbase 用户
useradd oceanbase
echo 'oceanbase' | passwd --stdin oceanbase

# 创建数据目录（需要与用户权限匹配）
mkdir -p /data/1 /data/2
chown -R oceanbase:oceanbase /data

3.3 下载并安装 OBServer

从官网下载 RPM 包（或使用社区版），上传至各节点：

# 以 4.2.x 版本为例
rpm -ivh oceanbase-4.2.1.el7.x86_64.rpm

安装后，二进制文件位于 /home/admin/oceanbase（默认）或 /usr/local/oceanbase，我们使用 /home/admin/oceanbase。

3.4 配置并启动 observer 进程

在 OBServer-1 上启动第一个节点，作为 RootService 初始节点：

su - oceanbase
cd /home/admin/oceanbase

# 启动命令（单行）
./bin/observer -i eth0 -p 2881 -P 2882 -z zone1 \
  -d /data/1 -r '192.168.10.101:2882:2881;192.168.10.102:2882:2881;192.168.10.103:2882:2881' \
  -c 1 -n obdemo -o "memory_limit=20G,datafile_size=50G,log_disk_size=30G,enable_syslog_recycle=True"

参数解释：

• -i：网卡名，用于监听。
• -p：SQL 端口（默认 2881）。
• -P：RPC 端口（默认 2882）。
• -z：指定 Zone 名称。
• -d：数据目录，需为 /data/1。
• -r：所有 OBServer 地址列表，格式 IP:RPC_PORT:SQL_PORT。
• -c：集群 ID。
• -n：集群名称。
• -o：启动参数，如内存、数据文件大小等。

然后在 OBServer-2 和 OBServer-3 上分别启动（注意 -z zone2/zone3，且不包含 -c 参数，因为集群已初始化）：

./bin/observer -i eth0 -p 2881 -P 2882 -z zone2 \
  -d /data/1 -r '192.168.10.101:2882:2881;192.168.10.102:2882:2881;192.168.10.103:2882:2881' \
  -n obdemo -o "memory_limit=20G,datafile_size=50G,log_disk_size=30G"

3.5 集群初始化与 Bootstrap

连接任意节点的 SQL 端口（mysql -h 192.168.10.101 -P 2881 -uroot），执行 Bootstrap 命令：

ALTER SYSTEM BOOTSTRAP ZONE 'zone1' SERVER '192.168.10.101:2882',
                          ZONE 'zone2' SERVER '192.168.10.102:2882',
                          ZONE 'zone3' SERVER '192.168.10.103:2882';

成功后，集群即搭建完成。

3.6 创建 Oracle 模式租户

首先修改 root 密码，并创建资源单元规格：

ALTER USER root IDENTIFIED BY 'password';

CREATE RESOURCE UNIT S4C8G MAX_CPU 4, MIN_CPU 4, MEMORY_SIZE '8G', LOG_DISK_SIZE '20G', MAX_IOPS 10000, MIN_IOPS 5000;
CREATE RESOURCE POOL pool_oracle UNIT 'S4C8G', UNIT_NUM 1, ZONE_LIST ('zone1','zone2','zone3');

创建租户，指定 ob_compatibility_mode='ORACLE'：

CREATE TENANT oracle_tenant RESOURCE_POOL_LIST=('pool_oracle') SET ob_compatibility_mode='ORACLE', ob_tcp_invited_nodes='%';

查看租户状态：

SELECT * FROM oceanbase.DBA_OB_TENANTS;

四、连接与基本管理

4.1 登录 Oracle 模式租户

租户创建后，系统会自动生成 sys 用户（相当于 Oracle 的 SYS）。使用租户的用户名连接（格式：用户名@租户名）：

mysql -h 192.168.10.101 -P 2881 -u sys@oracle_tenant -p

输入密码（默认为空，可修改）。

4.2 创建普通用户和数据库对象

在 Oracle 模式下，用户即 Schema，创建用户会自动生成同名 Schema：

CREATE USER app_user IDENTIFIED BY 'app123';
GRANT CONNECT, RESOURCE, CREATE SESSION TO app_user;

创建表：

CREATE TABLE app_user.orders (
  order_id NUMBER(10) PRIMARY KEY,
  customer_id NUMBER(10) NOT NULL,
  order_date DATE DEFAULT SYSDATE,
  total_amount NUMBER(12,2),
  status VARCHAR2(20)
);

支持序列、同义词、触发器、存储过程等。例如：

CREATE SEQUENCE app_user.orders_seq START WITH 1 INCREMENT BY 1;
CREATE TRIGGER app_user.trg_orders_id BEFORE INSERT ON app_user.orders FOR EACH ROW BEGIN SELECT orders_seq.NEXTVAL INTO :NEW.order_id FROM DUAL; END;
/

4.3 表空间管理

OceanBase Oracle 模式支持表空间（Tablespace），可设置数据文件位置（实际存储于集群的 SSTable 中）：

CREATE TABLESPACE tbs_data DATAFILE SIZE '10G' AUTOEXTEND ON NEXT '500M';
CREATE TABLE ... TABLESPACE tbs_data;

注意：表空间是逻辑概念，实际数据分布由分区策略决定。

五、Oracle 兼容性深度解析

5.1 数据类型支持

5.2 SQL 语法兼容

• DML：SELECT, INSERT, UPDATE, DELETE 完全兼容，支持 MERGE。
• DDL：CREATE/ALTER/DROP TABLE, INDEX, VIEW, SEQUENCE, SYNONYM, TRIGGER, PROCEDURE, FUNCTION, PACKAGE 等基本支持。
• 查询增强：支持 CONNECT BY 层次查询，分析函数（RANK, DENSE_RANK, LAG/LEAD），窗口函数。
• PL/SQL：支持块、变量、游标、异常处理、自治事务（部分）。但暂不支持 UTL_FILE、DBMS_SCHEDULER 等高级包，可用替代方案。

5.3 系统包与内置函数

常用函数如 TO_CHAR, TO_DATE, SUBSTR, INSTR, DECODE, NVL, COALESCE, CASE 等全部支持。系统视图如 DBA_TABLES, USER_TABLES, ALL_TABLES 提供与 Oracle 相同的信息。

5.4 兼容性限制（已知差异）

• 字符集：默认 AL32UTF8，不支持 ZHS16GBK 等。
• 分区键：最多支持 16 列。
• 外键约束：支持，但分布式跨节点性能可能下降。
• 物化视图：暂不支持自动刷新，需手动或使用定时任务。
• 全局临时表：支持，但事务级临时表行为略有不同。

六、从 Oracle 迁移到 OceanBase

6.1 迁移前评估

• 检查应用代码中使用的 Oracle 特性，对照官方兼容性列表。
• 预估数据量，设计分区策略（建议使用 Range/Hash 分区，充分利用分布式优势）。
• 准备迁移工具：OceanBase 官方 OMS（OceanBase Migration Service） 支持全量+增量迁移，且能实时同步。

6.2 使用 OMS 迁移（推荐）

1. 部署 OMS：在独立机器上运行 OMS Console。
2. 添加数据源：源端 Oracle（需开启归档日志和补充日志），目标端 OceanBase Oracle 租户。
3. 创建迁移任务：选择迁移对象（表、视图、序列等），配置并发度和校验规则。
4. 启动迁移：先进行全量迁移，再开启增量同步，实现不停机迁移。
5. 验证数据一致性：OMS 内置数据校验功能，对比两端数据。

6.3 手工迁移（适用于小型库）

使用 exp/imp（或 Oracle Data Pump）导出数据为 SQL 文件，再通过 OceanBase 的 obloader 或 mysql 命令导入。注意处理 DDL 语法差异，例如：

-- Oracle: CREATE TABLE ... PCTFREE 10;
-- OceanBase: 忽略 PCTFREE 参数，需修改

-- Oracle 的 VARCHAR2(10 CHAR) 在 OceanBase 中需明确为 VARCHAR2(10 CHAR) 或调整长度单位

对于存储过程，建议先导出 PL/SQL 源码，在 OceanBase 中重新编译，检查是否报错。

七、性能调优与运维

7.1 执行计划分析

使用 EXPLAIN 查看 SQL 执行计划，OceanBase 提供了类似 Oracle 的 DBMS_XPLAN 包：

EXPLAIN SELECT * FROM orders WHERE customer_id = 1001;

支持 OUTLINE 绑定执行计划，与 Oracle 的 SQL Profile 类似。

7.2 索引优化

• 局部索引（Local Index）：分区索引，分区键索引，适合 OLTP。
• 全局索引（Global Index）：跨分区，适合查询条件不含分区键的场景。

创建索引语法与 Oracle 一致：

CREATE INDEX idx_customer ON orders(customer_id) LOCAL;
CREATE INDEX idx_date_global ON orders(order_date) GLOBAL;

7.3 参数调优

租户级参数可通过 ALTER SYSTEM SET 动态修改，例如：

ALTER SYSTEM SET ob_sql_work_area_percentage = 10;  -- 工作区内存比例
ALTER SYSTEM SET parallel_servers_target = 64;       -- 并行度

7.4 监控与诊断

• 使用 OCP（OceanBase Cloud Platform） 提供可视化监控、告警和巡检。
• 内置系统视图：GV$OB_SQL_AUDIT 记录 SQL 历史，GV$OB_MEMORY 查看内存使用，GV$OB_IO_SCHEDULER 分析 IO。
• 日常运维命令：

-- 查看集群状态
SELECT * FROM oceanbase.DBA_OB_SERVERS;
-- 查看分区分布
SELECT * FROM oceanbase.DBA_OB_TABLE_PARTITIONS;
-- 租户资源使用
SELECT * FROM oceanbase.GV$OB_TENANT_MEMORY;

7.5 扩缩容操作

增加 OBServer 节点：在新机器启动 observer，并添加到集群：

ALTER SYSTEM ADD SERVER '192.168.10.104:2882' ZONE 'zone1';

回收节点：

ALTER SYSTEM DELETE SERVER '192.168.10.104:2882';

系统会自动进行数据重分布，无需停机。

八、高可用与容灾实战

8.1 多副本与故障切换

每个 Zone 保存一份完整数据，三副本策略下，任何一个 Zone 故障，集群仍可正常工作（Paxos 多数派）。若某个 OBServer 宕机，RootService 会在剩余节点上重新选举 Leader，并将故障节点的数据分区迁移到存活节点。

模拟测试：停止一个 observer 进程，观察业务影响（通常 RTO<30s）。

8.2 主备集群与异地容灾

OceanBase 支持创建 备租户（Standby Tenant），通过日志同步实现跨机房容灾：

CREATE STANDBY TENANT standby_tenant FROM oracle_tenant WITH LOG_RESTORE_SOURCE='...';

可通过 ALTER SYSTEM SWITCHOVER 进行主备切换。

九、真实案例：某金融系统迁移实践

背景：某银行核心交易系统原运行于 Oracle RAC 双节点，数据量约 10TB，日交易量 5000 万笔。面临 License 成本高、扩展性瓶颈。

迁移过程：

1. 评估：应用使用大量存储过程（约 2000 个），大部分 PL/SQL 可无缝迁移，少量依赖 DBMS_CRYPTO 的替换为 Java 加密。
2. 迁移：使用 OMS 进行全量迁移，业务低峰期切换，总耗时 8 小时（全量 5 小时，增量 3 小时）。
3. 验证：对账程序运行 24 小时，数据一致。
4. 优化：调整分区策略，由按日分区改为按小时分区，查询性能提升 40%。
5. 上线：连续运行 3 个月，未出现严重故障。

收益：硬件成本降低 50%，扩容时间从数周缩短到小时级。

十、总结与展望

OceanBase 的 Oracle 模式为企业提供了一条低门槛、高性能的分布式转型路径。通过高度兼容的 SQL 引擎和强大的扩展能力，它不仅解决了传统 Oracle 的扩展性问题，还带来了云原生运维的便捷性。

未来，OceanBase 将持续增强 PL/SQL 包支持、完善物化视图、提升并行查询能力，进一步缩小与原生 Oracle 的差距。