From 878ef3e3f7512085a7fcb3121ad0e7d279a61fad Mon Sep 17 00:00:00 2001 From: dingbo Date: Wed, 15 Jun 2022 17:53:21 +0800 Subject: [PATCH] docs: java connect --- docs/examples/java/pom.xml | 2 +- .../com/taos/example/ConnectCloudExample.java | 5 +- .../src/test/java/com/taos/test/TestAll.java | 79 ------------------- 3 files changed, 5 insertions(+), 81 deletions(-) diff --git a/docs/examples/java/pom.xml b/docs/examples/java/pom.xml index a48ba398da..1165879156 100644 --- a/docs/examples/java/pom.xml +++ b/docs/examples/java/pom.xml @@ -21,7 +21,7 @@ com.taosdata.jdbc taos-jdbcdriver - 2.0.38 + 2.0.39 diff --git a/docs/examples/java/src/main/java/com/taos/example/ConnectCloudExample.java b/docs/examples/java/src/main/java/com/taos/example/ConnectCloudExample.java index 7c7cfbbd1c..68004ab0aa 100644 --- a/docs/examples/java/src/main/java/com/taos/example/ConnectCloudExample.java +++ b/docs/examples/java/src/main/java/com/taos/example/ConnectCloudExample.java @@ -1,16 +1,19 @@ package com.taos.example; -import com.taosdata.jdbc.TSDBDriver; // ANCHOR: connect import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; +import java.sql.Statement; public class ConnectCloudExample { public static void main(String[] args) throws SQLException { String jdbcUrl = System.getenv("TDENGINE_JDBC_URL"); Connection conn = DriverManager.getConnection(jdbcUrl); + Statement stmt = conn.createStatement(); + // test the connection by firing a query + stmt.executeQuery("select server_version()"); conn.close(); } } diff --git a/docs/examples/java/src/test/java/com/taos/test/TestAll.java b/docs/examples/java/src/test/java/com/taos/test/TestAll.java index 42db24485a..c9af09169f 100644 --- a/docs/examples/java/src/test/java/com/taos/test/TestAll.java +++ b/docs/examples/java/src/test/java/com/taos/test/TestAll.java @@ -9,83 +9,4 @@ import java.sql.*; @FixMethodOrder public class TestAll { private String[] args = new String[]{}; - - public void dropDB(String dbName) throws SQLException { - String jdbcUrl = "jdbc:TAOS://localhost:6030?user=root&password=taosdata"; - try (Connection conn = DriverManager.getConnection(jdbcUrl)) { - try (Statement stmt = conn.createStatement()) { - stmt.execute("drop database if exists " + dbName); - } - } - } - - public void insertData() throws SQLException { - String jdbcUrl = "jdbc:TAOS://localhost:6030?user=root&password=taosdata"; - try (Connection conn = DriverManager.getConnection(jdbcUrl)) { - try (Statement stmt = conn.createStatement()) { - String sql = "INSERT INTO power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES('2018-10-03 14:38:05.000',10.30000,219,0.31000)\n" + - " power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES('2018-10-03 15:38:15.000',12.60000,218,0.33000)\n" + - " power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES('2018-10-03 15:38:16.800',12.30000,221,0.31000)\n" + - " power.d1002 USING power.meters TAGS(California.SanFrancisco, 3) VALUES('2018-10-03 15:38:16.650',10.30000,218,0.25000)\n" + - " power.d1003 USING power.meters TAGS(California.LosAngeles, 2) VALUES('2018-10-03 15:38:05.500',11.80000,221,0.28000)\n" + - " power.d1003 USING power.meters TAGS(California.LosAngeles, 2) VALUES('2018-10-03 15:38:16.600',13.40000,223,0.29000)\n" + - " power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 15:38:05.000',10.80000,223,0.29000)\n" + - " power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 15:38:06.000',10.80000,223,0.29000)\n" + - " power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 15:38:07.000',10.80000,223,0.29000)\n" + - " power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 15:38:08.500',11.50000,221,0.35000)"; - - stmt.execute(sql); - } - } - } - - @Test - public void testJNIConnect() throws SQLException { - JNIConnectExample.main(args); - } - - @Test - public void testRestConnect() throws SQLException { - RESTConnectExample.main(args); - } - - @Test - public void testRestInsert() throws SQLException { - dropDB("power"); - RestInsertExample.main(args); - RestQueryExample.main(args); - } - - @Test - public void testStmtInsert() throws SQLException { - dropDB("power"); - StmtInsertExample.main(args); - } - - @Test - public void testSubscribe() { - - Thread thread = new Thread(() -> { - try { - Thread.sleep(1000); - insertData(); - } catch (SQLException e) { - e.printStackTrace(); - } catch (InterruptedException e) { - e.printStackTrace(); - } - }); - thread.start(); - SubscribeDemo.main(args); - } - - @Test - public void testSchemaless() throws SQLException { - LineProtocolExample.main(args); - TelnetLineProtocolExample.main(args); - // for json protocol, tags may be double type. but for telnet protocol tag must be nchar type. - // To avoid type mismatch, we delete database test. - dropDB("test"); - JSONProtocolExample.main(args); - } } -- GitLab