From 91258f587eeaf1ccb093c647c4fd2ac05d384d2b Mon Sep 17 00:00:00 2001
From: sheyanjie-qq <249478495@qq.com>
Date: Tue, 30 Jul 2024 09:15:12 +0800
Subject: [PATCH] add jdbc api

---
 docs/zh/14-reference/05-connector/14-java.mdx | 1334 ++++++++++++++++-
 1 file changed, 1332 insertions(+), 2 deletions(-)

diff --git a/docs/zh/14-reference/05-connector/14-java.mdx b/docs/zh/14-reference/05-connector/14-java.mdx
index 3105dbdbb6..3ddc387c91 100644
--- a/docs/zh/14-reference/05-connector/14-java.mdx
+++ b/docs/zh/14-reference/05-connector/14-java.mdx
@@ -63,7 +63,7 @@ REST 连接支持所有能运行 Java 的平台。
 |        2.0.37        |                                                                  增加对 json tag 支持                                                                  |         -          |
 |        2.0.36        |                                                               增加对 schemaless 写入支持                                                               |         -          |
 
-## 处理异常
+## 异常和错误码
 
 在报错后，通过 SQLException 可以获取到错误的信息和错误码：
 
@@ -709,5 +709,1335 @@ consumer.close()
 其它问题请参考 [FAQ](../../train-faq/faq)
 
 ## API 参考
+### JDBC 驱动
+
+taos-jdbcdriver 实现了 JDBC 标准的 Driver 接口，提供了两个实现类：RestfulDriver 和 TSDBDriver。
+Websocket 和 REST 连接使用驱动类 `com.taosdata.jdbc.rs.RestfulDriver`。原生连接使用驱动类 `com.taosdata.jdbc.TSDBDriver`。
+
+
+#### URL 规范
+TDengine 的 JDBC URL 规范格式为：
+`jdbc:[TAOS|TAOS-RS]://[host_name]:[port]/[database_name]?[user={user}|&password={password}|&charset={charset}|&cfgdir={config_dir}|&locale={locale}|&timezone={timezone}]`
+
+对于建立连接，原生连接与 REST 连接有细微不同。 Websocket 和 REST 连接使用驱动类 `com.taosdata.jdbc.rs.RestfulDriver`。原生连接使用驱动类 `com.taosdata.jdbc.TSDBDriver`。
+
+**注**：REST 连接中增加 `batchfetch` 参数并设置为 true，将开启 WebSocket 连接。  
+
+##### 原生连接
+`jdbc:TAOS://taosdemo.com:6030/power?user=root&password=taosdata`，使用了 JDBC 原生连接的 TSDBDriver，建立了到 hostname 为 taosdemo.com，端口为 6030（TDengine 的默认端口），数据库名为 power 的连接。这个 URL
+中指定用户名（user）为 root，密码（password）为 taosdata。
+
+**注意**：使用 JDBC 原生连接，taos-jdbcdriver 需要依赖客户端驱动（Linux 下是 libtaos.so；Windows 下是 taos.dll；macOS 下是 libtaos.dylib）。
+
+对于原生连接 url 中支持的配置参数如下：
+
+- user：登录 TDengine 用户名，默认值 'root'。
+- password：用户登录密码，默认值 'taosdata'。
+- cfgdir：客户端配置文件目录路径，Linux OS 上默认值 `/etc/taos`，Windows OS 上默认值 `C:/TDengine/cfg`。
+- charset：客户端使用的字符集，默认值为系统字符集。
+- locale：客户端语言环境，默认值系统当前 locale。
+- timezone：客户端使用的时区，默认值为系统当前时区。
+- batchfetch: true：在执行查询时批量拉取结果集；false：逐行拉取结果集。默认值为：true。开启批量拉取同时获取一批数据在查询数据量较大时批量拉取可以有效的提升查询性能。
+- batchErrorIgnore：true：在执行 Statement 的 executeBatch 时，如果中间有一条 SQL 执行失败将继续执行下面的 SQL。false：不再执行失败 SQL 后的任何语句。默认值为：false。
+
+JDBC 原生连接的使用请参见[视频教程](https://www.taosdata.com/blog/2020/11/11/1955.html)。  
+
+**使用 TDengine 客户端驱动配置文件建立连接 **
+
+当使用 JDBC 原生连接连接 TDengine 集群时，可以使用 TDengine 客户端驱动配置文件，在配置文件中指定集群的 firstEp、secondEp 等参数。 此时在 JDBC url 中不指定 `hostname` 和 `port`。 
+配置如 `jdbc:TAOS://:/power?user=root&password=taosdata`。  
+在 TDengine 客户端驱动配置文件中指定 firstEp 和 secondEp，jdbc 会使用客户端的配置文件，建立连接。当集群中 firstEp 节点失效时，JDBC 会尝试使用 secondEp 连接集群。
+TDengine 中，只要保证 firstEp 和 secondEp 中一个节点有效，就可以正常建立到集群的连接。
+
+> **注意**：这里的配置文件指的是调用 JDBC Connector 的应用程序所在机器上的配置文件，Linux OS 上默认值 /etc/taos/taos.cfg ，Windows OS 上默认值 C://TDengine/cfg/taos.cfg。
+
+
+##### Websocket 和 REST 连接
+使用 JDBC REST 连接，不需要依赖客户端驱动。与 JDBC 原生连接相比，仅需要：
+
+1. driverClass 指定为“com.taosdata.jdbc.rs.RestfulDriver”；
+2. jdbcUrl 以“jdbc:TAOS-RS://”开头；
+3. 使用 6041 作为连接端口。
+
+对于 Websocket 和 REST 连接，url 中的配置参数如下：
+
+- user：登录 TDengine 用户名，默认值 'root'。
+- password：用户登录密码，默认值 'taosdata'。
+- batchfetch: true：在执行查询时批量拉取结果集；false：逐行拉取结果集。默认值为：false。逐行拉取结果集使用 HTTP 方式进行数据传输。JDBC REST 连接支持批量拉取数据功能。taos-jdbcdriver 与 TDengine 之间通过 WebSocket 连接进行数据传输。相较于 HTTP，WebSocket 可以使 JDBC REST 连接支持大数据量查询，并提升查询性能。
+- charset: 当开启批量拉取数据时，指定解析字符串数据的字符集。
+- batchErrorIgnore：true：在执行 Statement 的 executeBatch 时，如果中间有一条 SQL 执行失败，继续执行下面的 SQL 了。false：不再执行失败 SQL 后的任何语句。默认值为：false。
+- httpConnectTimeout: 连接超时时间，单位 ms， 默认值为 60000。
+- httpSocketTimeout: socket 超时时间，单位 ms，默认值为 60000。仅在 batchfetch 设置为 false 时生效。
+- messageWaitTimeout: 消息超时时间, 单位 ms， 默认值为 60000。 仅在 batchfetch 设置为 true 时生效。
+- useSSL: 连接中是否使用 SSL。
+- httpPoolSize: REST 并发请求大小，默认 20。
+
+**注意**：部分配置项（比如：locale、timezone）在 REST 连接中不生效。
+
+:::note
+
+- 与原生连接方式不同，REST 接口是无状态的。在使用 JDBC REST 连接时，需要在 SQL 中指定表、超级表的数据库名称。
+- 如果在 url 中指定了 dbname，那么，JDBC REST 连接会默认使用/rest/sql/dbname 作为 restful 请求的 url，在 SQL 中不需要指定 dbname。例如：url 为 jdbc:TAOS-RS://127.0.0.1:6041/power，那么，可以执行 sql：`INSERT INTO d1001 USING meters TAGS(2,'California.SanFrancisco') VALUES (NOW, 10.30000, 219, 0.31000)`;  
+
+:::
+
+#### Properties
+
+除了通过指定的 URL 获取连接，还可以使用 Properties 指定建立连接时的参数。
+
+**注意**：
+
+- 应用中设置的 client parameter 为进程级别的，即如果要更新 client 的参数，需要重启应用。这是因为 client parameter 是全局参数，仅在应用程序的第一次设置生效。
+- 以下示例代码基于 taos-jdbcdriver-3.1.0 或以上版本。
+
+```java
+public Connection getConn() throws Exception{
+  Class.forName("com.taosdata.jdbc.TSDBDriver");
+  String jdbcUrl = "jdbc:TAOS://taosdemo.com:6030/power?user=root&password=taosdata";
+  Properties connProps = new Properties();
+  connProps.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
+  connProps.setProperty(TSDBDriver.PROPERTY_KEY_LOCALE, "en_US.UTF-8");
+  connProps.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
+  connProps.setProperty("debugFlag", "135");
+  Connection conn = DriverManager.getConnection(jdbcUrl, connProps);
+  return conn;
+}
+
+public Connection getRestConn() throws Exception{
+  Class.forName("com.taosdata.jdbc.rs.RestfulDriver");
+  String jdbcUrl = "jdbc:TAOS-RS://taosdemo.com:6041/power?user=root&password=taosdata";
+  Properties connProps = new Properties();
+  connProps.setProperty(TSDBDriver.PROPERTY_KEY_BATCH_LOAD, "true");
+  Connection conn = DriverManager.getConnection(jdbcUrl, connProps);
+  return conn;
+}
+```
+
+以上示例，建立一个到 hostname 为 taosdemo.com，端口为 6030/6041，数据库名为 power 的连接。这个连接在 url 中指定了用户名(user)为 root，密码（password）为 taosdata，并在 connProps 中指定了使用的字符集、语言环境、时区、是否开启批量拉取等信息。
+
+properties 中的配置参数如下：
+
+- TSDBDriver.PROPERTY_KEY_USER：登录 TDengine 用户名，默认值 'root'。
+- TSDBDriver.PROPERTY_KEY_PASSWORD：用户登录密码，默认值 'taosdata'。
+- TSDBDriver.PROPERTY_KEY_BATCH_LOAD: true：在执行查询时批量拉取结果集；false：逐行拉取结果集。默认值为：false。
+- TSDBDriver.PROPERTY_KEY_BATCH_ERROR_IGNORE：true：在执行 Statement 的 executeBatch 时，如果中间有一条 SQL 执行失败，继续执行下面的 sq 了。false：不再执行失败 SQL 后的任何语句。默认值为：false。
+- TSDBDriver.PROPERTY_KEY_CONFIG_DIR：仅在使用 JDBC 原生连接时生效。客户端配置文件目录路径，Linux OS 上默认值 `/etc/taos`，Windows OS 上默认值 `C:/TDengine/cfg`。
+- TSDBDriver.PROPERTY_KEY_CHARSET：客户端使用的字符集，默认值为系统字符集。
+- TSDBDriver.PROPERTY_KEY_LOCALE：仅在使用 JDBC 原生连接时生效。 客户端语言环境，默认值系统当前 locale。
+- TSDBDriver.PROPERTY_KEY_TIME_ZONE：仅在使用 JDBC 原生连接时生效。 客户端使用的时区，默认值为系统当前时区。因为历史的原因，我们只支持POSIX标准的部分规范，如UTC-8(代表中国上上海), GMT-8，Asia/Shanghai 这几种形式。
+- TSDBDriver.HTTP_CONNECT_TIMEOUT: 连接超时时间，单位 ms， 默认值为 60000。仅在 REST 连接时生效。
+- TSDBDriver.HTTP_SOCKET_TIMEOUT: socket 超时时间，单位 ms，默认值为 60000。仅在 REST 连接且 batchfetch 设置为 false 时生效。
+- TSDBDriver.PROPERTY_KEY_MESSAGE_WAIT_TIMEOUT: 消息超时时间, 单位 ms， 默认值为 60000。 仅在 REST 连接且 batchfetch 设置为 true 时生效。
+- TSDBDriver.PROPERTY_KEY_USE_SSL: 连接中是否使用 SSL。仅在 REST 连接时生效。
+- TSDBDriver.HTTP_POOL_SIZE: REST 并发请求大小，默认 20。
+- TSDBDriver.PROPERTY_KEY_ENABLE_COMPRESSION: 传输过程是否启用压缩。仅在使用 REST/Websocket 连接时生效。true: 启用，false: 不启用。默认为 false。
+- TSDBDriver.PROPERTY_KEY_ENABLE_AUTO_RECONNECT: 是否启用自动重连。仅在使用 Websocket 连接时生效。true: 启用，false: 不启用。默认为 false。
+> **注意**：启用自动重连仅对简单执行 SQL 语句以及 无模式写入、数据订阅有效。对于参数绑定无效。自动重连仅对连接建立时通过参数指定数据库有效，对后面的 `use db` 语句切换数据库无效。
+
+- TSDBDriver.PROPERTY_KEY_RECONNECT_INTERVAL_MS: 自动重连重试间隔，单位毫秒，默认值 2000。仅在 PROPERTY_KEY_ENABLE_AUTO_RECONNECT 为 true 时生效。
+- TSDBDriver.PROPERTY_KEY_RECONNECT_RETRY_COUNT: 自动重连重试次数，默认值 3，仅在 PROPERTY_KEY_ENABLE_AUTO_RECONNECT 为 true 时生效。
+- TSDBDriver.PROPERTY_KEY_DISABLE_SSL_CERT_VALIDATION: 关闭 SSL 证书验证 。仅在使用 Websocket 连接时生效。true: 启用，false: 不启用。默认为 false。
+
+
+此外对 JDBC 原生连接，通过指定 URL 和 Properties 还可以指定其他参数，比如日志级别、SQL 长度等。更多详细配置请参考[客户端配置](../../reference/config/)。
+
+##### 配置参数的优先级
+
+通过前面三种方式获取连接，如果配置参数在 url、Properties、客户端配置文件中有重复，则参数的`优先级由高到低`分别如下：
+
+1. JDBC URL 参数，如上所述，可以在 JDBC URL 的参数中指定。
+2. Properties connProps
+3. 使用原生连接时，TDengine 客户端驱动的配置文件 taos.cfg
+
+例如：在 url 中指定了 password 为 taosdata，在 Properties 中指定了 password 为 taosdemo，那么，JDBC 会使用 url 中的 password 建立连接。
+
+#### 接口说明  
+
+- `Connection connect(String url, java.util.Properties info) throws SQLException`
+  - **接口说明**：连接 TDengine 数据库
+  - **参数说明**：
+    - `url`：连接地址 url，详见上文 URL 规范
+    - `info`：连接属性，详见上文 Properties 章节
+  - **返回值**：连接对象
+  - **异常**：连接失败抛出 `SQLException` 异常
+
+- `boolean acceptsURL(String url) throws SQLException`
+  - **接口说明**：判断驱动是否支持 url
+  - **参数说明**：
+    - `url`：连接地址 url
+  - **返回值**：`true`：支持，`false`：不支持
+  - **异常**：url 非法抛出 `SQLException` 异常
+
+- `DriverPropertyInfo[] getPropertyInfo(String url, java.util.Properties info) throws SQLException`
+  - **接口说明**：获取尝试连接数据库时可能需要的所有属性的详细信息。这些属性信息被封装在 DriverPropertyInfo 对象数组中返回。每个 DriverPropertyInfo 对象包含了一个数据库连接属性的详细信息，比如属性名、属性值、描述等
+  - **参数说明**：
+    - `url`：一个 String 类型的参数，表示数据库的 URL
+    - `info`：一个 java.util.Properties 类型的参数，包含了尝试连接时用户可能提供的属性列表
+  - **返回值**：返回值类型为 `DriverPropertyInfo[]`，即 `DriverPropertyInfo` 对象的数组。每个 `DriverPropertyInfo` 对象包含了一个特定的数据库连接属性的详细信息
+  - **异常**：如果在获取属性信息的过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常
+
+- `int getMajorVersion()`
+  - **接口说明**：获取 JDBC 驱动程序的主版本号
+
+- `int getMinorVersion()`
+  - **接口说明**：获取 JDBC 驱动程序的次版本号
+
+### 数据库元数据
+`DatabaseMetaData` 是 JDBC API 的一部分，它提供了关于数据库的元数据的详细信息，元数据意味着关于数据库数据的数据。通过 `DatabaseMetaData` 接口，可以查询数据库服务器的详细信息，比如数据库产品名称、版本、已安装的功能、表、视图、存储过程的列表等。这对于了解和适应不同数据库的特性非常有用。
+
+
+- `String getURL() throws SQLException`
+  - **接口说明**：获取用于连接数据库的 URL
+  - **返回值**：连接数据库的 URL
+  - **异常**：获取失败将抛出 `SQLException` 异常
+
+- `String getUserName() throws SQLException`
+  - **接口说明**：获取用于连接获取数据库的用户名
+  - **返回值**：连接数据库的用户名
+  - **异常**：获取失败将抛出 `SQLException` 异常
+
+- `String getDriverName() throws SQLException`
+  - **接口说明**：获取 JDBC 驱动程序的名称
+  - **返回值**：驱动名称字符串
+  - **异常**：获取失败将抛出 `SQLException` 异常
+
+- `String getDriverVersion() throws SQLException`
+  - **接口说明**：获取 JDBC 驱动版本
+  - **返回值**：驱动版本字符串
+  - **异常**：获取失败将抛出 `SQLException` 异常
+
+- `int getDriverMajorVersion()`
+  - **接口说明**：获取 JDBC 驱动主版本号
+
+- `int getDriverMinorVersion()`
+  - **接口说明**：获取 JDBC 驱动次版本号
+
+- `String getDatabaseProductName() throws SQLException`
+  - **接口说明**：获取数据库产品的名称
+
+- `String getDatabaseProductVersion() throws SQLException`
+  - **接口说明**：获取数据库产品的版本号
+
+- `String getIdentifierQuoteString() throws SQLException`
+  - **接口说明**：获取用于引用 SQL 标识符的字符串
+
+- `String getSQLKeywords() throws SQLException`
+  - **接口说明**：获取数据库特有的 SQL 关键字列表
+
+- `String getNumericFunctions() throws SQLException`
+  - **接口说明**：获取数据库支持的数值函数名称列表
+
+- `String getStringFunctions() throws SQLException`
+  - **接口说明**：获取数据库支持的字符串函数名称列表
+
+- `String getSystemFunctions() throws SQLException`
+  - **接口说明**：获取数据库支持的系统函数名称列表
+
+- `String getTimeDateFunctions() throws SQLException`
+  - **接口说明**：获取数据库支持的时间日期函数名称列表
+
+- `String getCatalogTerm() throws SQLException`
+  - **接口说明**：获取数据库中目录的术语
+
+- `String getCatalogSeparator() throws SQLException`
+  - **接口说明**：获取用于分隔目录和表名的分隔符
+
+- `int getDefaultTransactionIsolation() throws SQLException`
+  - **接口说明**：获取数据库的默认事务隔离级别
+
+- `boolean supportsTransactionIsolationLevel(int level) throws SQLException`
+  - **接口说明**：判断数据库是否支持给定的事务隔离级别
+  - **参数说明**：
+    - `level`：事务隔离级别
+  - **返回值**：`true`：支持，`false`：不支持
+  - **异常**：操作失败抛出 `SQLException` 异常
+
+- `ResultSet getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types) throws SQLException`
+  - **接口说明**：获取数据库中匹配指定模式的表信息
+  - **参数说明**：
+    - `catalog`：目录名称；`null` 表示不指定目录
+    - `schemaPattern`：模式名称的模式；null 表示不指定模式
+    - `tableNamePattern`：表名称的模式
+    - `types`：表类型列表，返回指定类型的表
+  - **返回值**：包含表信息的 `ResultSet`
+  - **异常**：操作失败抛出 `SQLException` 异常
+
+- `ResultSet getCatalogs() throws SQLException`
+  - **接口说明**：获取数据库中所有目录的信息
+  - **返回值**：包含目录信息的 `ResultSet`
+  - **异常**：操作失败抛出 `SQLException` 异常
+
+- `ResultSet getTableTypes() throws SQLException`
+  - **接口说明**：获取数据库支持的表类型
+  - **返回值**：包含表类型的 `ResultSet`
+  - **异常**：操作失败抛出 `SQLException` 异常
+
+- `ResultSet getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) throws SQLException`
+  - **接口说明**：获取指定表中匹配指定模式的列信息
+  - **参数说明**：
+    - `catalog`：目录名称；`null` 表示不指定目录
+    - `schemaPattern`：模式名称的模式；`null` 表示不指定模式
+    - `tableNamePattern`：表名称的模式
+    - `columnNamePattern`：列名称的模式
+  - **返回值**：包含列信息的 `ResultSet`
+  - **异常**：操作失败抛出 `SQLException` 异常
+
+- `ResultSet getPrimaryKeys(String catalog, String schema, String table) throws SQLException`
+  - **接口说明**：获取指定表的主键信息
+  - **参数说明**：
+    - `catalog`：目录名称；`null` 表示不指定目录
+    - `schema`：模式名称；`null` 表示不指定模式
+    - `table`：表名称
+  - **返回值**：包含主键信息的 `ResultSet`
+  - **异常**：操作失败抛出 `SQLException` 异常
+
+- `Connection getConnection() throws SQLException`
+  - **接口说明**：获取数据库连接。
+  - **返回值**：数据库连接 `Connection` 对象。
+  - **异常**：获取连接失败抛出 `SQLException` 异常。
+
+- `ResultSet getSuperTables(String catalog, String schemaPattern, String tableNamePattern) throws SQLException`
+  - **接口说明**：获取指定表的父表信息。
+  - **参数说明**：
+    - `catalog`：目录名称；`null` 表示不指定目录。
+    - `schemaPattern`：模式名称的模式；`null` 表示不指定模式。
+    - `tableNamePattern`：表名称的模式。
+  - **返回值**：包含父表信息的 `ResultSet`。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+
+- `boolean supportsResultSetHoldability(int holdability) throws SQLException`
+  - **接口说明**：判断数据库是否支持给定的 `ResultSet` 持有性。
+  - **参数说明**：
+    - `holdability`：`ResultSet` 的持有性。
+  - **返回值**：`true`：支持，`false`：不支持。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+
+- `int getSQLStateType() throws SQLException`
+  - **接口说明**：获取数据库使用的 SQLSTATE 类型。
+  - **返回值**：SQLSTATE 类型代码。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+
+支持类接口返回 `true` 的接口列表，其余返回 `false` 的接口不再赘述。
+
+| 接口方法                                       | 说明                                         |
+|--------------------------------------------|--------------------------------------------|
+| `boolean nullsAreSortedAtStart()` | 判断 `NULL` 值是否被排序在前                           |
+| `boolean storesLowerCaseIdentifiers()` | 判断数据库是否将标识符存储为小写                        |
+| `boolean supportsAlterTableWithAddColumn()` | 判断数据库是否支持使用 `ALTER TABLE` 添加列             |
+| `boolean supportsAlterTableWithDropColumn()` | 判断数据库是否支持使用 `ALTER TABLE` 删除列             |
+| `boolean supportsColumnAliasing()` | 判断数据库是否支持列别名                             |
+| `boolean supportsGroupBy()` | 判断数据库是否支持 `GROUP BY` 语句                   |
+| `boolean isCatalogAtStart()` | 判断在数据库中目录名是否出现在完全限定名的开头             |
+| `boolean supportsCatalogsInDataManipulation()` | 判断数据库在数据操作语句中是否支持目录名                  |  
+
+
+### 连接功能
+
+JDBC 驱动支持创建连接，返回支持 JDBC 标准的 `Connection` 接口的对象，还提供了 `AbstractConnection` 接口，扩充了一些无模式写入接口。
+
+#### 标准接口
+
+- `Statement createStatement() throws SQLException`
+  - **接口说明**：创建一个 `Statement` 对象来执行 SQL 语句。`Statement` 接口详细说明见下文 执行SQL。
+  - **返回值**：创建的 `Statement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `PreparedStatement prepareStatement(String sql) throws SQLException`
+  - **接口说明**：创建一个 `PreparedStatement` 对象来执行给定的 SQL 语句，`PreparedStatement` 接口详细说明见下文 执行SQL。
+  - **参数说明**：
+    - `sql`：预编译的 SQL 语句。
+  - **返回值**：创建的 `PreparedStatement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `String nativeSQL(String sql) throws SQLException`
+  - **接口说明**：将 SQL 语句转换为数据库特定的 SQL 语法。
+  - **参数说明**：
+    - `sql`：要转换的 SQL 语句。
+  - **返回值**：转换后的 SQL 语句。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `void close() throws SQLException`
+  - **接口说明**：关闭数据库连接。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `boolean isClosed() throws SQLException`
+  - **接口说明**：判断数据库连接是否已关闭。
+  - **返回值**：`true`：已关闭，`false`：未关闭。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `DatabaseMetaData getMetaData() throws SQLException`
+  - **接口说明**：获取数据库的元数据。
+  - **返回值**：数据库的元数据。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `void setCatalog(String catalog) throws SQLException`
+  - **接口说明**：设置当前连接的默认数据库。
+  - **参数说明**：
+    - `catalog`：要设置的数据库名称。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `String getCatalog() throws SQLException`
+  - **接口说明**：获取当前连接的默认数据库。
+  - **返回值**：当前连接的目录名称。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException`
+  - **接口说明**：创建一个 `Statement` 对象，指定 `ResultSet` 类型和并发模式。
+  - **参数说明**：
+    - `resultSetType`：`ResultSet` 类型。
+    - `resultSetConcurrency`：并发模式。
+  - **返回值**：创建的 `Statement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException`
+  - **接口说明**：创建一个 `Statement` 对象，指定 `ResultSet` 类型、并发模式和持有性。
+  - **参数说明**：
+    - `resultSetType`：`ResultSet` 类型。
+    - `resultSetConcurrency`：并发模式。
+    - `resultSetHoldability`：持有性。
+  - **返回值**：创建的 `Statement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException`
+  - **接口说明**：创建一个 `PreparedStatement` 对象，指定 SQL、`ResultSet` 类型和并发模式。
+  - **参数说明**：
+    - `sql`：预编译的 SQL 语句。
+    - `resultSetType`：`ResultSet` 类型。
+    - `resultSetConcurrency`：并发模式。
+  - **返回值**：创建的 `PreparedStatement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException`
+  - **接口说明**：创建一个 `PreparedStatement` 对象，指定 SQL、`ResultSet` 类型、并发模式和持有性。
+  - **参数说明**：
+    - `sql`：预编译的 SQL 语句。
+    - `resultSetType`：`ResultSet` 类型。
+    - `resultSetConcurrency`：并发模式。
+    - `resultSetHoldability`：持有性。
+  - **返回值**：创建的 `PreparedStatement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException`
+  - **接口说明**：创建一个 `PreparedStatement` 对象，指定 SQL 语句和自动生成键的标志。
+  - **参数说明**：
+    - `sql`：预编译的 SQL 语句。
+    - `autoGeneratedKeys`：指示是否应生成自动键的标志。
+  - **返回值**：创建的 `PreparedStatement` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `void setHoldability(int holdability) throws SQLException`
+  - **接口说明**：设置 `ResultSet` 对象的默认持有性。
+  - **参数说明**：
+    - `holdability`：`ResultSet` 的持有性。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `int getHoldability() throws SQLException`
+  - **接口说明**：获取 `ResultSet` 对象的默认持有性。
+  - **返回值**：`ResultSet` 的持有性。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `boolean isValid(int timeout) throws SQLException`
+  - **接口说明**：检测数据库连接是否有效。
+  - **参数说明**：
+    - `timeout`：等待有效性检查的超时时间，单位秒。
+  - **返回值**：`true`：连接有效，`false`：连接无效。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `void setClientInfo(String name, String value) throws SQLClientInfoException`
+  - **接口说明**：设置客户端信息属性。
+  - **参数说明**：
+    - `name`：属性名。
+    - `value`：属性值。
+  - **异常**：设置失败抛出 `SQLClientInfoException` 异常。
+- `void setClientInfo(Properties properties) throws SQLClientInfoException`
+  - **接口说明**：设置一组客户端信息属性。
+  - **参数说明**：
+    - `properties`：属性集合。
+  - **异常**：设置失败抛出 `SQLClientInfoException` 异常。
+- `String getClientInfo(String name) throws SQLException`
+  - **接口说明**：获取指定的客户端信息属性值。
+  - **参数说明**：
+    - `name`：属性名。
+  - **返回值**：属性值。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+- `Properties getClientInfo() throws SQLException`
+  - **接口说明**：获取所有客户端信息属性。
+  - **返回值**：包含所有客户端信息属性的 `Properties` 对象。
+  - **异常**：操作失败抛出 `SQLException` 异常。
+
+
+#### 无模式写入
+
+注：下面 abstract 类型接口会被具体实现类实现，因此建立连接后得到连接对象可以直接调用。
+
+- `public abstract void write(String[] lines, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType, Integer ttl, Long reqId) throws SQLException`
+  - **接口说明**：以指定的协议类型、时间戳类型、TTL（生存时间）和请求 ID 写入多行数据。
+  - **参数说明**：
+    - `lines`：待写入的数据行数组。
+    - `protocolType`：协议类型：支持 LINE， TELNET， JSON 三种。
+    - `timestampType`：时间戳类型，支持 HOURS，MINUTES，SECONDS，MILLI_SECONDS，MICRO_SECONDS 和 NANO_SECONDS。
+    - `ttl`：数据的生存时间，单位天。
+    - `reqId`：请求 ID。
+  - **异常**：操作失败抛出 SQLException 异常。
+- `public void write(String[] lines, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException`
+  - **接口说明**：以指定的协议类型和时间戳类型写入多行数据。
+  - **参数说明**：
+    - `lines`：待写入的数据行数组。
+    - `protocolType`：协议类型：支持 LINE， TELNET， JSON 三种。
+    - `timestampType`：时间戳类型，支持 HOURS，MINUTES，SECONDS，MILLI_SECONDS，MICRO_SECONDS 和 NANO_SECONDS。
+  - **异常**：操作失败抛出 SQLException 异常。
+- `public void write(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException`
+  - **接口说明**：以指定的协议类型和时间戳类型写入单行数据。
+  - **参数说明**：
+    - `line`：待写入的数据行。
+    - `protocolType`：协议类型：支持 LINE， TELNET， JSON 三种。
+    - `timestampType`：时间戳类型，支持 HOURS，MINUTES，SECONDS，MILLI_SECONDS，MICRO_SECONDS 和 NANO_SECONDS。
+  - **异常**：操作失败抛出 SQLException 异常。
+- `public void write(List<String> lines, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException`
+  - **接口说明**：以指定的协议类型和时间戳类型写入多行数据（使用列表）。
+  - **参数说明**：
+    - `lines`：待写入的数据行列表。
+    - `protocolType`：协议类型：支持 LINE， TELNET， JSON 三种。
+    - `timestampType`：时间戳类型，支持 HOURS，MINUTES，SECONDS，MILLI_SECONDS，MICRO_SECONDS 和 NANO_SECONDS。
+  - **异常**：操作失败抛出 SQLException 异常。
+- `public int writeRaw(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException`
+  - **接口说明**：以指定的协议类型和时间戳类型写入多行回车符分割的原始数据，回车符分割，并返回操作结果。
+  - **参数说明**：
+    - `line`：待写入的原始数据。
+    - `protocolType`：协议类型：支持 LINE， TELNET， JSON 三种。
+    - `timestampType`：时间戳类型，支持 HOURS，MINUTES，SECONDS，MILLI_SECONDS，MICRO_SECONDS 和 NANO_SECONDS。
+  - **返回值**：操作结果。
+  - **异常**：操作失败抛出 SQLException 异常。
+- `public abstract int writeRaw(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType, Integer ttl, Long reqId) throws SQLException`
+  - **接口说明**：以指定的协议类型、时间戳类型、TTL（生存时间）和请求 ID 写入多行回车符分割的原始数据，并返回操作结果。
+  - **参数说明**：
+    - `line`：待写入的原始数据。
+    - `protocolType`：协议类型：支持 LINE， TELNET， JSON 三种。
+    - `timestampType`：时间戳类型，支持 HOURS，MINUTES，SECONDS，MILLI_SECONDS，MICRO_SECONDS 和 NANO_SECONDS。
+    - `ttl`：数据的生存时间，单位天。
+    - `reqId`：请求 ID。
+  - **返回值**：操作结果。
+  - **异常**：操作失败抛出 SQLException 异常。
+
+### 执行 SQL
+
+JDBC 驱动提供了符合 JDBC 标准的 `Statement` 接口，支持以下功能：
+
+1. **执行 SQL 语句**：`Statement` 接口主要用于执行静态 SQL 语句，并返回其生成的结果对象。
+2. **查询执行**：可以执行返回数据集的查询（`SELECT` 语句）。
+3. **更新执行**：可以执行影响行数的 SQL 语句，如 `INSERT`、`UPDATE`、`DELETE` 等。
+4. **批量执行**：支持批量执行多个 SQL 语句，以提高应用程序运行效率。
+5. **获取结果**：可以获取查询执行后返回的结果集（`ResultSet` 对象），并遍历查询返回的数据。
+6. **获取更新计数**：对于非查询 SQL 语句，可以获取执行后影响的行数。
+7. **关闭资源**：提供了关闭 `Statement` 对象的方法，以释放数据库资源。
+
+另外 JDBC 驱动还提供了用于请求链路跟踪的扩展接口。
+
+#### 标准接口  
+
+- `ResultSet executeQuery(String sql) throws SQLException`
+  - **接口说明**：执行给定的 SQL 语句，该语句返回单个 `ResultSet` 对象。
+  - **参数说明**：
+    - `sql`：要执行的 SQL 查询语句。
+  - **返回值**：查询结果集 `ResultSet`。
+  - **异常**：执行查询过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int executeUpdate(String sql) throws SQLException`
+  - **接口说明**：执行给定的 SQL 语句，可以是 `INSERT` 或 `DELETE` 语句，或不返回任何内容的 SQL 语句。
+  - **参数说明**：
+    - `sql`：要执行的 SQL 更新语句。
+  - **返回值**：受影响的行数。
+  - **异常**：执行更新过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `void close() throws SQLException`
+  - **接口说明**：立即释放此 `Statement` 对象的数据库和 JDBC 资源。
+  - **异常**：关闭过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getMaxFieldSize() throws SQLException`
+  - **接口说明**：获取可以在 `ResultSet` 对象中读取的最大字符和二进制列值的字节数。
+  - **返回值**：最大列大小。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getQueryTimeout() throws SQLException`
+  - **接口说明**：获取当前 `Statement` 对象的查询超时时间。
+  - **返回值**：查询超时时间（以秒为单位）。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `void setQueryTimeout(int seconds) throws SQLException`
+  - **接口说明**：设置当前 `Statement` 对象的查询超时时间。
+  - **参数说明**：
+    - `seconds`：查询超时时间（以秒为单位）。
+  - **异常**：设置过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `boolean execute(String sql) throws SQLException`
+  - **接口说明**：执行给定的 SQL 语句，该语句可能返回多个结果。
+  - **参数说明**：
+    - `sql`：要执行的 SQL 语句。
+  - **返回值**：`true` 表示返回的是 `ResultSet` 对象；`false` 表示返回的是更新计数或没有结果。
+  - **异常**：执行过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `ResultSet getResultSet() throws SQLException`
+  - **接口说明**：获取当前 `Statement` 对象生成的 `ResultSet` 对象。
+  - **返回值**：当前 `Statement` 对象生成的结果集。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getUpdateCount() throws SQLException`
+  - **接口说明**：获取当前 `Statement` 对象执行的更新计数。
+  - **返回值**：受影响的行数；如果当前结果是 `ResultSet` 对象或没有结果，则返回 -1。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `boolean getMoreResults() throws SQLException`
+  - **接口说明**：移动到当前 `Statement` 对象的下一个结果，检查它是否为 `ResultSet` 对象。
+  - **返回值**：`true` 表示下一个结果是 `ResultSet` 对象；`false` 表示下一个结果是更新计数或没有更多结果。
+  - **异常**：移动过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getFetchDirection() throws SQLException`
+  - **接口说明**：获取 `Statement` 对象从数据库中获取行的方向。
+  - **返回值**：获取行的方向，TDengine 只支持 `FETCH_FORWARD` 方向。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `void setFetchSize(int rows) throws SQLException`
+  - **接口说明**：提示 JDBC 驱动程序每次从数据库中获取多少行。
+  - **参数说明**：
+    - `rows`：每次获取的行数。
+  - **异常**：设置过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getFetchSize() throws SQLException`
+  - **接口说明**：获取 `Statement` 对象的默认获取大小。
+  - **返回值**：默认的获取大小。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getResultSetConcurrency() throws SQLException`
+  - **接口说明**：获取 `ResultSet` 对象的并发模式。
+  - **返回值**：`ResultSet` 对象的并发模式。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getResultSetType() throws SQLException`
+  - **接口说明**：获取 `ResultSet` 对象的类型。
+  - **返回值**：`ResultSet` 对象的类型。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `void addBatch(String sql) throws SQLException`
+  - **接口说明**：将给定的 SQL 语句添加到当前 `Statement` 对象的批处理中。
+  - **参数说明**：
+    - `sql`：要添加到批处理中的 SQL 语句。
+  - **异常**：添加过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `void clearBatch() throws SQLException`
+  - **接口说明**：清空当前 `Statement` 对象的批处理。
+  - **异常**：清空过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int[] executeBatch() throws SQLException`
+  - **接口说明**：执行批处理中的所有 SQL 语句。
+  - **返回值**：批处理中每个 SQL 语句影响的行数。
+  - **异常**：执行过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `Connection getConnection() throws SQLException`
+  - **接口说明**：获取产生此 `Statement` 对象的 `Connection` 对象。
+  - **返回值**：产生此 `Statement` 对象的数据库连接。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `int getResultSetHoldability() throws SQLException`
+  - **接口说明**：获取 `ResultSet` 对象的可保持性。
+  - **返回值**：`ResultSet` 对象的可保持性。
+  - **异常**：获取过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+- `boolean isClosed() throws SQLException`
+  - **接口说明**：检查此 `Statement` 对象是否已关闭。
+  - **返回值**：`true` 表示此 `Statement` 对象已关闭；`false` 表示未关闭。
+  - **异常**：检查过程中发生数据库访问错误或其他错误，将抛出 `SQLException` 异常。
+
+#### 扩展接口
+扩展接口主要用于请求链路跟踪。
+
+- `ResultSet executeQuery(String sql, Long reqId) throws SQLException`
+  - **接口说明**：执行给定的 SQL 查询语句
+  - **参数说明**：
+    - `sql`：要执行的 SQL 查询语句
+    - `reqId`：请求 id
+  - **返回值**：包含查询结果的 `ResultSet` 对象
+  - **异常**：执行查询失败抛出 `SQLException` 异常
+
+- `int executeUpdate(String sql, Long reqId) throws SQLException`
+  - **接口说明**：执行给定的 SQL 更新语句
+  - **参数说明**：
+    - `sql`：要执行的 SQL 更新语句
+    - `reqId`：请求 id
+  - **返回值**：表示受影响的行数
+  - **异常**：执行更新失败抛出 `SQLException` 异常
+
+- `boolean execute(String sql, Long reqId) throws SQLException`
+  - **接口说明**：执行给定的 SQL 语句，该语句可能是 INSERT、UPDATE、DELETE 或者 DDL 语句
+  - **参数说明**：
+    - `sql`：要执行的 SQL 语句
+    - `reqId`：请求 id
+  - **返回值**：如果第一个结果是 `ResultSet` 对象，则返回 `true`；如果是更新计数或者没有结果，则返回 `false`
+  - **异常**：执行语句失败抛出 `SQLException` 异常
+
+
+### 结果获取
+JDBC 驱动支持标准的 ResultSet 接口，以及对应的结果集元数据 ResultSetMetaData 接口，提供了用于读取结果集中元数据和数据的方法。
+
+#### 结果集
+JDBC 驱动支持标准的 ResultSet 接口，提供了用于读取结果集中元数据和数据的方法。
+- `ResultSetMetaData getMetaData() throws SQLException`
+  - **接口说明**：获取此 ResultSet 对象的列的数量、类型和属性。
+  - **返回值**：此 ResultSet 对象的数据的 ResultSetMetaData 对象。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `boolean next() throws SQLException`
+  - **接口说明**：将光标从当前位置向前移动一行。用于遍历查询结果集。
+  - **返回值**：如果新的当前行有效，则返回 true；如果结果集中没有更多行，则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `void close() throws SQLException`
+  - **接口说明**：立即释放此 ResultSet 对象的数据库和 JDBC 资源，而不是等待该对象自动关闭时的资源释放。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `boolean wasNull() throws SQLException`
+  - **接口说明**：报告上一次读取的列值是否为 NULL。
+  - **返回值**：如果上一次读取的列值是 NULL，则返回 true；否则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `String getString(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java String 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号，第一列是 1，第二列是 2，以此类推。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `boolean getBoolean(int columnIndex) throws SQLException`
+  - **接口说明**：获取指定列的值作为 Java boolean。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：如果指定列的值为 true，则返回 true；如果值为 false 或 NULL，则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `byte getByte(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java byte 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `short getShort(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java short 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `int getInt(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java int 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `long getLong(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java long 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 0L。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `float getFloat(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java float 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 0.0f。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `double getDouble(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java double 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 0.0d。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `byte[] getBytes(int columnIndex) throws SQLException`
+  - **接口说明**：以字节数组的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值作为字节数组；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `Date getDate(int columnIndex) throws SQLException`
+  - **接口说明**：获取指定列的值作为 `java.sql.Date` 对象。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的日期值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `Time getTime(int columnIndex) throws SQLException`
+  - **接口说明**：获取指定列的值作为 `java.sql.Time` 对象。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的时间值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `Timestamp getTimestamp(int columnIndex) throws SQLException`
+  - **接口说明**：以 `java.sql.Timestamp` 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的时间戳值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `String getNString(int columnIndex) throws SQLException`
+  - **接口说明**：获取指定列的值作为 Java String。此方法用于读取 NCHAR、NVARCHAR 和 LONGNVARCHAR 类型的列，以支持国际化字符集。
+  - **参数说明**：
+    - `columnIndex`：要获取其值的列的编号（从 1 开始）。
+  - **返回值**：指定列的值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `Object getObject(int columnIndex) throws SQLException`
+  - **接口说明**：以 Java Object 的形式获取指定列的值。
+  - **参数说明**：
+    - `columnIndex`：列的编号。
+  - **返回值**：返回指定列的值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `String getString(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java String 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `boolean getBoolean(String columnLabel) throws SQLException`
+  - **接口说明**：获取指定列名的值作为 Java boolean。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：如果指定列名的值为 true，则返回 true；如果值为 false 或 NULL，则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `byte getByte(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java byte 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `short getShort(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java short 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `int getInt(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java int 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `long getLong(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java long 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 0L。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `float getFloat(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java float 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 0.0f。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+- `double getDouble(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java double 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 0.0d。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `byte[] getBytes(String columnLabel) throws SQLException`
+  - **接口说明**：以字节数组的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值作为字节数组；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `Date getDate(String columnLabel) throws SQLException`
+  - **接口说明**：获取指定列名的值作为 `java.sql.Date` 对象。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的日期值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `Time getTime(String columnLabel) throws SQLException`
+  - **接口说明**：获取指定列名的值作为 `java.sql.Time` 对象。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的时间值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `Timestamp getTimestamp(String columnLabel) throws SQLException`
+  - **接口说明**：以 `java.sql.Timestamp` 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的时间戳值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `String getNString(String columnLabel) throws SQLException`
+  - **接口说明**：获取指定列名的值作为 Java String。此方法用于读取 NCHAR、NVARCHAR 和 LONGNVARCHAR 类型的列，以支持国际化字符集。
+  - **参数说明**：
+    - `columnLabel`：要获取其值的列的标签名。
+  - **返回值**：指定列名的值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `Object getObject(String columnLabel) throws SQLException`
+  - **接口说明**：以 Java Object 的形式获取指定列名的值。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：返回指定列名的值；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `int findColumn(String columnLabel) throws SQLException`
+  - **接口说明**：获取给定列名的列编号。
+  - **参数说明**：
+    - `columnLabel`：列的标签名。
+  - **返回值**：给定列名的列编号。
+  - **异常**：如果列名不存在或发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `boolean isBeforeFirst() throws SQLException`
+  - **接口说明**：判断光标是否在第一行之前。
+  - **返回值**：如果光标在第一行之前，则返回 true；否则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `boolean isAfterLast() throws SQLException`
+  - **接口说明**：判断光标是否在最后一行之后。
+  - **返回值**：如果光标在最后一行之后，则返回 true；否则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `boolean isFirst() throws SQLException`
+  - **接口说明**：判断光标是否在第一行。
+  - **返回值**：如果光标在第一行，则返回 true；否则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `boolean isLast() throws SQLException`
+  - **接口说明**：判断光标是否在最后一行。
+  - **返回值**：如果光标在最后一行，则返回 true；否则返回 false。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `int getRow() throws SQLException`
+  - **接口说明**：获取当前光标所在行的行号。
+  - **返回值**：当前光标所在行的行号；如果光标在结果集外，则返回 0。
+  - **异常**：如果发生数据库访问错误，将抛出 `SQLException` 异常。
+
+- `void setFetchSize(int rows) throws SQLException`
+  - **接口说明**：设置数据库返回结果集的行数大小。此方法用于指导数据库驱动程序每次从数据库服务器获取的行数，以减少通信次数或限制内存使用。
+  - **参数说明**：
+    - `rows`：指定的获取行数大小。如果设置为 0，则表示使用驱动程序的默认值。
+  - **异常**：如果结果集已关闭 或 rows 参数小于 0，将抛出 `SQLException` 异常。
+
+- `int getFetchSize() throws SQLException`
+  - **接口说明**：获取当前结果集的 fetch size。
+  - **返回值**：当前结果集的 fetch size。
+  - **异常**：如果结果集已关闭，将抛出 `SQLException` 异常。
+
+- `int getType() throws SQLException`
+  - **接口说明**：获取 `ResultSet` 的类型。
+  - **返回值**：`ResultSet` 的类型。总是返回 `ResultSet.TYPE_FORWARD_ONLY`，表示结果集的游标只能向前移动。
+  - **异常**：如果结果集已关闭，将抛出 `SQLException` 异常。
+
+- `int getConcurrency() throws SQLException`
+  - **接口说明**：获取 `ResultSet` 的并发模式。
+  - **返回值**：`ResultSet` 的并发模式。总是返回 `ResultSet.CONCUR_READ_ONLY`，表示结果集不能被更新。
+  - **异常**：如果结果集已关闭，将抛出 `SQLException` 异常。
+
+- `<T> T getObject(String columnLabel, Class<T> type) throws SQLException`
+  - **接口说明**：根据列标签和返回类型的 Class 对象，获取指定列的值。这允许用户以更灵活的方式，根据需要将列值直接转换为相应的类型。
+  - **参数说明**：
+    - `columnLabel`：要获取其值的列的标签名。
+    - `type`：期望返回值的 Java 类型的 Class 对象。
+  - **返回值**：指定列的值，以指定的类型返回；如果值是 NULL，则返回 null。
+  - **异常**：如果发生数据库访问错误，或者指定的类型转换不支持，将抛出 `SQLException` 异常。
+
+#### 结果集元数据
+
+`ResultSetMetaData` 提供了获取结果集元数据的接口。`ResultSetMetaData` 类型的对象通过 `ResultSet` 类型对象的 `getMetaData` 接口获取。
+- `int getColumnCount() throws SQLException`
+  - **接口说明**：获取结果集中列的总数。
+  - **返回值**：结果集中列的数量。
+- `boolean isSearchable(int column) throws SQLException`
+  - **接口说明**：判断指定列是否可以用于 WHERE 子句中。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：如果指定列可以用于搜索，则返回 true；否则返回 false。
+- `int isNullable(int column) throws SQLException`
+  - **接口说明**：判断指定列的值是否可以为 null。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列值是否可为 null 的情况，会返回 `ResultSetMetaData.columnNoNulls`、`ResultSetMetaData.columnNullable` 或 `ResultSetMetaData.columnNullableUnknown`。
+- `boolean isSigned(int column) throws SQLException`
+  - **接口说明**：判断指定列的值是否为有符号数。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：如果列值为有符号数，则返回 true；否则返回 false。
+- `int getColumnDisplaySize(int column) throws SQLException`
+  - **接口说明**：获取指定列的最大标准宽度，以字符为单位。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列的最大宽度。
+  - **异常**：如果列索引超出范围，将抛出 `SQLException` 异常。
+- `String getColumnLabel(int column) throws SQLException`
+  - **接口说明**：获取指定列的建议标题，用于打印输出和显示用途。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列的建议标题。
+  - **异常**：如果列索引超出范围，将抛出 `SQLException` 异常。
+- `String getColumnName(int column) throws SQLException`
+  - **接口说明**：获取指定列的名称。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列的名称。
+  - **异常**：如果列索引超出范围，将抛出 `SQLException` 异常。
+- `int getPrecision(int column) throws SQLException`
+  - **接口说明**：获取指定列的最大精度。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列的最大精度。
+  - **异常**：如果列索引超出范围，将抛出 `SQLException` 异常。
+- `int getScale(int column) throws SQLException`
+  - **接口说明**：获取指定列的小数点右侧的位数。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列的小数位数。
+  - **异常**：如果列索引超出范围，将抛出 `SQLException` 异常。
+- `String getTableName(int column) throws SQLException`
+  - **接口说明**：获取指定列所在的表名。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列所在的表名。
+- `String getCatalogName(int column) throws SQLException`
+  - **接口说明**：获取指定列所在的数据库名。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列所在数据库名。
+- `int getColumnType(int column) throws SQLException`
+  - **接口说明**：获取指定列的 SQL 类型。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：SQL 类型，来自 `java.sql.Types`。
+- `String getColumnTypeName(int column) throws SQLException`
+  - **接口说明**：获取指定列的数据库特定的类型名称。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：数据库特定的类型名称。
+- `boolean isReadOnly(int column) throws SQLException`
+  - **接口说明**：判断指定列是否为只读。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：如果列为只读，则返回 true；否则返回 false。
+- `String getColumnClassName(int column) throws SQLException`
+  - **接口说明**：获取指定列的 Java 类名。
+  - **参数说明**：
+    - `column`：列的编号（从 1 开始）。
+  - **返回值**：列值在 Java 中对应的类名。
+
+
+### 参数绑定
+PreparedStatement 允许使用预编译的 SQL 语句，这可以提高性能并提供参数化查询的能力，从而增加安全性。  
+JDBC 驱动提供了实现 PreparedStatement 接口的两个类：  
+1. 对应原生连接的 TSDBPreparedStatement
+2. 对应 Websocket 连接的 TSWSPreparedStatement  
+
+因 JDBC 标准没有高性能绑定数据的接口，TSDBPreparedStatement 和 TSWSPreparedStatement 都新增了一些方法，用来扩展参数绑定能力。  
+> **注意**：由于 PreparedStatement 继承了 Statement 接口，因此对于这部分重复的接口不再赘述，请参考 Statement 接口中对应描述。  
+
+#### 标准接口
+- `void setNull(int parameterIndex, int sqlType) throws SQLException`
+  - **接口说明**：设置指定参数的 SQL 类型为 NULL。
+  - **参数说明**：
+    - `parameterIndex`：一个 int 类型的参数，表示预编译语句中的参数索引位置。
+    - `sqlType`：一个 int 类型的参数，表示要设置为 NULL 的 SQL 类型。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `void setBoolean(int parameterIndex, boolean x) throws SQLException`
+  - **接口说明**：设置指定参数的值为一个 Java boolean。
+  - **参数说明**：
+    - `parameterIndex`：一个 int 类型的参数，表示预编译语句中的参数索引位置。
+    - `x`：一个 boolean 类型的参数，表示要设置的值。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- 下面接口除了要设置的值类型不同外，其余同 setBoolean，不再赘述：
+  - `void setByte(int parameterIndex, byte x) throws SQLException`
+  - `void setShort(int parameterIndex, short x) throws SQLException`
+  - `void setInt(int parameterIndex, int x) throws SQLException`
+  - `void setLong(int parameterIndex, long x) throws SQLException`
+  - `void setFloat(int parameterIndex, float x) throws SQLException`
+  - `void setDouble(int parameterIndex, double x) throws SQLException`
+  - `void setBigDecimal(int parameterIndex, BigDecimal x) throws SQLException`
+  - `void setString(int parameterIndex, String x) throws SQLException`
+  - `void setBytes(int parameterIndex, byte[] x) throws SQLException`
+  - `void setDate(int parameterIndex, Date x) throws SQLException`
+  - `void setTime(int parameterIndex, Time x) throws SQLException`
+  - `void setTimestamp(int parameterIndex, Timestamp x) throws SQLException`
+- `void clearParameters() throws SQLException`
+  - **接口说明**：清除当前所有已设置的参数值。
+  - **异常**：如果预编译语句已关闭，将抛出 SQLException 异常。
+- `void setObject(int parameterIndex, Object x, int targetSqlType) throws SQLException`
+  - **接口说明**：使用给定对象设置指定参数的值，对象的类型由 targetSqlType 指定。
+  - **参数说明**：
+    - `parameterIndex`：一个 int 类型的参数，表示预编译语句中的参数索引位置。
+    - `x`：一个 Object 类型的参数，表示要设置的值。
+    - `targetSqlType`：一个 int 类型的参数，表示 x 参数的 SQL 类型。
+  - **异常**：如果预编译语句已关闭，将抛出 SQLException 异常。
+- `void setObject(int parameterIndex, Object x) throws SQLException`
+  - **接口说明**：使用给定对象设置指定参数的值，对象的类型由对象本身决定。
+  - **参数说明**：
+    - `parameterIndex`：一个 int 类型的参数，表示预编译语句中的参数索引位置。
+    - `x`：一个 Object 类型的参数，表示要设置的值。
+  - **异常**：如果预编译语句已关闭或者参数索引超出范围，将抛出 SQLException 异常。
+- `ResultSetMetaData getMetaData() throws SQLException`
+  - **接口说明**：获取与此 PreparedStatement 对象生成的 ResultSet 对象相关的元数据。
+  - **返回值**：如果此 PreparedStatement 对象尚未执行任何生成 ResultSet 对象的操作，则返回 null；否则，返回此 ResultSet 对象的元数据。
+  - **异常**：如果发生数据库访问错误，将抛出 SQLException 异常。
+- `ParameterMetaData getParameterMetaData() throws SQLException`
+  - **接口说明**：获取此 PreparedStatement 对象中每个参数的类型和属性信息。ParameterMetaData 说明见下文 参数元数据 章节。
+  - **返回值**：此 PreparedStatement 对象的参数的元数据。
+  - **异常**：如果预编译语句已关闭，将抛出 SQLException 异常。
+
+#### 参数元数据
+ParameterMetaData 提供了参数元数据接口：
+- `int getParameterCount() throws SQLException`
+  - **接口说明**：获取预编译语句中参数的数量。
+  - **返回值**：参数的数量，类型为 `int`。
+  - **异常**：如果在获取参数数量的过程中发生错误，将抛出 `SQLException` 异常。
+- `boolean isSigned(int param) throws SQLException`
+  - **接口说明**：判断指定参数是否为有符号数。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：如果参数为有符号数，则返回 `true`；否则返回 `false`。
+  - **异常**：如果在判断过程中发生错误，将抛出 `SQLException` 异常。
+- `int getPrecision(int param) throws SQLException`
+  - **接口说明**：获取指定参数的精度。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：参数的精度，类型为 `int`。
+  - **异常**：如果在获取精度的过程中发生错误，将抛出 `SQLException` 异常。
+- `int getScale(int param) throws SQLException`
+  - **接口说明**：获取指定参数的小数位数。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：参数的小数位数，类型为 `int`。
+  - **异常**：如果在获取小数位数的过程中发生错误，将抛出 `SQLException` 异常。
+- `int getParameterType(int param) throws SQLException`
+  - **接口说明**：获取指定参数的 SQL 类型。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：参数的 SQL 类型，类型为 `int`。
+  - **异常**：如果在获取 SQL 类型的过程中发生错误，将抛出 `SQLException` 异常。
+- `String getParameterTypeName(int param) throws SQLException`
+  - **接口说明**：获取指定参数的 SQL 类型名称。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：参数的 SQL 类型名称，类型为 `String`。
+  - **异常**：如果在获取 SQL 类型名称的过程中发生错误，将抛出 `SQLException` 异常。
+- `String getParameterClassName(int param) throws SQLException`
+  - **接口说明**：获取指定参数的 Java 类型名称。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：参数的 Java 类型名称，类型为 `String`。
+  - **异常**：如果在获取 Java 类型名称的过程中发生错误，将抛出 `SQLException` 异常。
+- `int getParameterMode(int param) throws SQLException`
+  - **接口说明**：获取指定参数的模式（例如，IN、OUT、INOUT）。
+  - **参数说明**：
+    - `param`：参数的索引，类型为 `int`。
+  - **返回值**：参数的模式，类型为 `int`。
+  - **异常**：如果在获取参数模式的过程中发生错误，将抛出 `SQLException` 异常。
+
+#### 扩展接口  
+
+- `public void setTableName(String name) throws SQLException`
+  - **接口说明**：设置当前操作的表名。
+  - **参数说明**：
+    - `name`：一个 String 类型的参数，表示要绑定的表名。
+- `public void setTagNull(int index, int type)`
+  - **接口说明**：为指定索引的标签设置 null 值。
+  - **参数说明**：
+    - `index`：标签的索引位置。
+    - `type`：标签的数据类型。
+- `public void setTagBoolean(int index, boolean value)`
+  - **接口说明**：为指定索引的标签设置布尔值。
+  - **参数说明**：
+    - `index`：标签的索引位置。
+    - `value`：要设置的布尔值。
+- 下面接口除了要设置的值类型不同外，其余同 setTagBoolean，不再赘述：
+  - `public void setTagInt(int index, int value)`
+  - `public void setTagByte(int index, byte value)`
+  - `public void setTagShort(int index, short value)`
+  - `public void setTagLong(int index, long value)`
+  - `public void setTagTimestamp(int index, long value)`
+  - `public void setTagFloat(int index, float value)`
+  - `public void setTagDouble(int index, double value)`
+  - `public void setTagString(int index, String value)`
+  - `public void setTagNString(int index, String value)`
+  - `public void setTagJson(int index, String value)`
+  - `public void setTagVarbinary(int index, byte[] value)`
+  - `public void setTagGeometry(int index, byte[] value)`
+
+- `public void setInt(int columnIndex, ArrayList<Integer> list) throws SQLException`
+  - **接口说明**：为指定列索引设置批量整型值。
+  - **参数说明**：
+    - `columnIndex`：列的索引位置。
+    - `list`：包含整型值的列表。
+  - **异常**：
+    - 如果操作过程中发生错误，将抛出 SQLException 异常。
+- 下面接口除了要设置的值类型不同外，其余同 setInt：
+  - `public void setFloat(int columnIndex, ArrayList<Float> list) throws SQLException`
+  - `public void setTimestamp(int columnIndex, ArrayList<Long> list) throws SQLException`
+  - `public void setLong(int columnIndex, ArrayList<Long> list) throws SQLException`
+  - `public void setDouble(int columnIndex, ArrayList<Double> list) throws SQLException`
+  - `public void setBoolean(int columnIndex, ArrayList<Boolean> list) throws SQLException`
+  - `public void setByte(int columnIndex, ArrayList<Byte> list) throws SQLException`
+  - `public void setShort(int columnIndex, ArrayList<Short> list) throws SQLException`
+- `public void setString(int columnIndex, ArrayList<String> list, int size) throws SQLException`
+  - **接口说明**：为指定列索引设置字符串值列表。
+  - **参数说明**：
+    - `columnIndex`：列的索引位置。
+    - `list`：包含字符串值的列表。
+    - `size`：所有字符串的最大长度，一般为建表语句的限制值。
+  - **异常**：
+    - 如果操作过程中发生错误，将抛出 SQLException 异常。
+- 下面接口除了要设置的值类型不同外，其余同 setString：    
+  - `public void setVarbinary(int columnIndex, ArrayList<byte[]> list, int size) throws SQLException`
+  - `public void setGeometry(int columnIndex, ArrayList<byte[]> list, int size) throws SQLException`
+  - `public void setNString(int columnIndex, ArrayList<String> list, int size) throws SQLException`
+- `void columnDataAddBatch() throws SQLException`
+  - **接口说明**：将 `setInt（int columnIndex， ArrayList<Integer> list）` 等数组形式接口设置的数据添加到当前 PrepareStatement 对象的批处理中。
+  - **异常**：
+    - 如果操作过程中发生错误，将抛出 SQLException 异常。
+- `void columnDataExecuteBatch() throws SQLException`
+  - **接口说明**：执行当前 PrepareStatement 对象的批处理操作。
+  - **异常**：如果操作过程中发生错误，将抛出 SQLException 异常。
+
+
+### 数据订阅
+
+JDBC 标准不支持数据订阅，因此本章所有接口都是扩展接口。TaosConsumer 类提供了消费者相关接口，ConsumerRecord 提供了消费记录相关接口，TopicPartition 和 OffsetAndMetadata 提供了分区信息以及偏移量元数据接口。最后 ReferenceDeserializer 和 MapDeserializer 提供了反序列化的支持。
+
+#### 消费者
+
+- `TaosConsumer(Properties properties) throws SQLException`
+  - **接口说明**：消费者构造函数
+  - **参数说明**：
+    - `properties`：一组属性，详细支持的属性见下文。
+  - **返回值**：消费者对象
+  - **异常**：如果创建失败，抛出 SQLException 异常。
+
+创建消费者支持属性列表：  
+- td.connect.type: 连接方式。jni：表示使用动态库连接的方式，ws/WebSocket：表示使用 WebSocket 进行数据通信。默认为 jni 方式。
+- bootstrap.servers: TDengine 服务端所在的`ip:port`，如果使用 WebSocket 连接，则为 taosAdapter 所在的`ip:port`。
+- enable.auto.commit: 是否允许自动提交。
+- group.id: consumer: 所在的 group。
+- value.deserializer: 结果集反序列化方法，可以继承 `com.taosdata.jdbc.tmq.ReferenceDeserializer`，并指定结果集 bean，实现反序列化。也可以继承 `com.taosdata.jdbc.tmq.Deserializer`，根据 SQL 的 resultSet 自定义反序列化方式。
+- httpConnectTimeout: 创建连接超时参数，单位 ms，默认为 5000 ms。仅在 WebSocket 连接下有效。
+- messageWaitTimeout: 数据传输超时参数，单位 ms，默认为 10000 ms。仅在 WebSocket 连接下有效。
+- httpPoolSize: 同一个连接下最大并行请求数。仅在 WebSocket 连接下有效。  
+- TSDBDriver.PROPERTY_KEY_ENABLE_COMPRESSION: 传输过程是否启用压缩。仅在使用 Websocket 连接时生效。true: 启用，false: 不启用。默认为 false。
+- TSDBDriver.PROPERTY_KEY_ENABLE_AUTO_RECONNECT: 是否启用自动重连。仅在使用 Websocket 连接时生效。true: 启用，false: 不启用。默认为 false。
+- TSDBDriver.PROPERTY_KEY_RECONNECT_INTERVAL_MS: 自动重连重试间隔，单位毫秒，默认值 2000。仅在 PROPERTY_KEY_ENABLE_AUTO_RECONNECT 为 true 时生效。
+- TSDBDriver.PROPERTY_KEY_RECONNECT_RETRY_COUNT: 自动重连重试次数，默认值 3，仅在 PROPERTY_KEY_ENABLE_AUTO_RECONNECT 为 true 时生效。  
+其他参数请参考：[Consumer 参数列表](../../develop/tmq/#数据订阅相关参数)， 注意TDengine服务端自 3.2.0.0 版本开始消息订阅中的 auto.offset.reset 默认值发生变化。
+
+- `public void subscribe(Collection<String> topics) throws SQLException`
+  - **接口说明**：订阅一组主题。
+  - **参数说明**：
+    - `topics`：一个 `Collection<String>` 类型的参数，表示要订阅的主题列表。
+  - **异常**：如果在订阅过程中发生错误，将抛出 SQLException 异常。
+- `public void unsubscribe() throws SQLException`
+  - **接口说明**：取消订阅所有主题。
+  - **异常**：如果在取消订阅过程中发生错误，将抛出 SQLException 异常。
+- `public Set<String> subscription() throws SQLException`
+  - **接口说明**：获取当前订阅的所有主题。
+  - **返回值**：返回值类型为 `Set<String>`，即当前订阅的所有主题集合。
+  - **异常**：如果在获取订阅信息过程中发生错误，将抛出 SQLException 异常。
+- `public ConsumerRecords<V> poll(Duration timeout) throws SQLException`
+  - **接口说明**：轮询消息。
+  - **参数说明**：
+    - `timeout`：一个 `Duration` 类型的参数，表示轮询的超时时间。
+  - **返回值**：返回值类型为 `ConsumerRecords<V>`，即轮询到的消息记录。
+  - **异常**：如果在轮询过程中发生错误，将抛出 SQLException 异常。
+- `public void commitAsync() throws SQLException`
+  - **接口说明**：异步提交当前处理的消息的偏移量。
+  - **异常**：如果在提交过程中发生错误，将抛出 SQLException 异常。
+- `public void commitSync() throws SQLException`
+  - **接口说明**：同步提交当前处理的消息的偏移量。
+  - **异常**：如果在提交过程中发生错误，将抛出 SQLException 异常。
+- `public void close() throws SQLException`
+  - **接口说明**：关闭消费者，释放资源。
+  - **异常**：如果在关闭过程中发生错误，将抛出 SQLException 异常。
+- `public void seek(TopicPartition partition, long offset) throws SQLException`
+  - **接口说明**：将给定分区的偏移量设置到指定的位置。
+  - **参数说明**：
+    - `partition`：一个 `TopicPartition` 类型的参数，表示要操作的分区。
+    - `offset`：一个 `long` 类型的参数，表示要设置的偏移量。
+  - **异常**：如果在设置偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public long position(TopicPartition tp) throws SQLException`
+  - **接口说明**：获取给定分区当前的偏移量。
+  - **参数说明**：
+    - `tp`：一个 `TopicPartition` 类型的参数，表示要查询的分区。
+  - **返回值**：返回值类型为 `long`，即给定分区当前的偏移量。
+  - **异常**：如果在获取偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException`
+  - **接口说明**：获取指定主题的每个分区的最早偏移量。
+  - **参数说明**：
+    - `topic`：一个 `String` 类型的参数，表示要查询的主题。
+  - **返回值**：返回值类型为 `Map<TopicPartition, Long>`，即指定主题的每个分区的最早偏移量。
+  - **异常**：如果在获取最早偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public Map<TopicPartition, Long> endOffsets(String topic) throws SQLException`
+  - **接口说明**：获取指定主题的每个分区的最新偏移量。
+  - **参数说明**：
+    - `topic`：一个 `String` 类型的参数，表示要查询的主题。
+  - **返回值**：返回值类型为 `Map<TopicPartition, Long>`，即指定主题的每个分区的最新偏移量。
+  - **异常**：如果在获取最新偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public void seekToBeginning(Collection<TopicPartition> partitions) throws SQLException`
+  - **接口说明**：将一组分区的偏移量设置到最早的偏移量。
+  - **参数说明**：
+    - `partitions`：一个 `Collection<TopicPartition>` 类型的参数，表示要操作的分区集合。
+  - **异常**：如果在设置偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public void seekToEnd(Collection<TopicPartition> partitions) throws SQLException`
+  - **接口说明**：将一组分区的偏移量设置到最新的偏移量。
+  - **参数说明**：
+    - `partitions`：一个 `Collection<TopicPartition>` 类型的参数，表示要操作的分区集合。
+  - **异常**：如果在设置偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public Set<TopicPartition> assignment() throws SQLException`
+  - **接口说明**：获取消费者当前分配的所有分区。
+  - **返回值**：返回值类型为 `Set<TopicPartition>`，即消费者当前分配的所有分区。
+  - **异常**：如果在获取分配的分区过程中发生错误，将抛出 SQLException 异常。
+- `public OffsetAndMetadata committed(TopicPartition partition) throws SQLException`
+  - **接口说明**：获取指定分区最后提交的偏移量。
+  - **参数说明**：
+    - `partition`：一个 `TopicPartition` 类型的参数，表示要查询的分区。
+  - **返回值**：返回值类型为 `OffsetAndMetadata`，即指定分区最后提交的偏移量。
+  - **异常**：如果在获取提交的偏移量过程中发生错误，将抛出 SQLException 异常。
+- `public Map<TopicPartition, OffsetAndMetadata> committed(Set<TopicPartition> partitions) throws SQLException`
+  - **接口说明**：获取一组分区最后提交的偏移量。
+  - **参数说明**：
+    - `partitions`：一个 `Set<TopicPartition>` 类型的参数，表示要查询的分区集合。
+  - **返回值**：返回值类型为 `Map<TopicPartition, OffsetAndMetadata>`，即一组分区最后提交的偏移量。
+  - **异常**：如果在获取提交的偏移量过程中发生错误，将抛出 SQLException 异常。
+
+#### 消费记录
+
+ConsumerRecords 类提供了消费记录信息，可以迭代 ConsumerRecord 对象。
+
+ConsumerRecord 提供的接口：
+
+- `public String getTopic()`
+  - **接口说明**：获取消息的主题。
+  - **返回值**：返回值类型为 `String`，即消息的主题。
+- `public String getDbName()`
+  - **接口说明**：获取数据库名称。
+  - **返回值**：返回值类型为 `String`，即数据库名称。
+- `public int getVGroupId()`
+  - **接口说明**：获取虚拟组 ID。
+  - **返回值**：返回值类型为 `int`，即虚拟组 ID。
+- `public V value()`
+  - **接口说明**：获取消息的值。
+  - **返回值**：返回值类型为 `V`，即消息的值。
+- `public long getOffset()`
+  - **接口说明**：获取消息的偏移量。
+  - **返回值**：返回值类型为 `long`，即消息的偏移量。
+
+#### 分区信息
+
+TopicPartition 类提供了分区信息，包含消息主题和虚拟组 ID。
+
+- `public TopicPartition(String topic, int vGroupId)`
+  - **接口说明**：构造一个新的 TopicPartition 实例，用于表示一个特定的主题和虚拟组 ID。
+  - **参数说明**：
+    - `topic`：一个 `String` 类型的参数，表示消息的主题。
+    - `vGroupId`：一个 `int` 类型的参数，表示虚拟组 ID。
+- `public String getTopic()`
+  - **接口说明**：获取此 TopicPartition 实例的主题。
+  - **返回值**：返回值类型为 `String`，即此 TopicPartition 实例的主题。
+- `public int getVGroupId()`
+  - **接口说明**：获取此 TopicPartition 实例的虚拟组 ID。
+  - **返回值**：返回值类型为 `int`，即此 TopicPartition 实例的虚拟组 ID。
+
+#### 偏移量元数据
+
+OffsetAndMetadata 类提供了偏移量元数据信息。
+
+- `public long offset()`
+  - **接口说明**：获取此 OffsetAndMetadata 实例中的偏移量。
+  - **返回值**：返回值类型为 `long`，即此 OffsetAndMetadata 实例中的偏移量。
+- `public String metadata()`
+  - **接口说明**：获取此 OffsetAndMetadata 实例中的元数据。
+  - **返回值**：返回值类型为 `String`，即此 OffsetAndMetadata 实例中的元数据。
+
+#### 反序列化
+
+JDBC 驱动提供了两个反序列化类：ReferenceDeserializer 和 MapDeserializer。它们都实现了 Deserializer 接口。
+ReferenceDeserializer 用来将消费到的一条记录反序列化为一个对象，需要保证对象类的属性名与消费到的数据的列名能够对应，且类型能够匹配。
+MapDeserializer 则会将消费到的一行数据反序列化为一个 `Map<String, Object>` 对象，其 key 为列名，值为 Java 对象。
+ReferenceDeserializer 和 MapDeserializer 的接口不会被用户直接调用，请参考使用样例。  
+
+
+## 附录
+
+taos-jdbcdriver Javadoc：[taos-jdbcdriver doc](https://docs.taosdata.com/api/taos-jdbcdriver)  
+JDBC Javadoc：[JDBC Reference doc](https://docs.oracle.com/javase/8/docs/api/java/sql/package-summary.html)
 
-[taos-jdbcdriver doc](https://docs.taosdata.com/api/taos-jdbcdriver)