From fee9f7404070d6ff0d17cb4bde07eef86cbf2ad5 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 20 Aug 2020 15:01:09 +0800 Subject: [PATCH] fix jdbc memory leaks. #3098 --- .../src/main/java/com/taosdata/jdbc/TSDBStatement.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBStatement.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBStatement.java index 075a351661..a36f7c67a0 100644 --- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBStatement.java +++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBStatement.java @@ -33,6 +33,7 @@ public class TSDBStatement implements Statement { * Status of current statement */ private boolean isClosed = true; + private int affectedRows = 0; TSDBStatement(TSDBJNIConnector connecter) { this.connecter = connecter; @@ -91,9 +92,10 @@ public class TSDBStatement implements Statement { throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL)); } - int num = this.connecter.getAffectedRows(pSql); + this.affectedRows = this.connecter.getAffectedRows(pSql); this.connecter.freeResultSet(pSql); - return num; + + return this.affectedRows; } public String getErrorMsg(long pSql) { @@ -190,7 +192,8 @@ public class TSDBStatement implements Statement { if (isClosed) { throw new SQLException("Invalid method call on a closed statement."); } - return this.connecter.getAffectedRows(this.pSql); + + return this.affectedRows; } public boolean getMoreResults() throws SQLException {