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

[#5106] Result.formatXXX() methods should flush Writers to prevent data loss

Browse Source
This commit is contained in:
lukaseder 2016-02-24 21:02:49 +01:00
parent d289c17229
commit dde5d91bb4
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
jOOQ/src/main/java/org/jooq/impl/ResultImpl.java
View File

@ -556,6 +556,8 @@ final class ResultImpl<R extends Record> implements Result<R>, AttachableInterna
writer.append("" + (size() - maxRecords));
writer.append(" record(s) truncated...");
}
writer.flush();
}
catch (java.io.IOException e) {
throw new IOException("Exception while writing TEXT", e);
@ -633,6 +635,8 @@ final class ResultImpl<R extends Record> implements Result<R>, AttachableInterna
writer.append("</tbody>");
writer.append("</table>");
writer.flush();
}
catch (java.io.IOException e) {
throw new IOException("Exception while writing HTML", e);
@ -774,6 +778,8 @@ final class ResultImpl<R extends Record> implements Result<R>, AttachableInterna
writer.append(format.newline());
}
writer.flush();
}
catch (java.io.IOException e) {
throw new IOException("Exception while writing CSV", e);
@ -894,6 +900,8 @@ final class ResultImpl<R extends Record> implements Result<R>, AttachableInterna
map.put("records", r);
writer.append(JSONObject.toJSONString(map));
writer.flush();
}
catch (java.io.IOException e) {
throw new IOException("Exception while writing JSON", e);
@ -975,6 +983,8 @@ final class ResultImpl<R extends Record> implements Result<R>, AttachableInterna
writer.append("</records>");
writer.append("</result>");
writer.flush();
}
catch (java.io.IOException e) {
throw new IOException("Exception while writing XML", e);
@ -1027,6 +1037,8 @@ final class ResultImpl<R extends Record> implements Result<R>, AttachableInterna
writer.append(ctx.renderInlined(insertInto(table, f).values(record.intoArray())));
writer.append(";\n");
}
writer.flush();
}
catch (java.io.IOException e) {
throw new IOException("Exception while writing INSERTs", e);