TDengine Java 连接器快速入门指南

3. 执行 SQL 操作

通过 Statement 或 PreparedStatement 执行查询或写入：

try (Statement stmt = conn.createStatement()) {
    // 创建数据库（可选）
    stmt.execute("CREATE DATABASE IF NOT EXISTS test");
    // 创建表
    stmt.execute("CREATE TABLE IF NOT EXISTS test.meters (ts TIMESTAMP, current FLOAT, voltage INT)");
    // 插入数据
    stmt.executeUpdate("INSERT INTO test.meters VALUES (NOW, 10.2, 219)");
    // 查询数据
    ResultSet rs = stmt.executeQuery("SELECT * FROM test.meters");
    while (rs.next()) {
        Timestamp ts = rs.getTimestamp("ts");
        float current = rs.getFloat("current");
        int voltage = rs.getInt("voltage");
        System.out.println(ts + ", " + current + ", " + voltage);
    }
    rs.close();
}

4. 关键注意事项

批量写入：对于高频写入场景，建议使用 PreparedStatement 批量提交：

String sql = "INSERT INTO test.meters VALUES (?, ?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
    for (int i = 0; i < 1000; i++) {
        pstmt.setTimestamp(1, new Timestamp(System.currentTimeMillis()));
        pstmt.setFloat(2, 10.2f + i);
        pstmt.setInt(3, 220);
        pstmt.addBatch();
    }
    pstmt.executeBatch();
}

时区处理：TDengine 默认使用 UTC 时间。若需本地时区，可在 JDBC URL 中指定：

jdbc:TAOS://...?timezone=UTC+8

5. 资源清理

始终在 finally 块或使用 try-with-resources 关闭资源：

try (Connection conn = DriverManager.getConnection(jdbcUrl);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery("SELECT * FROM test.meters")) {
    // 操作结果集...
} catch (SQLException e) {
    e.printStackTrace();
}

下一步学习建议

• 探索 TDengine Java 连接器文档
• 优化连接池（如 HikariCP）
• 学习 TDengine 的超级表（Super Table）设计模式

通过以上步骤，您已掌握 Java 连接 TDengine 的基础操作，可进一步开发时序数据应用。