From b538c4448a9d4c1dc5b4dce5c2e8b03c886601c0 Mon Sep 17 00:00:00 2001 From: Herval Freire Date: Thu, 22 Jun 2017 10:46:26 -0700 Subject: [PATCH 1/2] limiting results from jdbc --- .../src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java index 948914ff190..65d3f08a8d2 100644 --- a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java +++ b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java @@ -681,6 +681,8 @@ private InterpreterResult executeSql(String propertyKey, String sql, for (int i = 0; i < sqlArray.size(); i++) { String sqlToExecute = sqlArray.get(i); statement = connection.createStatement(); + statement.setFetchSize(getMaxResult()); + if (statement == null) { return new InterpreterResult(Code.ERROR, "Prefix not found."); } From 4f664690f0f04676bb1b74e9164138cdb3fcb240 Mon Sep 17 00:00:00 2001 From: Herval Freire Date: Thu, 29 Jun 2017 12:39:07 -0700 Subject: [PATCH 2/2] display truncation message --- .../main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java index 65d3f08a8d2..8415e67e379 100644 --- a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java +++ b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java @@ -681,7 +681,10 @@ private InterpreterResult executeSql(String propertyKey, String sql, for (int i = 0; i < sqlArray.size(); i++) { String sqlToExecute = sqlArray.get(i); statement = connection.createStatement(); + + // fetch n+1 rows in order to indicate there's more rows available (for large selects) statement.setFetchSize(getMaxResult()); + statement.setMaxRows(getMaxResult() + 1); if (statement == null) { return new InterpreterResult(Code.ERROR, "Prefix not found.");