Browse Source

修改结果集处理问题

koul 4 years ago
parent
commit
bec0bd38cf

+ 0 - 1
src/main/java/com/uas/service/Impl/SendHttpImpl.java

@@ -258,7 +258,6 @@ public class SendHttpImpl implements SendHttp {
                 map.put("cd_varchar50_2", cd_varchar50_2);
                 maps.add(map);
             }
-            /*rs.close();*/
         } catch (SQLException e) {
             BaseUtil.logger.error("263"+e.getMessage());
             e.printStackTrace();

+ 2 - 5
src/main/java/com/uas/service/Impl/UploadAttachImpl.java

@@ -62,8 +62,7 @@ public class UploadAttachImpl implements UploadAttach {
                     String cd_varchar50_4 = map.get("cd_varchar50_4");
                     if (cd_varchar50_9!=null) {
                         cd_varchar50_9 = cd_varchar50_9.replace(";", ",").substring(0, cd_varchar50_9.length() - 1);
-                        uploadAttachFtp(statement,sob,cd_varchar50_9,client,config.get("ip").toString(),folder,
-                                cd_varchar50_4,s,cd_id);
+                        uploadAttachFtp(statement,sob,cd_varchar50_9,client,config.get("ip").toString(),folder, cd_varchar50_4,s,cd_id);
                     }
                 }
             }
@@ -122,8 +121,7 @@ public class UploadAttachImpl implements UploadAttach {
     }
     private void uploadAttachFtp(Statement statement,String sob,String attach,FTPClient client,String ip,
                                  String folder,String attachName,String dateString,String cd_id) throws SQLException {
-        ResultSet res = statement.executeQuery("select fp_path from " + sob + ".filepath where " +
-                "fp_id in (" + attach + ")");
+        ResultSet res = statement.executeQuery("select fp_path from " + sob + ".filepath where fp_id in (" + attach + ")");
         while (res.next()) {
             String path = res.getString("fp_path");
             String substring = path.substring(path.lastIndexOf("."));
@@ -136,7 +134,6 @@ public class UploadAttachImpl implements UploadAttach {
                 }
             }
         }
-        res.close();
     }
 
     private boolean upload(FTPClient client,String ip,String folder,File file,String name){