未验证 提交 1b7eab59 编写于 作者: R Rui,Lei 提交者: GitHub

[IOTDB-5316] fix bug that Session.setFetchSize is not used in the following fetch requests

上级 954e682f
......@@ -100,6 +100,37 @@ public class SessionDataSet implements AutoCloseable {
timeout);
}
public SessionDataSet(
String sql,
List<String> columnNameList,
List<String> columnTypeList,
Map<String, Integer> columnNameIndex,
long queryId,
long statementId,
IClientRPCService.Iface client,
long sessionId,
List<ByteBuffer> queryResult,
boolean ignoreTimeStamp,
long timeout,
boolean moreData,
int fetchSize) {
this.ioTDBRpcDataSet =
new IoTDBRpcDataSet(
sql,
columnNameList,
columnTypeList,
columnNameIndex,
ignoreTimeStamp,
moreData,
queryId,
statementId,
client,
sessionId,
queryResult,
fetchSize,
timeout);
}
public int getFetchSize() {
return ioTDBRpcDataSet.fetchSize;
}
......
......@@ -381,7 +381,8 @@ public class SessionConnection {
execResp.queryResult,
execResp.isIgnoreTimeStamp(),
timeout,
execResp.moreData);
execResp.moreData,
session.fetchSize);
}
protected void executeNonQueryStatement(String sql)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册