连接 MySQL 租户也可以使用 MySQL 官方 JDBC 驱动:mysql-connector-Java。推荐使用 5.1.30 和 5.1.40 版本,其他版本可能存在兼容问题。

注意

  • oceanbase-client 完全兼容 MySQL JDBC 的使用方式并且可以自动识别 OceanBase 的运行模式是 MySQL 还是 Oracle,因为其在协议层还兼容 2 种模式,且兼容 OB 2.0 协议。

  • mysql-connector-Java 只支持 MySQL 运行模式。

oceanbase-client 使用说明

连接串的前缀需要设置为 ,其他部分的使用方式与原生的 MySQL 使用方式保持一致。

注意

1.0.9 版本的 oceanbase-client 的驱动类名为:com.alipay.oceanbase.obproxy.mysql.jdbc.Driver。

后续版本驱动类名改为:com.alipay.oceanbase.jdbc.Driver。

代码示例如下所示:

mysql-connector-Java 使用说明

连接串的前缀需要设置为 jdbc:mysql,驱动类名为:com.mysql.jdbc.Driver。

代码示例如下所示:

  1. String url = "jdbc:mysql://xxx.xxx.xxx.xxx:2883/hr?useUnicode=true&characterEncoding=utf-8"; //IP地址:OBProxy端口号/数据库名
  2. String username = "root@test2#obtest"; //用户名@租户名#集群名称
  3. String password = "test"; //密码
  4. Connection conn = null;
  5. try {
  6. Class.forName("com.mysql.jdbc.Driver"); //驱动类名
  7. conn = DriverManager.getConnection(url, username, password);
  8. PreparedStatement ps = conn.prepareStatement("select date_format(now(),'%Y-%m-%d %H:%i:%s');");
  9. ResultSet rs = ps.executeQuery();
  10. rs.next();
  11. System.out.println("sysdate is:" + rs.getString(1));
  12. rs.close();
  13. ps.close();
  14. } catch (Exception e) {
  15. e.printStackTrace();
  16. } finally {
  17. if (null != conn) {
  18. conn.close();
  19. }
  20. }

下述表格中展示了 JDBC 中几个必须要设置的重要参数。均可以设置到连接池的 ConnectionProperties 中,或者 JdbcURL 上:

应用连接池配置

将应用和数据库连接进行业务操作,建议使用连接池。如果是 Java 程序,推荐使用 Druid 连接池。配置示例如下所示:

  1. <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
  2. <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  3. <!-- 基本属性 URL、user、password -->
  4. <property name="url" value="jdbc:mysql://ip:port/db?socketTimeout=30000&amp;connectTimeout=3000" />
  5. <property name="username" value="{user}" />
  6. <property name="password" value="{password}" />
  7. <property name="maxActive" value="4" /> //initialSize/minIdle/maxActive视业务规模设置
  8. <property name="initialSize" value="2" />
  9. <property name="minIdle" value="2" />
  10. <!-- 获取连接等待超时的时间,单位是毫秒 -->
  11. <property name="maxWait" value="1000" />
  12. <property name="timeBetweenEvictionRunsMillis" value="60000" />
  13. <!-- 一个连接在池中最小空闲的时间,单位是毫秒-->
  14. <property name="minEvictableIdleTimeMillis" value="300000" />
  15. <!-- 检测连接是否可用的 SQL -->
  16. <property name="validationQuery" value="SELECT foo FROM bar" /> //找真实的、记录少的业务表用作查询探测语句
  17. <!-- 是否开启空闲连接检查 -->
  18. <property name="testWhileIdle" value="true" />
  19. <!-- 是否在获取连接前检查连接状态 -->
  20. <property name="testOnBorrow" value="false" />
  21. <!-- 是否在归还连接时检查连接状态 -->
  22. <property name="testOnReturn" value="false" />
  23. </bean>

开放数据库互连(ODBC)是微软公司开放服务结构(WOSA,Windows Open Services Architecture)中有关数据库的一个组成部分,基本思想是为用户提供简单、标准、透明的数据库连接的公共编程接口,开发厂商根据 ODBC 的标准去实现底层的驱动程序,这个驱动对用户是透明的,并允许根据不同的 DBMS 采用不同的技术加以优化实现。

ODBC 主要由驱动程序和驱动程序管理器组成。驱动程序是一个用以支持 ODBC 函数调用的模块,每个驱动程序对应于相应的数据库,当应用程序从基于一个数据库系统移植到另一个时,只需更改应用程序中由 ODBC 管理程序设定的与相应数据库系统对应的别名即可。

连接 OceanBase 数据库的驱动程序管理器和驱动程序 OB-ODBC 均是定制开发,通过该驱动可以连接访问 OceanBase 数据库的 MySQL 及 Oracle 租户。

Linux 下 OB-ODBC 连接 OceanBase 数据库的架构图如下所示。

连接环境配置

连接数据库前,需要配置连接环境,配置方法如下:

  1. 修改配置文件 odbc.ini,路径为 /etc/odbc.ini,配置文件 odbc.ini 也可以放在除了 /etc 以外的其他目录,通过设置环境变量到相应的目录即可。

    1. [ODBC Data Sources]
    2. data_source_name = Name
    3. [Name]
    4. Driver=Oceanbase
    5. Description = MyODBC 5 Driver DSN
    6. SERVER = [OBProxy IP地址]
    7. PORT = [OBProxy 端口]
    8. USER = [用户名@租户名#集群名称]
    9. Password = [用户密码]
    10. Database = [数据库名]
    11. OPTION = 3
    12. charset=UTF8
  2. 设置环境变量。

    1. export ODBCSYSINI=/etc
    2. export ODBCINI=/etc/odbc.ini
    3. export LD_LIBRARY_PATH=/u01/mysql/lib:/usr/lib64:$LD_LIBRARY_PATH
  3. 配置完成后使用 odbcinst -j命令查看配置是否正确。

    返回结果如下所示。

    1. unixODBC 2.3.7
    2. DRIVERS............: /etc/odbcinst.ini
    3. SYSTEM DATA SOURCES: /etc/odbc.ini
    4. FILE DATA SOURCES..: /etc/ODBCDataSources
    5. USER DATA SOURCES..: /etc/odbc.ini
    6. SQLULEN Size.......: 8
    7. SQLLEN Size........: 8
    8. SQLSETPOSIROW Size.: 8

示例:

  1. 以 OceanBase 数据库的 Oracle 租户为测试环境,运行下述语句在数据库中创建一张示例表 TEST。

    1. CREATE TABLE "TEST" (
    2. "ID" NUMBER(38) NOT NULL,
    3. "NAME" VARCHAR2(32),
    4. CONSTRAINT "TEST_PK" PRIMARY KEY ("ID")
    5. ) COMPRESS FOR ARCHIVE REPLICA_NUM = 3 BLOCK_SIZE = 16384 USE_BLOOM_FILTER = FALSE TABLET_SIZE = 134217728 PCTFREE = 10
  2. 编写连接数据库的驱动程序。

    驱动程序的代码示例如下:

    注意

    Oracle 租户同 MySQL 租户最大的区别在于不会自动提交,因此代码中增加了 ORACLE mode will need this section片段,如果是操作 MySQL 租户则无需这段代码。

  3. 编译并执行驱动程序。

    GCC 编译时,使用 -I 选项指定头文件, -L 指定库文件目录, -l指定库名。

    示例语句如下所示:

    1. gcc test.c -L/u01/unix-odbc/lib -lodbc -I/u01/unix-odbc/include -otest
    2. ./test

    检查结果:

    1. obclient -hobproxy.oceanbase.abc.com -uhr@test0_5#obtest -p'hr' -P2883
    2. obclient> select * from test;
    3. +----+-------+
    4. | ID | NAME |
    5. +----+-------+
    6. | 1 | jason |
    7. | 2 | robin |

C APIs 包含在 mysqlclient库文件当中,GCC 编译时使用 -I选项指定头文件, -L指定库文件目录, -l指定库名。示例语句如下所示:

注意

把库文件名开头的 lib 和结尾的 .so 去掉即为库名。

代码示例: