首页 / 知识

基于GBase8s和Calcite的多数据源查询

2023-04-11 16:28:00

基于GBase8s和Calcite的多数据源查询
在本文中，我们将实践 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"
 
}

数据源查询多数据源存放镜像安装

最新内容

相关内容

热门文章

推荐文章

标签云

猜你喜欢