github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[#1177] Add SQL Console module to jOOQ - fixed infinite loop on certain

Browse Source 
RDBMS.
This commit is contained in:
Chrriis 2012-11-08 11:47:04 +01:00
parent d39a5dcb1c
commit 9453aa3a3c
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jOOQ-console/src/main/java/org/jooq/debug/impl/LocalStatementExecutor.java
View File

@ -151,6 +151,7 @@ class LocalStatementExecutor implements QueryExecutor {
return new QueryExecution(executionDuration, new QueryExecutionMessageResult("Interrupted by user after " + Utils.formatDuration(executionDuration), true));
}
List<QueryExecutionResult> statementExecutionResultList = new ArrayList<QueryExecutionResult>();
int updateCount = stmt.getUpdateCount();
do {
QueryExecutionResult queryExecutionResult;
if(executeResult) {
@ -294,7 +295,6 @@ class LocalStatementExecutor implements QueryExecutor {
final long resultSetParsingDuration = System.currentTimeMillis() - rsStart;
queryExecutionResult = new LocalStatementExecutionResultSetResult(rs, columnNames, typeInfos, columnClasses, rowDataList.toArray(new Object[0][]), rowCount, resultSetParsingDuration, retainParsedRSDataRowCountThreshold, isReadOnly);
} else {
final int updateCount = stmt.getUpdateCount();
queryExecutionResult = new QueryExecutionMessageResult(Utils.formatDuration(executionDuration) + "> " + updateCount + " row(s) affected.", false);
}
if(executorContext.getSQLDialect() == SQLDialect.SQLSERVER) {
@ -303,11 +303,13 @@ class LocalStatementExecutor implements QueryExecutor {
} catch(Exception e) {
executeResult = stmt.getMoreResults();
}
updateCount = stmt.getUpdateCount();
} else {
executeResult = false;
updateCount = -1;
}
statementExecutionResultList.add(queryExecutionResult);
} while(executeResult || stmt.getUpdateCount() != -1);
} while(executeResult || updateCount != -1);
return new QueryExecution(executionDuration, statementExecutionResultList.toArray(new QueryExecutionResult[0]));
} catch(Exception e) {
long executionDuration = System.currentTimeMillis() - start;