未验证 提交 c43f2234 编写于 作者: H huolibo 提交者: GitHub

rename executeSchemaless to insert (#8883)

上级 33cac659
...@@ -9,15 +9,11 @@ import java.sql.SQLException; ...@@ -9,15 +9,11 @@ import java.sql.SQLException;
import java.sql.Statement; import java.sql.Statement;
/** /**
* @author huolibo@qq.com * this class is an extension of {@link Statement}. e.g.:
* @version v1.0.0
* @JDK: 1.8
* @description: this class is an extension of {@link Statement}. use like:
* Statement statement = conn.createStatement(); * Statement statement = conn.createStatement();
* SchemalessStatement schemalessStatement = new SchemalessStatement(statement); * SchemalessStatement schemalessStatement = new SchemalessStatement(statement);
* schemalessStatement.execute(sql); * schemalessStatement.execute(sql);
* schemalessStatement.executeSchemaless(lines, SchemalessProtocolType, SchemalessTimestampType); * schemalessStatement.insert(lines, SchemalessProtocolType, SchemalessTimestampType);
* @since 2021-11-03 17:10
*/ */
public class SchemalessStatement extends AbstractStatementWrapper { public class SchemalessStatement extends AbstractStatementWrapper {
public SchemalessStatement(Statement statement) { public SchemalessStatement(Statement statement) {
...@@ -27,12 +23,12 @@ public class SchemalessStatement extends AbstractStatementWrapper { ...@@ -27,12 +23,12 @@ public class SchemalessStatement extends AbstractStatementWrapper {
/** /**
* batch insert schemaless lines * batch insert schemaless lines
* *
* @param lines schemaless data * @param lines schemaless lines
* @param protocolType schemaless type {@link SchemalessProtocolType} * @param protocolType schemaless type {@link SchemalessProtocolType}
* @param timestampType Time precision {@link SchemalessTimestampType} * @param timestampType Time precision {@link SchemalessTimestampType}
* @throws SQLException execute insert exception * @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(); Connection connection = this.getConnection();
if (connection instanceof TSDBConnection) { if (connection instanceof TSDBConnection) {
TSDBConnection tsdbConnection = (TSDBConnection) connection; TSDBConnection tsdbConnection = (TSDBConnection) connection;
...@@ -52,7 +48,7 @@ public class SchemalessStatement extends AbstractStatementWrapper { ...@@ -52,7 +48,7 @@ public class SchemalessStatement extends AbstractStatementWrapper {
* @param timestampType Time precision {@link SchemalessTimestampType} * @param timestampType Time precision {@link SchemalessTimestampType}
* @throws SQLException execute insert exception * @throws SQLException execute insert exception
*/ */
public void executeSchemaless(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException { public void insert(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType) throws SQLException {
executeSchemaless(new String[]{line}, protocolType, timestampType); insert(new String[]{line}, protocolType, timestampType);
} }
} }
...@@ -29,7 +29,7 @@ public class SchemalessInsertTest { ...@@ -29,7 +29,7 @@ public class SchemalessInsertTest {
// when // when
try (Statement statement = conn.createStatement(); try (Statement statement = conn.createStatement();
SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) { SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) {
schemalessStatement.executeSchemaless(lines, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS); schemalessStatement.insert(lines, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS);
} }
// then // then
...@@ -64,7 +64,7 @@ public class SchemalessInsertTest { ...@@ -64,7 +64,7 @@ public class SchemalessInsertTest {
// when // when
try (Statement statement = conn.createStatement(); try (Statement statement = conn.createStatement();
SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) { SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) {
schemalessStatement.executeSchemaless(lines, SchemalessProtocolType.TELNET, SchemalessTimestampType.NOT_CONFIGURED); schemalessStatement.insert(lines, SchemalessProtocolType.TELNET, SchemalessTimestampType.NOT_CONFIGURED);
} }
// then // then
...@@ -116,7 +116,7 @@ public class SchemalessInsertTest { ...@@ -116,7 +116,7 @@ public class SchemalessInsertTest {
// when // when
try (Statement statement = conn.createStatement(); try (Statement statement = conn.createStatement();
SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) { SchemalessStatement schemalessStatement = new SchemalessStatement(statement)) {
schemalessStatement.executeSchemaless(json, SchemalessProtocolType.JSON, SchemalessTimestampType.NOT_CONFIGURED); schemalessStatement.insert(json, SchemalessProtocolType.JSON, SchemalessTimestampType.NOT_CONFIGURED);
} }
// then // then
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册