R Language Connector

通过 R 语言中的 RJDBC 库可以使 R 语言程序支持访问 TDengine 数据。以下是安装过程、配置过程以及 R 语言示例代码。

安装过程

在开始之前，请确保已经安装了R语言环境。然后按照以下步骤安装和配置RJDBC库：

安装Java Development Kit (JDK)：RJDBC库需要依赖Java环境。请从Oracle官方网站下载适合您操作系统的JDK，并按照安装指南进行安装。
安装RJDBC库：在R控制台中执行以下命令来安装RJDBC库。

install.packages("RJDBC", repos='http://cran.us.r-project.org')

备注

Ubuntu 系统自带的 R 语言软件版本 4.2 在调用 RJDBC 库会产生无响应 bug，请安装 R 语言官网的安装包。
在 Linux 上安装 RJDBC 包可能需要安装编译需要的组件，以 Ubuntu 为例执行 apt install -y libbz2-dev libpcre2-dev libicu-dev 命令安装。
在 Windows 系统上需要设置 JAVA_HOME 环境变量。

下载 TDengine JDBC 驱动程序：访问 maven.org 网站，下载 TDengine JDBC 驱动程序（taos-jdbcdriver-X.X.X-dist.jar）。
将 TDengine JDBC 驱动程序放置在适当的位置：在您的计算机上选择一个合适的位置，将 TDengine JDBC 驱动程序文件（taos-jdbcdriver-X.X.X-dist.jar）保存在此处。

配置过程

完成了安装步骤后，您需要进行一些配置，以便RJDBC库能够正确连接和访问TDengine时序数据库。

在 R 脚本中加载 RJDBC 和其他必要的库：

library(DBI)
library(rJava)
library(RJDBC)

设置 JDBC 驱动程序和 JDBC URL：

# 设置JDBC驱动程序路径（根据您实际保存的位置进行修改）
driverPath <- "/path/to/taos-jdbcdriver-X.X.X-dist.jar"

# 设置JDBC URL（根据您的具体环境进行修改）
url <- "jdbc:TAOS://localhost:6030/?user=root&password=taosdata"

加载 JDBC 驱动程序：

# 加载JDBC驱动程序
drv <- JDBC("com.taosdata.jdbc.TSDBDriver", driverPath)

创建 TDengine 数据库连接：

# 创建数据库连接
conn <- dbConnect(drv, url)

连接成功后，您可以使用 conn 对象进行各种数据库操作，如查询数据、插入数据等。
最后，不要忘记在使用完成后关闭数据库连接：

# 关闭数据库连接
dbDisconnect(conn)

使用 RJDBC 的 R 语言示例代码

以下是一个使用 RJDBC 库连接 TDengine 时序数据库并执行查询操作的示例代码：

原生连接
library("DBI")
library("rJava")
library("RJDBC")

args<- commandArgs(trailingOnly = TRUE)
driver_path = args[1] # path to jdbc-driver for example: "/root/taos-jdbcdriver-3.2.4-dist.jar"
driver = JDBC("com.taosdata.jdbc.TSDBDriver", driver_path)
conn = dbConnect(driver, "jdbc:TAOS://127.0.0.1:6030/?user=root&password=taosdata")
dbGetQuery(conn, "SELECT server_version()")
dbSendUpdate(conn, "create database if not exists rtest")
dbSendUpdate(conn, "create table if not exists rtest.test (ts timestamp, current float, voltage int, devname varchar(20))")
dbSendUpdate(conn, "insert into rtest.test values (now, 1.2, 220, 'test')")
dbGetQuery(conn, "select * from rtest.test")
dbDisconnect(conn)