在本文中，我们将实践 GBase8s 和 MySQL 的跨数据源联合查询，案例中 MySQL 数据源中存放商品信息，GBase8s 数据源中存放订单信息。 整体架构如下
好了，我们开始吧。
环境准备
GBase8s
安装镜像 docker pull liaosnet/gbase8s
启动容器 docker run -itd -p 19088:9088 liaosnet/gbase8s
容器基本信息：
JDBC JAR：/home/gbase/gbasedbtjdbc_3.3.0_2.jar
类名：com.gbasedbt.jdbc.Driver
URL：jdbc:gbasedbt-sqli://IPADDR:19088/testdb:GBASEDBTSERVER=gbase01;DB_LOCALE=zh_CN.utf8;CLIENT_LOCALE=zh_CN.utf8;IFX_LOCK_MODE_WAIT=30;
用户：gbasedbt
密码：GBase123
其中：IPADDR为docker所在机器的IP地址，同时需要放通19088端口。
MySQL
安装镜像 docker pull liaosnet/gbase8s
启动容器 docker run -p 3306:3306 --name mysql -e MYSQL_ROOT_PASSWORD=dafei1288 -d mysql
数据准备
GBase8s
CREATE TABLE order_table （
oid INTEGER NOT NULL,
iid INTEGER,
icount INTEGER,
PRIMARY KEY （oid） CONSTRAINT order_table_pk
）;
INSERT INTO order_table （oid, iid, icount） VALUES（1, 1, 10）;
INSERT INTO order_table （oid, iid, icount） VALUES（2, 3, 30）;
MySQL
create table item
（
i_id int auto_increment
primary key,
catalog varchar（20） null,
pname varchar（20） null,
price float null,
constraint item_i_id_uindex
unique （i_id）
）;
INSERT INTO test.item （i_id, catalog, pname, price） VALUES （1, '游戏', '大航海时代IV', 300）;
INSERT INTO test.item （i_id, catalog, pname, price） VALUES （2, '游戏', '马车8', 300）;
INSERT INTO test.item （i_id, catalog, pname, price） VALUES （3, '食品', '青椒豆腐乳西瓜', 20）;
工程准备
创建 maven 工程，目录如下图所示：
添加依赖
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>calcite_multi_database</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.calcite</groupId>
<artifactId>calcite-core</artifactId>
<version>1.29.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.28</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.9</version>
</dependency>
<dependency>
<groupId>gbase</groupId>
<artifactId>gbasedbt</artifactId>
<version>330</version>
<scope>system</scope>
<systemPath>${project.basedir}/libs/gbasedbtjdbc_3.3.0_2_36477d.jar</systemPath>
</dependency>
</dependencies>
</project>
添加数据源配置文件 multiSource.json
{
"defaultSchema": "gbasedbt",
"schemas": [
{
"factory": "org.apache.calcite.adapter.jdbc.JdbcSchema$Factory",
"name": "mysql",
"operand": {
"jdbcDriver": "com.mysql.cj.jdbc.Driver",
"jdbcUrl": "jdbc:mysql://localhost:3306/test",
"jdbcUser": "root",
"jdbcPassword": "dafei1288"
},
"type": "custom"
},
{
"factory": "org.apache.calcite.adapter.jdbc.JdbcSchema$Factory",
"name": "gbasedbt",
"operand": {
"jdbcDriver": "com.gbasedbt.jdbc.Driver",
"jdbcUrl": "jdbc:gbasedbt-sqli://localhost:19088/testdb:GBASEDBTSERVER=gbase01;DB_LOCALE=zh_CN.utf8;CLIENT_LOCALE=zh_CN.utf8;IFX_LOCK_MODE_WAIT=30;",
"jdbcUser": "gbasedbt",
"jdbcPassword": "GBase123"
},
"type": "custom"
}
],
"version": "1.0"
}
|
