[incubator-iotdb] 01/01: remove check is query in session

[qi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch remove_check_query_in_session
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git

commit ea5a76b9418dcf0d6be3569b77cf2c9adefcd5d9
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Apr 21 17:37:44 2020 +0800

    remove check is query in session
---
 .../main/java/org/apache/iotdb/session/Session.java   | 19 -------------------
 1 file changed, 19 deletions(-)

diff --git a/session/src/main/java/org/apache/iotdb/session/Session.java b/session/src/main/java/org/apache/iotdb/session/Session.java
index bb8ba86..ebafa6b 100644
--- a/session/src/main/java/org/apache/iotdb/session/Session.java
+++ b/session/src/main/java/org/apache/iotdb/session/Session.java
@@ -655,16 +655,6 @@ public class Session {
     this.zoneId = ZoneId.of(zoneId);
   }
 
-  /**
-   * check whether this sql is for query
-   *
-   * @param sql sql
-   * @return whether this sql is for query
-   */
-  private boolean checkIsQuery(String sql) {
-    sql = sql.trim().toLowerCase();
-    return sql.startsWith("select") || sql.startsWith("show") || sql.startsWith("list");
-  }
 
   /**
    * execure query sql
@@ -674,10 +664,6 @@ public class Session {
    */
   public SessionDataSet executeQueryStatement(String sql)
       throws StatementExecutionException, IoTDBConnectionException {
-    if (!checkIsQuery(sql)) {
-      throw new IllegalArgumentException("your sql \"" + sql
-          + "\" is not a query statement, you should use executeNonQueryStatement method instead.");
-    }
 
     TSExecuteStatementReq execReq = new TSExecuteStatementReq(sessionId, sql, statementId);
     execReq.setFetchSize(fetchSize);
@@ -700,11 +686,6 @@ public class Session {
    */
   public void executeNonQueryStatement(String sql)
       throws IoTDBConnectionException, StatementExecutionException {
-    if (checkIsQuery(sql)) {
-      throw new IllegalArgumentException("your sql \"" + sql
-          + "\" is a query statement, you should use executeQueryStatement method instead.");
-    }
-
     TSExecuteStatementReq execReq = new TSExecuteStatementReq(sessionId, sql, statementId);
     try {
       TSExecuteStatementResp execResp = client.executeUpdateStatement(execReq);