关于数据连续写入，tags的值没有变化的问题

TDuser_5mX2_6449 · 2025 年12 月 25 日 08:19

【TDengine 使用环境】
测试

【TDengine 版本】

3.3.8.8

【操作系统以及版本】

MacOS

【部署方式】容器/非容器部署
Docker

【集群节点数】

单节点

【集群副本数】

【描述业务影响】

问题一：TSWSPreparedStatement 区操作数据插入使用官网提供的tswsPreparedStatement.columnDataAddBatch();
tswsPreparedStatement.columnDataExecuteBatch();
会报出 Exception in thread “main” java.sql.SQLException: column data is not empty 这样的异常，使用 tswsPreparedStatement.addBatch(); tswsPreparedStatement.executeBatch(); 就没有问题，但是官方示例使用 tswsPreparedStatement.columnDataAddBatch();
tswsPreparedStatement.columnDataExecuteBatch();是可以的。

问题二：在写入的场景下，第一次写 INSERT INTO oneths.logger_message_subscribe_18764521652465 USING oneths.logger_message_subscribe TAGS (‘http://127.0.0.1:13200’, false, 0, 2, ‘18764521652465’, 1850785932467634176, 1635181216120438785, 1765577363955253251, 1712029883699822592, 1767718971333017600, ‘2’, ‘1825802683232419839,1753344780810977280’) VALUES (‘2025-12-25 16:10:47.789’, ‘2004102509827850240’, ‘2004102511249719296’, ‘推送异常Failed to connect to /192.168.110.15:13200’, ‘{“details”:“在线”,“type”:0,“content”:“在线”}’)
第二次写 INSERT INTO oneths.logger_message_subscribe_18764521652465 USING oneths.logger_message_subscribe TAGS (‘http://192.168.110.15:13200’, false, 0, 1, ‘18764521652465’, 1850785932467634176, 1635181216120438785, 1765577363955253251, 1712029883699822592, 1767718971333017600, ‘2’, ‘1825802683232419839,1753344780810977280’) VALUES (‘2025-12-25 16:10:47.893’, ‘2004102509827850240’, ‘2004102511631400960’, ‘推送异常Failed to connect to /192.168.110.15:13200’, ‘{“events”:[{“event_level”:3,“event_content”:“设备正常”,“event_details”:“设备正常”}],“properties”:,“telemetries”:[{“electric_c_phase_voltage”:226.2,“electric_c_phase_current”:17.19,“electric_leakage_current”:0,“electric_b_phase_power”:-60,“electric_c_phase_power”:-3400,“electric_b_phase_current”:1.15,“electric_3_temperature”:21.9,“electric_1_temperature”:21.6,“electric_2_temperature”:21.7,“electric_b_phase_voltage”:233.2,“electric_4_temperature”:0,“electric_a_phase_voltage”:234.8,“electric_a_phase_power”:-50}]}’)

写入的数据 TAGS 里的内容很多没有变化，例如我提条写 SQL 是插入的tag是2 第二次插入的是1 ，但查询出来两个都是 2

表结构是这样的
CREATE STABLE IF NOT EXISTS logger_message_subscribe (
timeseries TIMESTAMP,
trace_id BINARY(64),
message_id BINARY(64),
response_content BINARY(128),
data_content BINARY(4096)
) TAGS (
address BINARY(255),
response_status BOOL,
retries INT,
data_type SMALLINT,
unique_id BINARY(64),
device_id BIGINT,
product_id BIGINT,
channel_id BIGINT,
connector_id BIGINT,
subscribe_id BIGINT,
organization_id BINARY(64),
device_group_ids BINARY(512)
);

【问题复现路径/shan】做过哪些操作出现的问题

【遇到的问题：问题现象及影响】

【资源配置】

【报错完整截图】（不要大段的粘贴报错代码，论坛直接看报错代码不直观）

TDuser_B7if_4489 · 2025 年12 月 25 日 08:30

tags值是和子表绑定的，第一次设置是什么就是什么，固定不变的

TDuser_5mX2_6449 · 2025 年12 月 25 日 08:47

public static void main(String[] args) throws Exception {
        String url = "jdbc:TAOS-WS://127.0.0.1:6041";
        Properties properties = new Properties();
        properties.setProperty(TSDBDriver.PROPERTY_KEY_USER, "oneths");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_PASSWORD, "yjupi181018.");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_BATCH_SIZE_BY_ROW, "1000");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_CACHE_SIZE_BY_ROW, "10000");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_BACKEND_WRITE_THREAD_NUM, "20");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_ENABLE_AUTO_RECONNECT, "true");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_RECONNECT_INTERVAL_MS, "3000");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_RECONNECT_RETRY_COUNT, "10");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_MESSAGE_WAIT_TIMEOUT, "60000");
        properties.setProperty(TSDBDriver.PROPERTY_KEY_ENABLE_COMPRESSION, "true");
//        properties.setProperty(TSDBDriver.PROPERTY_KEY_ASYNC_WRITE, "STMT");
        Connection connection = DriverManager.getConnection(url, properties);
        Statement statement = connection.createStatement();
        statement.execute("USE oneths");

        String sql = "INSERT INTO ? USING oneths.logger_message_subscribe TAGS (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) VALUES (?, ?, ?, ?, ?)";
        try (TSWSPreparedStatement tswsPreparedStatement = connection.prepareStatement(sql).unwrap(TSWSPreparedStatement.class)) {
            tswsPreparedStatement.setTableName("oneths.logger_message_subscribe_18764521652465");
//            tswsPreparedStatement.setTagString(0, "127.0.0.1");
            tswsPreparedStatement.setTagNull(0, 8);
            tswsPreparedStatement.setTagBoolean(1, true);
            tswsPreparedStatement.setTagInt(2, 0);
            tswsPreparedStatement.setTagNull(3, 3); // DataType
            tswsPreparedStatement.setTagString(4, "86xxxxxxxxxxxxx878");
            tswsPreparedStatement.setTagLong(5, 1L);
            tswsPreparedStatement.setTagLong(6, 1L);
            tswsPreparedStatement.setTagLong(7, 1L);
            tswsPreparedStatement.setTagLong(8, 1L);
            tswsPreparedStatement.setTagLong(9, 1L);
            tswsPreparedStatement.setTagString(10, "0");
            tswsPreparedStatement.setTagString(11, "1,2,3,4,5,6,7,8,9,10");
            tswsPreparedStatement.setTimestamp(1, Timestamp.from(Instant.now()));
            tswsPreparedStatement.setString(2, "1000000000");
            tswsPreparedStatement.setString(3, "100000000000");
            tswsPreparedStatement.setString(4, "11111111111111111");
            tswsPreparedStatement.setString(5, "4040OIWQEOIQPU312IIOFDHJEOWIP4823HJIDOWE784923YHUIDSORY78923748923YDFUIWEUR7WE89YHUIWEHCIBJBHJKSDYTF87623478H2323");

            tswsPreparedStatement.addBatch();
            tswsPreparedStatement.executeBatch();

//            tswsPreparedStatement.columnDataAddBatch();
//            tswsPreparedStatement.columnDataExecuteBatch();
        }

不好意思，可能我没有表达清除，上面是我的写入逻辑，第一次写入我的TAGS 下dataType 为 2 第二次写入我的 TAGS 下 dataType 为1 ，我现在区查询SQL为 SELECT * FROM oneths.logger_message_subscribe_1975797937696854016 limit 200; 这样，应该查询出来的数据为2条一条为1 一条为2 ，但是我现在查询出来2条都dataType为2

TDuser_B7if_4489 · 2025 年12 月 25 日 09:11

我知道，你的子表是自动创建的，标签值是按你第一条数据设定的，你两次插入的是同一个子表logger_message_subscribe_18764521652465

你这两条数据是两台设备的数据，你可以一台设备一个子表，这样你的dataType就是不同的

TDuser_5mX2_6449 · 2025 年12 月 25 日 09:33

非常感谢您，您说的我好像大致明白了，我可能对这个TAGS 理解有些错误，那如果我想同一个子表向写入时可以动态赋予不同的TAGS这样的话，我的写入方式和逻辑上是有什么不合理吗，这样是否能做到。