提交 825fd604 authored 作者: Thomas Mueller's avatar Thomas Mueller

Temporary files from LOB objects were not deleted early enough when using the server mode.

上级 b765cef0
...@@ -33,10 +33,12 @@ public class ResultRemote implements ResultInterface { ...@@ -33,10 +33,12 @@ public class ResultRemote implements ResultInterface {
private int rowId, rowCount, rowOffset; private int rowId, rowCount, rowOffset;
private ObjectArray<Value[]> result; private ObjectArray<Value[]> result;
private ObjectArray<Value> lobValues; private ObjectArray<Value> lobValues;
private final Trace trace;
public ResultRemote(SessionRemote session, Transfer transfer, int id, int columnCount, int fetchSize) public ResultRemote(SessionRemote session, Transfer transfer, int id, int columnCount, int fetchSize)
throws IOException, SQLException { throws IOException, SQLException {
this.session = session; this.session = session;
trace = session.getTrace();
this.transfer = transfer; this.transfer = transfer;
this.id = id; this.id = id;
this.columns = new ResultColumn[columnCount]; this.columns = new ResultColumn[columnCount];
...@@ -150,7 +152,7 @@ public class ResultRemote implements ResultInterface { ...@@ -150,7 +152,7 @@ public class ResultRemote implements ResultInterface {
transfer.writeInt(SessionRemote.RESULT_CLOSE).writeInt(id); transfer.writeInt(SessionRemote.RESULT_CLOSE).writeInt(id);
} }
} catch (IOException e) { } catch (IOException e) {
session.getTrace().error("close", e); trace.error("close", e);
} finally { } finally {
transfer = null; transfer = null;
session = null; session = null;
...@@ -158,12 +160,6 @@ public class ResultRemote implements ResultInterface { ...@@ -158,12 +160,6 @@ public class ResultRemote implements ResultInterface {
} }
public void close() { public void close() {
if (session == null) {
return;
}
result = null;
Trace trace = session.getTrace();
sendClose();
if (lobValues != null) { if (lobValues != null) {
for (Value v : lobValues) { for (Value v : lobValues) {
try { try {
...@@ -174,6 +170,8 @@ public class ResultRemote implements ResultInterface { ...@@ -174,6 +170,8 @@ public class ResultRemote implements ResultInterface {
} }
lobValues = null; lobValues = null;
} }
result = null;
sendClose();
} }
private void remapIfOld() throws SQLException { private void remapIfOld() throws SQLException {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论