ODBC

2024年11月8日大约 2 分钟

ODBC

在 JDBC 插件的基础上，IoTDB 可以通过 ODBC-JDBC 桥来支持通过 ODBC 对数据库的操作。

依赖

带依赖打包的 IoTDB JDBC 插件包
ODBC-JDBC 桥（如 Zappy-Sys）

部署方法

准备 JDBC 插件包

下载 IoTDB 源码，在根目录下执行下面的命令：

mvn clean package -pl iotdb-client/jdbc -am -DskipTests -P get-jar-with-dependencies

之后，就可以在iotdb-client/jdbc/target目录下看到iotdb-jdbc-1.3.2-SNAPSHOT-jar-with-dependencies.jar文件。

准备 ODBC-JDBC 桥

注意: 这里给出的仅仅是一种 ODBC-JDBC 桥，仅作示例。读者可以自行寻找其他的 ODBC-JDBC 桥来对接 IoTDB 的 JDBC 插件。

下载 Zappy-Sys ODBC-JDBC 桥插件：
进入 https://zappysys.com/products/odbc-powerpack/odbc-jdbc-bridge-driver/ 网站，点击下载按钮并直接安装。
ZappySys_website.jpg

准备 IoTDB：打开 IoTDB 集群，并任意写入一条数据。

IoTDB > insert into root.ln.wf02.wt02(timestamp,status) values(1,true)

部署及调试插件：

打开 ODBC 数据源 32/64 位，取决于 Windows 的位数，一个示例的位置是 C:\ProgramData\Microsoft\Windows\Start Menu\Programs\Administrative Tools。
ODBC_ADD_CN.jpg
点击添加，选择 ZappySys JDBC Bridge。
ODBC_CREATE_CN.jpg

填写如下配置：

配置项	填写内容	示例
Connection String	jdbc:iotdb://<IoTDB 的 IP>:<IoTDB 的 rpc port>/	jdbc:iotdb://127.0.0.1:6667/
Driver Class	org.apache.iotdb.jdbc.IoTDBDriver	org.apache.iotdb.jdbc.IoTDBDriver
JDBC driver file(s)	IoTDB JDBC jar-with-dependencies 插件路径	C:\Users\13361\Documents\GitHub\iotdb\iotdb-client\jdbc\target\iotdb-jdbc-1.3.2-SNAPSHOT-jar-with-dependencies.jar
User name	IoTDB 的用户名	root
User password	IoTDB 的密码	root

点击 Test Connection 按钮，应该显示连接成功。
ODBC_CONFIG_CN.jpg
点击上方的 Preview，将查询文本换为 select * from root.**，点击 Preview Data，应该正确显示查询结果。
ODBC_TEST.jpg

使用 ODBC 操作数据：正确部署后，就可以使用 Windows 的 ODBC 库，对 IoTDB 的数据进行操作。这里给出 C# 语言的代码示例：

using System.Data.Odbc;

// Get a connection
var dbConnection = new OdbcConnection("DSN=ZappySys JDBC Bridge");
dbConnection.Open();

// Execute the write commands to prepare data
var dbCommand = dbConnection.CreateCommand();
dbCommand.CommandText = "insert into root.Keller.Flur.Energieversorgung(time, s1) values(1715670861634, 1)";
dbCommand.ExecuteNonQuery();
dbCommand.CommandText = "insert into root.Keller.Flur.Energieversorgung(time, s2) values(1715670861634, true)";
dbCommand.ExecuteNonQuery();
dbCommand.CommandText = "insert into root.Keller.Flur.Energieversorgung(time, s3) values(1715670861634, 3.1)";
dbCommand.ExecuteNonQuery();

// Execute the read command
dbCommand.CommandText = "SELECT * FROM root.Keller.Flur.Energieversorgung";
var dbReader = dbCommand.ExecuteReader();

// Write the output header
var fCount = dbReader.FieldCount;
Console.Write(":");
for(var i = 0; i < fCount; i++)
{
    var fName = dbReader.GetName(i);
    Console.Write(fName + ":");
}
Console.WriteLine();

// Output the content
while (dbReader.Read())
{
    Console.Write(":");
    for(var i = 0; i < fCount; i++) 
    {
        var fieldType = dbReader.GetFieldType(i);
        switch (fieldType.Name)
        {
            case "DateTime":
                var dateTime = dbReader.GetInt64(i);
                Console.Write(dateTime + ":");
                break;
            case "Double":
                if (dbReader.IsDBNull(i)) 
                {
                    Console.Write("null:");
                }
                else 
                {
                    var fValue = dbReader.GetDouble(i);
                    Console.Write(fValue + ":");
                }   
                break;
            default:
                Console.Write(fieldType.Name + ":");
                break;
        }
    }
    Console.WriteLine();
}

// Shut down gracefully
dbReader.Close();
dbCommand.Dispose();
dbConnection.Close();

运行该程序可以向 IoTDB 内写入数据，并且查询并打印写入的数据。