作者 朱兆平

已ROWNUM为基础,发送数据

@@ -118,7 +118,6 @@ public class DaoImpl implements Dao { @@ -118,7 +118,6 @@ public class DaoImpl implements Dao {
118 } 118 }
119 119
120 public List<MessageBak> getRecordByFID(int fid) { 120 public List<MessageBak> getRecordByFID(int fid) {
121 - String SQL_FMT = "select FID,CONTENT from MESSAGE_BAK WHERE (FID>%s and FID<%s+%s) AND (TYPE='CLR' OR TYPE='ES1' OR TYPE='IS1' OR STYP = 'BSTA' OR STYP = 'FZE_RCF' OR STYP = 'FSU_FOH' OR STYP = 'FSU_DEP' OR STYP = 'COST' OR STYP = 'ABME' OR STYP = 'FZE_DEP' OR STYP = 'FSU_RCF') ORDER BY FID ";  
122 //从配置文件读取sql语句 121 //从配置文件读取sql语句
123 String sql_select=ConfigUtils.SQl; 122 String sql_select=ConfigUtils.SQl;
124 String sql = String.format(sql_select, fid, fid, ConfigUtils.RECORD_COUNT); //这里修改从FID_INDEX文件读取的FID ,改为取搜索结果的rownum 123 String sql = String.format(sql_select, fid, fid, ConfigUtils.RECORD_COUNT); //这里修改从FID_INDEX文件读取的FID ,改为取搜索结果的rownum
@@ -130,11 +129,10 @@ public class DaoImpl implements Dao { @@ -130,11 +129,10 @@ public class DaoImpl implements Dao {
130 this.jdbcTemplate.query(sql, new AbstractLobStreamingResultSetExtractor() { 129 this.jdbcTemplate.query(sql, new AbstractLobStreamingResultSetExtractor() {
131 protected void streamData(ResultSet rs) throws SQLException, IOException, DataAccessException { 130 protected void streamData(ResultSet rs) throws SQLException, IOException, DataAccessException {
132 String content = ""; 131 String content = "";
133 - int rownum=0;  
134 while(rs.next()) { 132 while(rs.next()) {
135 int fid = rs.getInt(1); 133 int fid = rs.getInt(1);
136 content = lobHandler.getClobAsString(rs, "CONTENT"); 134 content = lobHandler.getClobAsString(rs, "CONTENT");
137 - rownum = rs.getInt("rownum_"); 135 + int rownum = rs.getInt("rownum_");
138 if (content != null) { 136 if (content != null) {
139 MessageBak obj = new MessageBak(fid, content,rownum); 137 MessageBak obj = new MessageBak(fid, content,rownum);
140 xmlList.add(obj); 138 xmlList.add(obj);