Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -433,7 +433,11 @@ public CallableStatement prepareCall(String arg0, int arg1, int arg2, int arg3)

@Override
public PreparedStatement prepareStatement(String sql) throws SQLException {
return new IoTDBPreparedStatement(this, getClient(), sessionId, sql, zoneId, charset);
if (getSqlDialect().equals(Constant.TABLE_DIALECT)) {
return new IoTDBTablePreparedStatement(this, getClient(), sessionId, sql, zoneId, charset);
} else {
return new IoTDBPreparedStatement(this, getClient(), sessionId, sql, zoneId, charset);
}
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public class IoTDBStatement implements Statement {

private final IoTDBConnection connection;

private ResultSet resultSet = null;
protected ResultSet resultSet = null;
private int fetchSize;
private int maxRows = 0;

Expand All @@ -66,7 +66,7 @@ public class IoTDBStatement implements Statement {
* Timeout of query can be set by users. Unit: s. A negative number means using the default
* configuration of server. And value 0 will disable the function of query timeout.
*/
private int queryTimeout = -1;
protected int queryTimeout = -1;

protected IClientRPCService.Iface client;
private List<String> batchSQLList;
Expand All @@ -82,7 +82,7 @@ public class IoTDBStatement implements Statement {
/** Add SQLWarnings to the warningChain if needed. */
private SQLWarning warningChain = null;

private long sessionId;
protected long sessionId;
private long stmtId = -1;
private long queryId = -1;

Expand Down
Loading