From c43f2234f208764e7590b28e86f06293c39dbc59 Mon Sep 17 00:00:00 2001 From: huolibo Date: Sat, 4 Dec 2021 22:59:55 +0800 Subject: [PATCH] rename executeSchemaless to insert (#8883) --- .../com/taosdata/jdbc/SchemalessStatement.java | 16 ++++++---------- .../com/taosdata/jdbc/SchemalessInsertTest.java | 6 +++--- 2 files changed, 9 insertions(+), 13 deletions(-) diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/SchemalessStatement.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/SchemalessStatement.java index 748891d943..d1184abc27 100644 --- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/SchemalessStatement.java +++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/SchemalessStatement.java @@ -9,15 +9,11 @@ import java.sql.SQLException; import java.sql.Statement; /** - * @author huolibo@qq.com - * @version v1.0.0 - * @JDK: 1.8 - * @description: this class is an extension of {@link Statement}. use like: + * this class is an extension of {@link Statement}. e.g.: * Statement statement = conn.createStatement(); * SchemalessStatement schemalessStatement = new SchemalessStatement(statement); * schemalessStatement.execute(sql); - * schemalessStatement.executeSchemaless(lines, SchemalessProtocolType, SchemalessTimestampType); - * @since 2021-11-03 17:10 + * schemalessStatement.insert(lines, SchemalessProtocolType, SchemalessTimestampType); */ public class SchemalessStatement extends AbstractStatementWrapper { public SchemalessStatement(Statement statement) { @@ -27,12 +23,12 @@ public class SchemalessStatement extends AbstractStatementWrapper { /** * batch insert schemaless lines * - * @param lines schemaless data + * @param lines schemaless lines * @param protocolType schemaless type {@link SchemalessProtocolType} * @param timestampType Time precision {@link SchemalessTimestampType} * @throws SQLException execute insert exception */ - public void executeSchemaless(String[] lines, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException { + public void insert(String[] lines, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException { Connection connection = this.getConnection(); if (connection instanceof TSDBConnection) { TSDBConnection tsdbConnection = (TSDBConnection) connection; @@ -52,7 +48,7 @@ public class SchemalessStatement extends AbstractStatementWrapper { * @param timestampType Time precision {@link SchemalessTimestampType} * @throws SQLException execute insert exception */ - public void executeSchemaless(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException { - executeSchemaless(new String[]{line}, protocolType, timestampType); + public void insert(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException { + insert(new String[]{line}, protocolType, timestampType); } } diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/SchemalessInsertTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/SchemalessInsertTest.java index fd4ac12ce4..b24271615c 100644 --- a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/SchemalessInsertTest.java +++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/SchemalessInsertTest.java @@ -29,7 +29,7 @@ public class SchemalessInsertTest { // when try (Statement statement = conn.createStatement(); SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) { - schemalessStatement.executeSchemaless(lines, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS); + schemalessStatement.insert(lines, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS); } // then @@ -64,7 +64,7 @@ public class SchemalessInsertTest { // when try (Statement statement = conn.createStatement(); SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) { - schemalessStatement.executeSchemaless(lines, SchemalessProtocolType.TELNET, SchemalessTimestampType.NOT_CONFIGURED); + schemalessStatement.insert(lines, SchemalessProtocolType.TELNET, SchemalessTimestampType.NOT_CONFIGURED); } // then @@ -116,7 +116,7 @@ public class SchemalessInsertTest { // when try (Statement statement = conn.createStatement(); SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) { - schemalessStatement.executeSchemaless(json, SchemalessProtocolType.JSON, SchemalessTimestampType.NOT_CONFIGURED); + schemalessStatement.insert(json, SchemalessProtocolType.JSON, SchemalessTimestampType.NOT_CONFIGURED); } // then -- GitLab