chore: add unit tests

Author: sheyanjie-qq

src/main/java/com/taosdata/jdbc/AbstractConnection.java

@@ -8,7 +8,7 @@
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicLong;
-
+@SuppressWarnings("java:S4144")
 public abstract class AbstractConnection extends WrapperImpl implements Connection {
 
     protected final AtomicLong idGenerator = new AtomicLong(0);
@@ -47,7 +47,8 @@ public boolean canRebalanced() {
     }
     @Override
     public CallableStatement prepareCall(String sql) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
@@ -204,17 +205,20 @@ public PreparedStatement prepareStatement(String sql, int resultSetType, int res
 
     @Override
     public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public Map<String, Class<?>> getTypeMap() throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public void setTypeMap(Map<String, Class<?>> map) throws SQLException {
-        notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
@@ -243,21 +247,25 @@ public int getHoldability() throws SQLException {
 
     @Override
     public Savepoint setSavepoint() throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public Savepoint setSavepoint(String name) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public void rollback(Savepoint savepoint) throws SQLException {
-        notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
     @Override
     public void releaseSavepoint(Savepoint savepoint) throws SQLException {
-        notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
@@ -289,7 +297,8 @@ public PreparedStatement prepareStatement(String sql, int resultSetType, int res
 
     @Override
     public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
@@ -308,34 +317,40 @@ public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) thr
 
     @Override
     public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public Clob createClob() throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public Blob createBlob() throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
 
     }
 
     @Override
     public NClob createNClob() throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
 
     }
 
     @Override
     public SQLXML createSQLXML() throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
@@ -414,12 +429,14 @@ public Properties getClientInfo() throws SQLException {
 
     @Override
     public Array createArrayOf(String typeName, Object[] elements) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
     public Struct createStruct(String typeName, Object[] attributes) throws SQLException {
-        return notSupportedMethod();
+        checkClosed();
+        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
     }
 
     @Override
@@ -499,11 +516,7 @@ public int writeRaw(String line, SchemalessProtocolType protocolType, Schemaless
     }
 
     public abstract int writeRaw(String line, SchemalessProtocolType protocolType, SchemalessTimestampType timestampType, Integer ttl, Long reqId) throws SQLException;
-
-    protected <T> T notSupportedMethod() throws SQLException {
-        checkClosed();
-        throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
-    }
+    
     private void checkClosed() throws SQLException {
         if (this.isClosed) {
             throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_CONNECTION_CLOSED);

src/main/java/com/taosdata/jdbc/AbstractDatabaseMetaData.java

@@ -2,7 +2,7 @@
 
 import com.google.common.collect.Lists;
 import com.taosdata.jdbc.enums.DataType;
-import com.taosdata.jdbc.rs.ConnectionParam;
+import com.taosdata.jdbc.common.ConnectionParam;
 import com.taosdata.jdbc.utils.StringUtils;
 import com.taosdata.jdbc.ws.WSConnection;
 import org.slf4j.Logger;

src/main/java/com/taosdata/jdbc/AbstractDriver.java

@@ -5,7 +5,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.ObjectReader;
 import com.taosdata.jdbc.enums.WSFunction;
-import com.taosdata.jdbc.rs.ConnectionParam;
+import com.taosdata.jdbc.common.ConnectionParam;
 import com.taosdata.jdbc.utils.*;
 import com.taosdata.jdbc.ws.*;
 import com.taosdata.jdbc.ws.entity.*;