in src/main/java/com/aliyun/ha3engine/jdbc/Ha3Connection.java [110:118]
public Statement createStatement() throws SQLException {
checkClosed();
if (this.cloudClient == null) {
throw new SQLException("Unable to connect on specified schema '" + this.schema + "'");
}
Ha3Statement st = new Ha3Statement(this, cloudClient);
statements.add(st);
return st;
}