feat(jdbc): implement PreparedStatement

integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBPreparedStatementIT.java → integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBTablePreparedStatementIT.java

@@ -45,7 +45,7 @@
 
 @RunWith(IoTDBTestRunner.class)
 @Category({TableLocalStandaloneIT.class, TableClusterIT.class})
-public class IoTDBPreparedStatementIT {
+public class IoTDBTablePreparedStatementIT {
   private static final String DATABASE_NAME = "test";
   private static final String[] sqls =
       new String[] {

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java

@@ -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

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java

@@ -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;
 
@@ -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;
@@ -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;