oceanbase基础概念和语法介绍

OceanBase 是由蚂蚁集团自主研发的分布式关系型数据库，兼容 MySQL 和 Oracle 模式，具备高可用、强一致性、水平扩展、HTAP（混合事务/分析处理）等能力。以下是其核心基础概念与常用语法介绍。

一、OceanBase 核心架构与基础概念

1.分布式架构

• 多副本强一致：数据自动分片（Partition），每个分片在多个节点（OBServer）上存有副本（通常 3 副本），通过 Paxos 协议保证强一致性。
• 无共享（Shared-Nothing）：每个节点独立存储和计算，避免单点瓶颈。
• 自动负载均衡：数据和流量可动态迁移，实现弹性扩缩容。

2.关键组件

3.租户（Tenant）

• 逻辑隔离单元：类似“数据库实例”，一个集群可创建多个租户（如mysql_tenant,oracle_tenant）。
• 资源隔离：每个租户分配 CPU、内存、磁盘资源（通过 Resource Unit 控制）。
• 模式选择：创建租户时指定兼容模式（MySQL / Oracle）。

4.分区（Partition）

• 表数据按分区规则（如 HASH、RANGE、KEY）拆分到多个 Partition。
• 每个 Partition 有多个副本（Leader + Follower），Leader 处理读写，Follower 只读或同步。

5.LS（Log Stream） & Tablet

• LS（日志流）：事务日志的最小单位，一个 LS 包含多个 Tablet。
• Tablet：存储的最小物理单元（类似传统数据库的“段”），是副本调度的基本单位。

二、OceanBase 兼容模式

OceanBase 支持两种 SQL 模式：

💡 创建租户时指定模式：

CREATETENANT mysql_tenant RESOURCE_POOL_LIST=('pool1'),PRIMARY_ZONE='zone1',LOCALITY='F@zone1,F@zone2,F@zone3',COMMENT'MySQL mode tenant';

三、常用 SQL 语法（以 MySQL 模式为例）

1.建表与分区

-- 普通表（自动分区）CREATETABLEusers(idBIGINTPRIMARYKEY,nameVARCHAR(50),create_timeDATETIME);-- 显式 HASH 分区（按 id 分 8 个分区）CREATETABLEorders(order_idBIGINT,user_idBIGINT,amountDECIMAL(10,2))PARTITIONBYHASH(user_id)PARTITIONS8;-- RANGE 分区CREATETABLElogs(log_idBIGINT,log_dateDATE)PARTITIONBYRANGECOLUMNS(log_date)(PARTITIONp2023VALUESLESS THAN('2024-01-01'),PARTITIONp2024VALUESLESS THAN('2025-01-01'));

2.插入与查询

-- 插入数据INSERTINTOusers(id,name,create_time)VALUES(1,'Alice',NOW());-- 查询（支持 MySQL 语法）SELECT*FROMusersWHEREid=1LIMIT1;-- 分布式 JOIN（自动优化）SELECTu.name,o.amountFROMusers uJOINorders oONu.id=o.user_id;

3.事务控制

-- 显式事务（强一致性）BEGIN;UPDATEaccountsSETbalance=balance-100WHEREuser_id=1;UPDATEaccountsSETbalance=balance+100WHEREuser_id=2;COMMIT;

4.系统视图（监控用）

-- 查看当前租户分区信息SELECT*FROMoceanbase.DBA_OB_TABLE_LOCATIONS;-- 查看会话SHOWPROCESSLIST;-- 查看资源使用SELECT*FROMGV$OB_SERVERS;-- 所有节点状态

四、特色功能语法

1.全局索引（Global Index）

-- 在非分区键上创建全局索引CREATEINDEXidx_order_amountONorders(amount)GLOBAL;

2.闪回查询（Flashback Query）

-- 查询 5 分钟前的数据（依赖 clog 保留时间）SELECT*FROMusersASOFTIMESTAMP(NOW()-INTERVAL5MINUTE)WHEREid=1;

3.多模（JSON 支持）

-- JSON 类型（MySQL 模式）CREATETABLEproducts(idBIGINT,info JSON);INSERTINTOproductsVALUES(1,'{"color": "red", "size": "M"}');SELECTinfo->'$.color'FROMproducts;

五、运维常用命令（通过 ODP 或直连）

六、与 MySQL 的主要差异

📌最佳实践：

• 避免大事务（默认超时 10s）
• 主键设计尽量单调递增（避免热点）
• OLAP 查询走只读副本或独立分析型租户

七、快速体验

1. 部署：使用 OceanBase Docker 镜像 快速启动。

2. 连接：

   mysql -h127.0.0.1 -P2881 -uroot@sys -p -c -A

3. 创建租户 & 数据库：

   CREATETENANT test_tenant resource_pool_list=('test_pool');CREATEDATABASEtest_db;USEtest_db;

✅ 总结

官方文档：https://www.oceanbase.com/docs
开源版本：OceanBase CE（社区版）免费可用。

掌握以上概念和语法，即可开始在 OceanBase 上开发和部署应用！