使用 R2DBC 连接 KWDB

Reactive Relational Database Connectivity (R2DBC) 项目为关系型数据库提供了响应式编程的 API。R2DBC 创建了一个非阻塞的服务提供接口，方便数据库驱动和客户端库的开发者使用。

KWDB 支持用户通过 R2DBC 连接数据库，并执行创建、插入和查询操作。本示例演示了如何通过 R2DBC 连接和使用 KWDB。

前提条件

安装 openJDKopen in new window（1.8 及以上版本）。
安装 Mavenopen in new window（3.6 及以上版本）。
安装 KWDB 数据库、配置数据库认证方式、创建数据库。
创建具有表级别及以上操作权限的用户。
获取 KaiwuDB JDBC 驱动包。

配置示例

下载 R2DBC 相关代码。

编译项目。

cd r2dbc
mvn clean package -Dmaven.test.skip=true

创建目录并复制文件：

mkdir -p /opt/r2dbc/
mkdir -p /opt/r2dbc/logs/
cp target/r2dbc-0.0.1-SNAPSHOT.jar /opt/r2dbc/
cp target/classes/application.properties /opt/r2dbc/

启动应用：

nohup java -jar /opt/r2dbc/r2dbc-0.0.1-SNAPSHOT.jar --spring.config.location=/opt/r2dbc/application.properties --server.port=8090 > /opt/r2dbc/logs/output.log 2>&1 &

执行数据写入、查询和删除操作，验证配置：以下示例假设已创建名为 r2dbc 的时序库，名为 cpu 的时序表，并向表内写入数据。

CREATE TS DATABASE r2dbc;

CREATE TABLE r2dbc.cpu (
    k_timestamp TIMESTAMPTZ NOT NULL,
    usage_user INT8 NOT NULL,
    usage_system INT8 NOT NULL,
    usage_idle INT8 NOT NULL,
    usage_nice INT8 NOT NULL,
    usage_iowait INT8 NOT NULL,
    usage_irq INT8 NOT NULL,
    usage_softirq INT8 NOT NULL,
    usage_steal INT8 NOT NULL,
    usage_guest INT8 NOT NULL
) TAGS (
    ptag INT4 NOT NULL,
    region INT4 NOT NULL,
    datacenter INT4 NOT NULL,
    rack VARCHAR(1024),
    os VARCHAR(1024),
    arch VARCHAR(1024),
    team VARCHAR(1024),
    service VARCHAR(1024)
) PRIMARY TAGS (ptag);

INSERT INTO r2dbc.cpu (k_timestamp, usage_user, usage_system, usage_idle, usage_nice,
    usage_iowait, usage_irq, usage_softirq, usage_steal, usage_guest, ptag, region, datacenter,
    rack, os, arch, team, service)
VALUES
    ('2024-01-21 22:22:22.221', 1, 2, 3, 4, 5, 6, 7, 8, 1, 1, 1, 1, '2', '2', '2', '2', '2'),
    ('2024-01-22 22:22:22.221', 1, 2, 3, 4, 5, 6, 7, 8, 1, 1, 1, 1, '2', '2', '2', '2', '2'),
    ('2024-01-23 22:22:22.221', 1, 2, 3, 4, 5, 6, 7, 8, 1, 1, 1, 1, '2', '2', '2', '2', '2');

使用 curl 查询数据：

curl -X GET -H "Accept:*/*" -H "Content-Type:application/x-www-form-urlencoded" "http://localhost:8090/r2dbc/cpus/1?end=1706106142221&start=1705760542221"

使用 curl 写入数据：

curl -X POST -H "Accept:*/*" -H "Content-Type:application/json" -d "{\"arch\":\"\",\"dataCenter\":2,\"id\":2,\"os\":\"\",\"rack\":\"\",\"region\":2,\"service\":\"\",\"team\":\"\",\"time\":1722579427867,\"usageGuest\":1,\"usageIdle\":1,\"usageIoWait\":1,\"usageIrq\":1,\"usageNice\":1,\"usageSoftIrq\":1,\"usageSteal\":1,\"usageSystem\":1,\"usageUser\":1}" "http://localhost:8090/r2dbc/cpu"

使用 curl 删除数据：

curl -X POST -H  "Accept:*/*" -H  "Content-Type:application/json" -d "{\"id\":1,\"time\":1722579427867}" "http://localhost:8090/r2dbc/cpu/delete"

# 使用 R2DBC 连接 KWDB

# 前提条件

# 配置示例

使用 R2DBC 连接 KWDB

前提条件

配置示例