OceanBase的正确使用方法

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: OceanBase不是设计出来的,而是在使用过程中不断进化出来的。因此,系统使用以及运维的方便性至关重要。 OceanBase的使用者是业务系统开发人员,并交由专门的OceanBase DBA来运维。

OceanBase不是设计出来的,而是在使用过程中不断进化出来的。因此,系统使用以及运维的方便性至关重要。

OceanBase的使用者是业务系统开发人员,并交由专门的OceanBase
DBA来运维。为了方便业务使用,OceanBase实现了SQL接口且兼容MySQL协议,从而融入到MySQL开源生态圈。MySQL大部分管理工具,例如MySQL客户端,MySQL admin,能够在OceanBase系统中直接使用。另外,OceanBase将系统运维、监控相关的内部信存放到内部的系统表中,从而方便运维、监控系统获取。

OceanBase早期版本只允许通过Java或者C APl接口访问,新版本增加了SQL支持,且兼容MySQL客户端访问协议。OceanBase推荐用户使用SQL,但老应用仍然可以使用以前的JavaAPI访问OceanBase。下面介绍几个访问与使用场景。

MySQL客户端连接

使用者采用MySQL客户端连接OceanBase。通过MySQL客户端可以查看系统已有的表格、表格schema,执行select、update、insert、delete等SOL语句,查看系统内部状态,以及发送OceanBase集群运维命令。

【例】首先通过create table命令创建一张名称为test的表格,表格包含两列:id和ame,其中id为主键。接着,往表格中写入两行记录(1,“alice”),(2,”tob”)。最后,通过select语句读取这两行数据。

JDBC访问(JDBC template)

Java 应用通过标准JDBC访问OceanBase,代码如下所示:

ObGroupDataSource groupSource = new OBGroupDataSource();
groupSource.setUserName("user");//设置用户名
groupSource.setPasswd("pass");//设置密码
groupSource.setDbNane("test");// oceanBase不支持db,这里可以填任意值
groupSouorce.setConfigURL(ob_addr_url);//设置OceanBase集群的地址
groupSource.init();//初始化data source
JdbcTemplate jtp = new JdbcTemplate();
jtp.setDatasource(groupsource);//设置 jdbc template依赖的data source
String sql = "select 1 from = dual";
int ret = jtp.queryForInt(sql);//执行SOL查询
AI 代码解读

Spring集成

可以通过将OceanBase DataSource集成到Spring中,配置如下:

<bean id = "groupDataSource" 
        class=”com.alipay.oceanbase,ObGroupDataSource”
        init-method="init">
    <property name="username" value="user" />
    <property name="passwd" value="pass" />
    <property name="dbName" value="test" />
    <property name="configURL" value_ob_addr_url />
</bean>
AI 代码解读

C 客户端

C 应用通过OceanBase C客户端访间OceanBase,使用方式与MySQL C客户端完全一致,代码如下:

MYSQL mysql;
mysql_init(&mysql); //初始化
Mysql_real_connect(&mysql, ob url, ob user, ob pass, NULL, 0, NULL, 0);  //连接OceanBase数据库
Mysql_real_query(&mysq1, sq1, strlen(sql));  //执行SQL查询
MYSQL_RES* res = mysql_store_reault(&mysql); //获取SQL查询结果集
//处理SQL查询返回的结果集
while(MYSQL_ROW row = mysql_fetch_row(res); //从结果集读取一行数据
//处理结果集中的一行结果
Mysql_free_result(res); //释放结果集
Mysql_close(&mysql);  //关闭连接
AI 代码解读

总结

当然,应用可能会在客户端维护OceanBase连接池,Java应用还可能会使用其他持久层框架,例如iBatis。由于OceanBase兼容JDBC和MySQL C客户端,使用MySQL的应用无须修改代码就能接入OceanBase。

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
打赏
0
0
0
0
718
分享
相关文章
手把手教你实现 OceanBase 数据到阿里云数据库 SelectDB 内核版 Apache Doris 的便捷迁移|实用指南
本文介绍了如何将数据从 OceanBase 迁移到阿里云数据库 SelectDB 内核版 Apache Doris。提供 3 种数据同步方法 1. 使用 DataX,下载 DataX 并编写配置文件,通过 OceanBaseReader 和 DorisWriter 进行数据迁移。 2. 利用 Apache Doris 的 Catalog功 能,将 OceanBase 表映射到 Doris 并插入数据。 3. 通过Flink CDC,设置 OceanBase 环境,配置 Flink 连接器,实现实时数据同步。
手把手教你实现 OceanBase 数据到阿里云数据库 SelectDB 内核版 Apache Doris 的便捷迁移|实用指南
OceanBase有哪些功能?OceanBase有哪些功能?
OceanBase有哪些功能?【8月更文挑战第11天】
210 62
OceanBase数据库简介
【8月更文挑战第9天】OceanBase数据库简介
549 60
OceanBase的用法
【8月更文挑战第9天】OceanBase的用法
98 3
OceanBase数据库完整版和商业版
OceanBase数据库完整版和商业版
226 1
OceanBase有什么特性?
OceanBase有什么特性?【8月更文挑战第12天】
207 0
PolarDB产品使用合集之PolarDB-X是否支持MySQL的WITH AS语法
PolarDB是阿里云推出的一种云原生数据库服务,专为云设计,提供兼容MySQL、PostgreSQL的高性能、低成本、弹性可扩展的数据库解决方案,可以有效地管理和优化PolarDB实例,确保数据库服务的稳定、高效运行。以下是使用PolarDB产品的一些建议和最佳实践合集。
100 1
OBCP实践 - 迁移 MySQL 数据到 OceanBase 集群
OBCP实践 - 迁移MySQL数据到OceanBase集群,这是一个涉及到将现有MySQL数据库的数据和表结构迁移到OceanBase分布式数据库集群的实际操作过程。OceanBase是一款高度兼容MySQL协议的分布式数据库产品,支持在线平滑迁移,以便企业用户可以从传统的MySQL数据库平滑迁移到OceanBase,以实现更高的可用性、扩展性和性能。
158 0
OceanBase数据库完整版和商业版的主要区别在于
OceanBase数据库完整版和商业版的主要区别在于
252 3