Merge pull request #3179 from taosdata/TD-1174_feature

TD-1174: jdbc without host ip

src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConnection.java

@@ -14,6 +14,7 @@
  *****************************************************************************/
 package com.taosdata.jdbc;
 
+import java.io.*;
 import java.sql.Array;
 import java.sql.Blob;
 import java.sql.CallableStatement;
@@ -30,336 +31,392 @@ import java.sql.SQLXML;
 import java.sql.Savepoint;
 import java.sql.Statement;
 import java.sql.Struct;
-import java.util.Enumeration;
-import java.util.Map;
-import java.util.Properties;
+import java.util.*;
 import java.util.concurrent.Executor;
 
 public class TSDBConnection implements Connection {
 
-	private TSDBJNIConnector connector = null;
-
-	protected Properties props = null;
-
-	private String catalog = null;
-
-	private TSDBDatabaseMetaData dbMetaData = null;
-
-	private Properties clientInfoProps = new Properties();
-
-	private int timeoutMilliseconds = 0;
-
-	private String tsCharSet = "";
-
-	public TSDBConnection(Properties info, TSDBDatabaseMetaData meta) throws SQLException {
-		this.dbMetaData = meta;
-		connect(info.getProperty(TSDBDriver.PROPERTY_KEY_HOST),
-				Integer.parseInt(info.getProperty(TSDBDriver.PROPERTY_KEY_PORT, "0")),
-				info.getProperty(TSDBDriver.PROPERTY_KEY_DBNAME), info.getProperty(TSDBDriver.PROPERTY_KEY_USER),
-				info.getProperty(TSDBDriver.PROPERTY_KEY_PASSWORD));
-	}
-
-	private void connect(String host, int port, String dbName, String user, String password) throws SQLException {
-		this.connector = new TSDBJNIConnector();
-		this.connector.connect(host, port, dbName, user, password);
-
-		try {
-			this.setCatalog(dbName);
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-
-		this.dbMetaData.setConnection(this);
-	}
-
-	public TSDBJNIConnector getConnection() {
-		return this.connector;
-	}
-
-	public Statement createStatement() throws SQLException {
-		if (!this.connector.isClosed()) {
-			return new TSDBStatement(this.connector);
-		} else {
-			throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
-		}
-	}
-
-	public TSDBSubscribe subscribe(String topic, String sql, boolean restart) throws SQLException {
-		if (this.connector.isClosed()) {
-			throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
-		}
-
-		long id = this.connector.subscribe(topic, sql, restart, 0);
-		if (id == 0) {
-			throw new SQLException(TSDBConstants.WrapErrMsg("failed to create subscription"));
-		}
-
-		return new TSDBSubscribe(this.connector, id);
-	}
-
-	public PreparedStatement prepareStatement(String sql) throws SQLException {
-		if (!this.connector.isClosed()) {
-			return new TSDBPreparedStatement(this.connector, sql);
-		} else {
-			throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
-		}
-	}
-
-	public CallableStatement prepareCall(String sql) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public String nativeSQL(String sql) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void setAutoCommit(boolean autoCommit) throws SQLException {
-	}
-
-	public boolean getAutoCommit() throws SQLException {
-		return true;
-	}
-
-	public void commit() throws SQLException {
-	}
-
-	public void rollback() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void close() throws SQLException {
-		if (this.connector != null && !this.connector.isClosed()) {
-			this.connector.closeConnection();
-		} else {
-			throw new SQLException(TSDBConstants.WrapErrMsg("connection is already closed!"));
-		}
-	}
-
-	public boolean isClosed() throws SQLException {
-		return this.connector.isClosed();
-	}
-
-	/**
-	 * A connection's database is able to provide information describing its tables,
-	 * its supported SQL grammar, its stored procedures, the capabilities of this
-	 * connection, etc. This information is made available through a
-	 * DatabaseMetaData object.
-	 * 
-	 * @return a DatabaseMetaData object for this connection
-	 * @exception SQLException
-	 *                if a database access error occurs
-	 */
-	public DatabaseMetaData getMetaData() throws SQLException {
-		return this.dbMetaData;
-	}
-
-	/**
-	 * This readOnly option is not supported by TDengine. However, the method is intentionally left blank here to
-	 * support HikariCP connection.
-	 * @param readOnly
-	 * @throws SQLException
-	 */
-	public void setReadOnly(boolean readOnly) throws SQLException {
-	}
-
-	public boolean isReadOnly() throws SQLException {
-		return true;
-	}
-
-	public void setCatalog(String catalog) throws SQLException {
-		this.catalog = catalog;
-	}
-
-	public String getCatalog() throws SQLException {
-		return this.catalog;
-	}
-
-	/**
-	 * The transaction isolation level option is not supported by TDengine.
-	 * This method is intentionally left empty to support HikariCP connection.
-	 * @param level
-	 * @throws SQLException
-	 */
-	public void setTransactionIsolation(int level) throws SQLException {
-	}
-
-	/**
-	 * The transaction isolation level option is not supported by TDengine.
-	 * @return
-	 * @throws SQLException
-	 */
-	public int getTransactionIsolation() throws SQLException {
-		return Connection.TRANSACTION_NONE;
-	}
-
-	public SQLWarning getWarnings() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void clearWarnings() throws SQLException {
-		// left blank to support HikariCP connection
-		//todo: implement getWarnings according to the warning messages returned from TDengine
-	}
-
-	public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
-			throws SQLException {
-		// This method is implemented in the current way to support Spark
-		if (resultSetType != ResultSet.TYPE_FORWARD_ONLY) {
-			throw new SQLException(TSDBConstants.INVALID_VARIABLES);
-		}
-
-		if (resultSetConcurrency != ResultSet.CONCUR_READ_ONLY) {
-			throw new SQLException(TSDBConstants.INVALID_VARIABLES);
-		}
-
-		return this.prepareStatement(sql);
-	}
-
-	public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public Map<String, Class<?>> getTypeMap() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void setTypeMap(Map<String, Class<?>> map) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void setHoldability(int holdability) throws SQLException {
-		// intentionally left empty to support druid connection pool.
-	}
-
-	/**
-	 * the transaction is not supported by TDengine, so the opened ResultSet Objects will remain open
-	 * @return
-	 * @throws SQLException
-	 */
-	public int getHoldability() throws SQLException {
-		//intentionally left empty to support HikariCP connection.
-		return ResultSet.HOLD_CURSORS_OVER_COMMIT;
-	}
-
-	public Savepoint setSavepoint() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public Savepoint setSavepoint(String name) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void rollback(Savepoint savepoint) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void releaseSavepoint(Savepoint savepoint) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
-			throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency,
-			int resultSetHoldability) throws SQLException {
-		return this.prepareStatement(sql, resultSetType, resultSetConcurrency);
-	}
-
-	public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency,
-			int resultSetHoldability) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public Clob createClob() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public Blob createBlob() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public NClob createNClob() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public SQLXML createSQLXML() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public boolean isValid(int timeout) throws SQLException {
-		return !this.isClosed();
-	}
-
-	public void setClientInfo(String name, String value) throws SQLClientInfoException {
-		clientInfoProps.setProperty(name, value);
-	}
-
-	public void setClientInfo(Properties properties) throws SQLClientInfoException {
-		for (Enumeration<Object> enumer = properties.keys(); enumer.hasMoreElements();) {
-			String name = (String) enumer.nextElement();
-			clientInfoProps.put(name, properties.getProperty(name));
-		}
-	}
-
-	public String getClientInfo(String name) throws SQLException {
-		return clientInfoProps.getProperty(name);
-	}
-
-	public Properties getClientInfo() throws SQLException {
-		return clientInfoProps;
-	}
-
-	public Array createArrayOf(String typeName, Object[] elements) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public Struct createStruct(String typeName, Object[] attributes) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void setSchema(String schema) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public String getSchema() throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void abort(Executor executor) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException {
-		this.timeoutMilliseconds = milliseconds;
-	}
-
-	public int getNetworkTimeout() throws SQLException {
-		return this.timeoutMilliseconds;
-	}
-
-	public <T> T unwrap(Class<T> iface) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
-
-	public boolean isWrapperFor(Class<?> iface) throws SQLException {
-		throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
-	}
+    private TSDBJNIConnector connector = null;
+
+    protected Properties props = null;
+
+    private String catalog = null;
+
+    private TSDBDatabaseMetaData dbMetaData = null;
+
+    private Properties clientInfoProps = new Properties();
+
+    private int timeoutMilliseconds = 0;
+
+    private String tsCharSet = "";
+
+    public TSDBConnection(Properties info, TSDBDatabaseMetaData meta) throws SQLException {
+        this.dbMetaData = meta;
+
+        //load taos.cfg start
+        File cfgDir = loadConfigDir(info.getProperty(TSDBDriver.PROPERTY_KEY_CONFIG_DIR));
+        File cfgFile = cfgDir.listFiles((dir, name) -> "taos.cfg".equalsIgnoreCase(name))[0];
+        List<String> endpoints = loadConfigEndpoints(cfgFile);
+        if (!endpoints.isEmpty()){
+            info.setProperty(TSDBDriver.PROPERTY_KEY_HOST,endpoints.get(0).split(":")[0]);
+            info.setProperty(TSDBDriver.PROPERTY_KEY_PORT,endpoints.get(0).split(":")[1]);
+        }
+        //load taos.cfg end
+
+        connect(info.getProperty(TSDBDriver.PROPERTY_KEY_HOST),
+                Integer.parseInt(info.getProperty(TSDBDriver.PROPERTY_KEY_PORT, "0")),
+                info.getProperty(TSDBDriver.PROPERTY_KEY_DBNAME), info.getProperty(TSDBDriver.PROPERTY_KEY_USER),
+                info.getProperty(TSDBDriver.PROPERTY_KEY_PASSWORD));
+    }
+
+    private List<String> loadConfigEndpoints(File cfgFile){
+        List<String> endpoints = new ArrayList<>();
+        try(BufferedReader reader = new BufferedReader(new FileReader(cfgFile))) {
+            String line = null;
+            while ((line = reader.readLine())!=null){
+                if (line.trim().startsWith("firstEp") || line.trim().startsWith("secondEp")){
+                    endpoints.add(line.substring(line.indexOf('p')+1).trim());
+                }
+                if (endpoints.size()>1)
+                    break;
+            }
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return endpoints;
+    }
+
+    /**
+     * @param cfgDirPath
+     * @return return the config dir
+     * **/
+    private File loadConfigDir(String cfgDirPath) {
+        if (cfgDirPath == null)
+            return loadDefaultConfigDir();
+        File cfgDir = new File(cfgDirPath);
+        if (!cfgDir.exists())
+            return loadDefaultConfigDir();
+        return cfgDir;
+    }
+
+    /**
+     * @return search the default config dir, if the config dir is not exist will return null
+     * */
+    private File loadDefaultConfigDir(){
+        File cfgDir;
+        File cfgDir_linux = new File("/etc/taos");
+        cfgDir = cfgDir_linux.exists() ? cfgDir_linux : null;
+        File cfgDir_windows = new File("C:\\TDengine\\cfg");
+        cfgDir = (cfgDir == null && cfgDir_windows.exists()) ? cfgDir_windows : cfgDir;
+        return cfgDir;
+    }
+
+    private void connect(String host, int port, String dbName, String user, String password) throws SQLException {
+        this.connector = new TSDBJNIConnector();
+        this.connector.connect(host, port, dbName, user, password);
+
+        try {
+            this.setCatalog(dbName);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+        this.dbMetaData.setConnection(this);
+    }
+
+    public TSDBJNIConnector getConnection() {
+        return this.connector;
+    }
+
+    public Statement createStatement() throws SQLException {
+        if (!this.connector.isClosed()) {
+            return new TSDBStatement(this.connector);
+        } else {
+            throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
+        }
+    }
+
+    public TSDBSubscribe subscribe(String topic, String sql, boolean restart) throws SQLException {
+        if (this.connector.isClosed()) {
+            throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
+        }
+
+        long id = this.connector.subscribe(topic, sql, restart, 0);
+        if (id == 0) {
+            throw new SQLException(TSDBConstants.WrapErrMsg("failed to create subscription"));
+        }
+
+        return new TSDBSubscribe(this.connector, id);
+    }
+
+    public PreparedStatement prepareStatement(String sql) throws SQLException {
+        if (!this.connector.isClosed()) {
+            return new TSDBPreparedStatement(this.connector, sql);
+        } else {
+            throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
+        }
+    }
+
+    public CallableStatement prepareCall(String sql) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public String nativeSQL(String sql) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void setAutoCommit(boolean autoCommit) throws SQLException {
+    }
+
+    public boolean getAutoCommit() throws SQLException {
+        return true;
+    }
+
+    public void commit() throws SQLException {
+    }
+
+    public void rollback() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void close() throws SQLException {
+        if (this.connector != null && !this.connector.isClosed()) {
+            this.connector.closeConnection();
+        } else {
+            throw new SQLException(TSDBConstants.WrapErrMsg("connection is already closed!"));
+        }
+    }
+
+    public boolean isClosed() throws SQLException {
+        return this.connector.isClosed();
+    }
+
+    /**
+     * A connection's database is able to provide information describing its tables,
+     * its supported SQL grammar, its stored procedures, the capabilities of this
+     * connection, etc. This information is made available through a
+     * DatabaseMetaData object.
+     *
+     * @return a DatabaseMetaData object for this connection
+     * @throws SQLException if a database access error occurs
+     */
+    public DatabaseMetaData getMetaData() throws SQLException {
+        return this.dbMetaData;
+    }
+
+    /**
+     * This readOnly option is not supported by TDengine. However, the method is intentionally left blank here to
+     * support HikariCP connection.
+     *
+     * @param readOnly
+     * @throws SQLException
+     */
+    public void setReadOnly(boolean readOnly) throws SQLException {
+    }
+
+    public boolean isReadOnly() throws SQLException {
+        return true;
+    }
+
+    public void setCatalog(String catalog) throws SQLException {
+        this.catalog = catalog;
+    }
+
+    public String getCatalog() throws SQLException {
+        return this.catalog;
+    }
+
+    /**
+     * The transaction isolation level option is not supported by TDengine.
+     * This method is intentionally left empty to support HikariCP connection.
+     *
+     * @param level
+     * @throws SQLException
+     */
+    public void setTransactionIsolation(int level) throws SQLException {
+    }
+
+    /**
+     * The transaction isolation level option is not supported by TDengine.
+     *
+     * @return
+     * @throws SQLException
+     */
+    public int getTransactionIsolation() throws SQLException {
+        return Connection.TRANSACTION_NONE;
+    }
+
+    public SQLWarning getWarnings() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void clearWarnings() throws SQLException {
+        // left blank to support HikariCP connection
+        //todo: implement getWarnings according to the warning messages returned from TDengine
+    }
+
+    public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
+            throws SQLException {
+        // This method is implemented in the current way to support Spark
+        if (resultSetType != ResultSet.TYPE_FORWARD_ONLY) {
+            throw new SQLException(TSDBConstants.INVALID_VARIABLES);
+        }
+
+        if (resultSetConcurrency != ResultSet.CONCUR_READ_ONLY) {
+            throw new SQLException(TSDBConstants.INVALID_VARIABLES);
+        }
+
+        return this.prepareStatement(sql);
+    }
+
+    public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public Map<String, Class<?>> getTypeMap() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void setTypeMap(Map<String, Class<?>> map) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void setHoldability(int holdability) throws SQLException {
+        // intentionally left empty to support druid connection pool.
+    }
+
+    /**
+     * the transaction is not supported by TDengine, so the opened ResultSet Objects will remain open
+     *
+     * @return
+     * @throws SQLException
+     */
+    public int getHoldability() throws SQLException {
+        //intentionally left empty to support HikariCP connection.
+        return ResultSet.HOLD_CURSORS_OVER_COMMIT;
+    }
+
+    public Savepoint setSavepoint() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public Savepoint setSavepoint(String name) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void rollback(Savepoint savepoint) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void releaseSavepoint(Savepoint savepoint) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
+            throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency,
+                                              int resultSetHoldability) throws SQLException {
+        return this.prepareStatement(sql, resultSetType, resultSetConcurrency);
+    }
+
+    public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency,
+                                         int resultSetHoldability) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public Clob createClob() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public Blob createBlob() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public NClob createNClob() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public SQLXML createSQLXML() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public boolean isValid(int timeout) throws SQLException {
+        return !this.isClosed();
+    }
+
+    public void setClientInfo(String name, String value) throws SQLClientInfoException {
+        clientInfoProps.setProperty(name, value);
+    }
+
+    public void setClientInfo(Properties properties) throws SQLClientInfoException {
+        for (Enumeration<Object> enumer = properties.keys(); enumer.hasMoreElements(); ) {
+            String name = (String) enumer.nextElement();
+            clientInfoProps.put(name, properties.getProperty(name));
+        }
+    }
+
+    public String getClientInfo(String name) throws SQLException {
+        return clientInfoProps.getProperty(name);
+    }
+
+    public Properties getClientInfo() throws SQLException {
+        return clientInfoProps;
+    }
+
+    public Array createArrayOf(String typeName, Object[] elements) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public Struct createStruct(String typeName, Object[] attributes) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void setSchema(String schema) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public String getSchema() throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void abort(Executor executor) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException {
+        this.timeoutMilliseconds = milliseconds;
+    }
+
+    public int getNetworkTimeout() throws SQLException {
+        return this.timeoutMilliseconds;
+    }
+
+    public <T> T unwrap(Class<T> iface) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
+
+    public boolean isWrapperFor(Class<?> iface) throws SQLException {
+        throw new SQLException(TSDBConstants.UNSUPPORT_METHOD_EXCEPTIONZ_MSG);
+    }
 }