From b45d34094b343213a960e59e562b8bcca193c9e8 Mon Sep 17 00:00:00 2001 From: zyyang Date: Sat, 20 Feb 2021 15:33:03 +0800 Subject: [PATCH] change --- .../com/taosdata/jdbc/TSDBConnectionTest.java | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java index 5fd9578957..1d9546b8fb 100644 --- a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java +++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java @@ -35,11 +35,18 @@ public class TSDBConnectionTest { public void subscribe() { try { TSDBConnection unwrap = conn.unwrap(TSDBConnection.class); - TSDBSubscribe subscribe = unwrap.subscribe("topic1", "select server_status()", false); + TSDBSubscribe subscribe = unwrap.subscribe("topic1", "select * from log.log", false); TSDBResultSet rs = subscribe.consume(); - rs.next(); - int status = rs.getInt("server_status()"); - Assert.assertEquals(1, status); + ResultSetMetaData metaData = rs.getMetaData(); + while (rs.next()) { + for (int i = 1; i <= metaData.getColumnCount(); i++) { + String value = rs.getString(i); + System.out.print(metaData.getColumnLabel(i) + ":" + value + "\t"); + } + System.out.println(); + } + Assert.assertNotNull(rs); + subscribe.close(false); } catch (SQLException | OperationsException e) { e.printStackTrace(); }