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

Closing streams that were not properly closed.

Browse Source
This commit is contained in:
Chrriis 2012-10-25 19:02:31 +02:00
parent c624a8c1d2
commit b8a3cfd6d6
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -240,8 +240,12 @@ class LocalStatementExecutor implements QueryExecutor {
StringWriter stringWriter = new StringWriter();
char[] chars = new char[1024];
Reader reader = new BufferedReader(clob.getCharacterStream());
for(int count; (count=reader.read(chars))>=0; ) {
stringWriter.write(chars, 0, count);
try {
for(int count; (count=reader.read(chars))>=0; ) {
stringWriter.write(chars, 0, count);
}
} finally {
reader.close();
}
rowData[i] = stringWriter.toString();
} else {
@ -255,8 +259,12 @@ class LocalStatementExecutor implements QueryExecutor {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte[] bytes = new byte[1024];
InputStream in = new BufferedInputStream(blob.getBinaryStream());
for(int count; (count=in.read(bytes))>=0; ) {
baos.write(bytes, 0, count);
try {
for(int count; (count=in.read(bytes))>=0; ) {
baos.write(bytes, 0, count);
}
} finally {
in.close();
}
rowData[i] = baos.toByteArray();
} else {