async_write 方式写入 taos nchar 字段时报错

[chncaesar]

版本

<dependency>
    <groupId>com.taosdata.jdbc</groupId>
    <artifactId>taos-jdbcdriver</artifactId>
    <version>3.6.3</version>
</dependency>

问题描述

参考高效写入官方文档 验证 async_write 方式写入 taos 表时，power.meters 加了一个字段 co nchar(100) ，并相应 添加了 PreparedStatment 的绑定变量，运行时报错。

20:06:06.937 [pool-2-thread-1] ERROR com.taosdata.jdbc.ws.WSEWPreparedStatement$WorkerThread - Error in serialize data to block, stmt id: 2, req id: 8865057829279498247
java.lang.ClassCastException: [B cannot be cast to java.lang.String
	at com.taosdata.jdbc.common.SerializeBlock.getColumnSize(SerializeBlock.java:422) ~[connector-tdengine-2.3.12-SNAPSHOT.jar:2.3.12-SNAPSHOT]
	at com.taosdata.jdbc.common.SerializeBlock.getColTotalLength(SerializeBlock.java:387) ~[connector-tdengine-2.3.12-SNAPSHOT.jar:2.3.12-SNAPSHOT]
	at com.taosdata.jdbc.common.SerializeBlock.getStmt2BindBlock(SerializeBlock.java:471) ~[connector-tdengine-2.3.12-SNAPSHOT.jar:2.3.12-SNAPSHOT]
	at com.taosdata.jdbc.ws.WSEWPreparedStatement$WorkerThread.writeBlockWithRetry(WSEWPreparedStatement.java:419) [connector-tdengine-2.3.12-SNAPSHOT.jar:2.3.12-SNAPSHOT]
	at com.taosdata.jdbc.ws.WSEWPreparedStatement$WorkerThread.run(WSEWPreparedStatement.java:392) [connector-tdengine-2.3.12-SNAPSHOT.jar:2.3.12-SNAPSHOT]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0-332]
	at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [?:1.8.0-332]
	at java.util.concurrent.FutureTask.run(FutureTask.java) [?:1.8.0-332]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0-332]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0-332]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0-332]

[sheyanjie-qq]

大概率是你使用了 setString 来设置 nchar，根据 jdbc 规范应该是使用 setNString
我看看如何兼容这个用法。

[chncaesar]

最新代码 (3.7.1) 不支持 setNString()

    @Override
    public void setNString(int parameterIndex, String value) throws SQLException {
        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
    }

我提交的 PR #263 ，能够解决这个问题。 @sheyanjie-qq