2-TDengine客户端连接，RESTful，JDBC

时间：2022-12-18 04:00:00 cm220连接器插座连接器dc060t00

【本文正在参与 “拥抱开源 | 涛思数据 TDengine有奖征稿】
https://marketing.csdn.net/p/0ada836ca30caa924b9baae0fd33857c

背景

在上一篇文章的经验中，使用服务器本地客户端连接后，如何远程连接？ TDengine 例如：远程客户端，JDBC等。

TDengine包括应用程序开发界面在内的应用程序开发界面丰富C/C 、Java、Python、Go、Node.js、C# 、RESTful等等，方便用户快速开发应用。这里有三种连接远程的方式 taosd 服务：

RESTful Connector；
Windows远程客户端；
JDBC-JNI；

RESTful Connector

RESTful Connector 直接启动是最简单的远程连接方式，跨平台，无需安装任何客户端 HTTP 请求即可。

TDengine 通过 HTTP POST 请求 BODY 中包含的 SQL 操作数据库只需要一个句子 URL ，以下是在 Windows 10 使用操作系统 curl 发送 HTTP 请求体验。

Note: RESTful Connector 默认使用6041(实际值是 serverPort 因此，可以修改 serverPort 修改参数设置)端口通信，因此需要在服务器端打开6041TCP端口。

   iptables -I INPUT -p TCP --dport 6041 -j ACCEPT

# RESTful Connector  # 无认证信息，报错 cxzx-t580@Heartsuit MINGW64 /d/IoT $ curl -d 'select * from db.t' hadoop1:6041/rest/sql { 
        "status":"error","code":4357,"desc":"no auth info input"}  # 附加用户名：密码，正常响应 cxzx-t580@Heartsuit MINGW64 /d/IoT $ curl -u root:taosdata -d 'select * from db.t' hadoop1:6041/rest/sql { 
        "status":"succ","head":["ts","speed"],"column_meta":[["ts",9,8],["speed",4,4]],"data":[["2019-07-15 00:00:00.000",10],["2019-07-15 01:00:00.000",20]],"rows":2}  # 附加用户名：密码Base64编码头信息，正常响应 cxzx-t580@Heartsuit MINGW64 /d/IoT $ curl -H 'Authorization: Basic cm9vdDp0YW9zZGF0YQ==' -d 'select * from db.t' hadoop1:6041/rest/sql { 
        "status":"succ","head":["ts","speed"],"column_meta":[["ts",9,8],["speed",4,4]],"data":[["2019-07-15 00:00:00.000",10],["2019-07-15 01:00:00.000,20]],"rows":2}

# 获取token
cxzx-t580@Heartsuit MINGW64 /d/IoT
$ curl hadoop1:6041/rest/login/root/taosdata
{ 
        "status":"succ","code":0,"desc":"/KfeAzX/f9na8qdtNZmtONryp201ma04bEl8LcvLUd7a8qdtNZmtONryp201ma04"}

# 附加自定义token在头信息，正常响应
cxzx-t580@Heartsuit MINGW64 /d/IoT
$ curl -H 'Authorization: Taosd /KfeAzX/f9na8qdtNZmtONryp201ma04bEl8LcvLUd7a8qdtNZmtONryp201ma04' -d 'select * from db.t' hadoop1:6041/rest/sql
{ 
        "status":"succ","head":["ts","speed"],"column_meta":[["ts",9,8],["speed",4,4]],"data":[["2019-07-15 00:00:00.000",10],["2019-07-15 01:00:00.000",20]],"rows":2}

# 请求URL采用sqlt时，返回结果集的时间戳将采用Unix时间戳格式表示
cxzx-t580@Heartsuit MINGW64 /d/IoT
$ curl -H 'Authorization: Basic cm9vdDp0YW9zZGF0YQ==' -d 'select * from db.t' hadoop1:6041/rest/sqlt
{ 
        "status":"succ","head":["ts","speed"],"column_meta":[["ts",9,8],["speed",4,4]],"data":[[1563120000000,10],[1563123600000,20]],"rows":2}

# 请求URL采用sqlutc时，返回结果集的时间戳将采用UTC时间字符串表示
cxzx-t580@Heartsuit MINGW64 /d/IoT
$ curl -H 'Authorization: Basic cm9vdDp0YW9zZGF0YQ==' -d 'select * from db.t' hadoop1:6041/rest/sqlutc
{ 
        "status":"succ","head":["ts","speed"],"column_meta":[["ts",9,8],["speed",4,4]],"data":[["2019-07-15T00:00:00.000+0800",10],["2019-07-15T01:00:00.000+0800",20]],"rows":2}

# 创建数据库
cxzx-t580@Heartsuit MINGW64 /d/IoT
$ curl -H 'Authorization: Basic cm9vdDp0YW9zZGF0YQ==' -d 'create database ok' hadoop1:6041/rest/sql
{ 
        "status":"succ","head":["affected_rows"],"column_meta":[["affected_rows",4,4]],"data":[[0]],"rows":1}

# 删除数据库
cxzx-t580@Heartsuit MINGW64 /d/IoT
$ curl -H 'Authorization: Basic cm9vdDp0YW9zZGF0YQ==' -d 'drop database ok' hadoop1:6041/rest/sql
{ 
        "status":"succ","head":["affected_rows"],"column_meta":[["affected_rows",4,4]],"data":[[0]],"rows":1}

Widnows客户端

下载与服务器端版本一致的客户端：https://www.taosdata.com/assets-download/TDengine-client-2.1.2.0-Windows-x64.exe

Note：

客户端竟然直接安装到C盘下：C:\TDengine，不过考虑到默认的配置文件位置，可以理解。
TDengine 默认使用6030端口通信，所以在服务器端需要开放6030的TCP端口。

# 在taos所在目录执行连接命令，报错了。。
C:\TDengine>taos -h 192.168.169.129
Welcome to the TDengine shell from Linux, Client Version:2.1.2.0
Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.

taos connect failed, reason: Unable to establish connection.

这时，如果通过 JDBC-JNI 方式远程连接 TDengine 时： spring.datasource.driver-class-name=com.taosdata.jdbc.TSDBDriver ，报错：

   java.sql.SQLException: JNI ERROR (2354): JNI connection is NULL

解决方法：除了开启6030的 TCP 端口外，还需要开放6030的 UDP 端口： iptables -I INPUT -p UDP --dport 6030 -j ACCEPT

# 再次连接，成功
C:\TDengine>taos -h 192.168.169.129
Welcome to the TDengine shell from Linux, Client Version:2.1.2.0
Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.

taos>

JDBC-JNI

使用官方的 Demo ：https://github.com/taosdata/TDengine/tree/develop/tests/examples/JDBC；

这些示例在安装的客户端目录也有： /usr/local/taos/examples/JDBC 或者 C:\TDengine\examples\JDBC

这里主要涉及到 JDBCDemo 项目下的 JDBCDemo.java 文件，其中的逻辑比较简单，就是一个主方法，实现建库、建表、插入数据、查询方法。

不过遇到了一些问题：

既然我用的是2.1.2.0的版本，可是下载的客户端自带示例的taos-jdbc依赖版本却五花八门。。
JDBCDemo.java 报错，但是实际上已经跑通了。。
JDBCDemo.java 中每条语句都正常执行，可是返回的却是Error。。

着实令人哭笑不得、摸不着头脑呀。

Note：

因为 JDBC-JNI 使用的是 com.taosdata.jdbc. TSDBDriver ，连接 6030 端口，所以也需要开放TCP、UDP。

iptables -I INPUT -p TCP --dport 6030 -j ACCEPT
iptables -I INPUT -p UDP --dport 6030 -j ACCEPT

pom中关于taos-jdbc的依赖版本应与服务端、客户端保持兼容，默认是2.0.18，我改成了2.0.30

<dependency>
       <groupId>com.taosdata.jdbcgroupId>
       <artifactId>taos-jdbcdriverartifactId>
       <version>2.0.30version>
dependency>

关于版本兼容性说明，见官方这个表：

Reference

https://www.taosdata.com/cn/documentation/connector#restful
https://www.taosdata.com/cn/documentation/connector/java

If you have any questions or any bugs are found, please feel free to contact me.

Your comments and suggestions are welcome!

【本文正在参与 “拥抱开源 | 涛思数据 TDengine有奖征稿】
https://marketing.csdn.net/p/0ada836ca30caa924b9baae0fd33857c

锐单商城拥有海量元器件数据手册、IC替代型号，打造电子元器件IC百科大全！

2-TDengine客户端连接，RESTful，JDBC

相关文章